apache_beam.transforms.sideinputs module

Internal side input transforms and implementations.

For internal use only; no backwards-compatibility guarantees.

Important: this module is an implementation detail and should not be used directly by pipeline writers. Instead, users should use the helper methods AsSingleton, AsIter, AsList and AsDict in apache_beam.pvalue.

apache_beam.transforms.sideinputs.default_window_mapping_fn(target_window_fn: WindowFn) → Callable[[BoundedWindow], BoundedWindow]

apache_beam.transforms.sideinputs.get_sideinput_index(tag: str) → int

class apache_beam.transforms.sideinputs.SideInputMap(view_class: pvalue.AsSideInput, view_options, iterable)

Bases: object

Represents a mapping of windows to side input values.

is_globally_windowed() → bool