fiftyone.utils.beam.MergeBatch

class documentation

class MergeBatch(beam.DoFn): (source)

Constructor: MergeBatch(dataset_name, parse_fcn, key_field, key_fcn, ...)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method finish_bundle Undocumented
Method process Undocumented
Method setup Undocumented
Method start_bundle Undocumented
Instance Variable dataset_name Undocumented
Instance Variable expand_schema Undocumented
Instance Variable key_fcn Undocumented
Instance Variable key_field Undocumented
Instance Variable kwargs Undocumented
Instance Variable parse_fcn Undocumented
Instance Variable _dataset Undocumented
Instance Variable _id_map Undocumented
Instance Variable _key_fcn Undocumented
Instance Variable _samples Undocumented
def __init__(self, dataset_name, parse_fcn=None, key_field='filepath', key_fcn=None, expand_schema=True, **kwargs): (source)

Undocumented

def finish_bundle(self): (source)

Undocumented

def process(self, sample): (source)

Undocumented

def setup(self): (source)

Undocumented

def start_bundle(self): (source)

Undocumented

dataset_name = (source)

Undocumented

expand_schema = (source)

Undocumented

key_fcn = (source)

Undocumented

key_field = (source)

Undocumented

kwargs = (source)

Undocumented

parse_fcn = (source)

Undocumented

_dataset = (source)

Undocumented

_id_map = (source)

Undocumented

_key_fcn = (source)

Undocumented

_samples: list = (source)

Undocumented