apache_beam.transforms.combinefn_lifecycle_pipeline module

class apache_beam.transforms.combinefn_lifecycle_pipeline.CallSequenceEnforcingCombineFn

Bases: apache_beam.transforms.core.CombineFn

instances = {}

setup(*args, **kwargs)

create_accumulator(*args, **kwargs)

add_input(mutable_accumulator, element, *args, **kwargs)

add_inputs(mutable_accumulator, elements, *args, **kwargs)

merge_accumulators(accumulators, *args, **kwargs)

extract_output(accumulator, *args, **kwargs)

teardown(*args, **kwargs)

class apache_beam.transforms.combinefn_lifecycle_pipeline.IndexAssigningDoFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

state_param = StateParam(index)

process(element, state=StateParam(index))

apache_beam.transforms.combinefn_lifecycle_pipeline.run_combine(pipeline, input_elements=5, lift_combiners=True)

apache_beam.transforms.combinefn_lifecycle_pipeline.run_pardo(pipeline, input_elements=10)