apache_beam.transforms.combinefn_lifecycle_pipeline module

class apache_beam.transforms.combinefn_lifecycle_pipeline.CallSequenceEnforcingCombineFn[source]

Bases: apache_beam.transforms.core.CombineFn

instances = {}
setup(*args, **kwargs)[source]
create_accumulator(*args, **kwargs)[source]
add_input(mutable_accumulator, element, *args, **kwargs)[source]
add_inputs(mutable_accumulator, elements, *args, **kwargs)[source]
merge_accumulators(accumulators, *args, **kwargs)[source]
extract_output(accumulator, *args, **kwargs)[source]
teardown(*args, **kwargs)[source]
class apache_beam.transforms.combinefn_lifecycle_pipeline.IndexAssigningDoFn(*unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

state_param = StateParam(index)
process(element, state=StateParam(index))[source]
apache_beam.transforms.combinefn_lifecycle_pipeline.run_combine(pipeline, input_elements=5, lift_combiners=True)[source]
apache_beam.transforms.combinefn_lifecycle_pipeline.run_pardo(pipeline, input_elements=10)[source]