apache_beam.portability.api.beam_runner_api_pb2_urns module

class apache_beam.portability.api.beam_runner_api_pb2_urns.AccumulationMode

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

DISCARDING = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

ACCUMULATING = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

RETRACTING = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.BeamConstants

Bases: object

class Constants

Bases: object

MIN_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn=u'', constant=u'-9223372036854775', spec=, label_props=)

MAX_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn=u'', constant=u'9223372036854775', spec=, label_props=)

GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn=u'', constant=u'9223371950454775', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.ClosingBehavior

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

EMIT_ALWAYS = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

EMIT_IF_NONEMPTY = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.DisplayData

Bases: object

class Type

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

STRING = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

INTEGER = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

FLOAT = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

BOOLEAN = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

TIMESTAMP = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

DURATION = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

JAVA_CLASS = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.IsBounded

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

UNBOUNDED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

BOUNDED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.MergeStatus

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

NON_MERGING = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

NEEDS_MERGE = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

ALREADY_MERGED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.OnTimeBehavior

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

FIRE_ALWAYS = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

FIRE_IF_NONEMPTY = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.OutputTime

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

END_OF_WINDOW = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

LATEST_IN_PANE = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

EARLIEST_IN_PANE = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.Parameter

Bases: object

class Type

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

WINDOW = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

PIPELINE_OPTIONS = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

RESTRICTION_TRACKER = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardCoders

Bases: object

class Enum

Bases: object

BYTES = PropertiesFromEnumValue(urn=u'beam:coder:bytes:v1', constant=u'', spec=, label_props=)

STRING_UTF8 = PropertiesFromEnumValue(urn=u'beam:coder:string_utf8:v1', constant=u'', spec=, label_props=)

KV = PropertiesFromEnumValue(urn=u'beam:coder:kv:v1', constant=u'', spec=, label_props=)

BOOL = PropertiesFromEnumValue(urn=u'beam:coder:bool:v1', constant=u'', spec=, label_props=)

VARINT = PropertiesFromEnumValue(urn=u'beam:coder:varint:v1', constant=u'', spec=, label_props=)

DOUBLE = PropertiesFromEnumValue(urn=u'beam:coder:double:v1', constant=u'', spec=, label_props=)

ITERABLE = PropertiesFromEnumValue(urn=u'beam:coder:iterable:v1', constant=u'', spec=, label_props=)

TIMER = PropertiesFromEnumValue(urn=u'beam:coder:timer:v1', constant=u'', spec=, label_props=)

INTERVAL_WINDOW = PropertiesFromEnumValue(urn=u'beam:coder:interval_window:v1', constant=u'', spec=, label_props=)

LENGTH_PREFIX = PropertiesFromEnumValue(urn=u'beam:coder:length_prefix:v1', constant=u'', spec=, label_props=)

GLOBAL_WINDOW = PropertiesFromEnumValue(urn=u'beam:coder:global_window:v1', constant=u'', spec=, label_props=)

WINDOWED_VALUE = PropertiesFromEnumValue(urn=u'beam:coder:windowed_value:v1', constant=u'', spec=, label_props=)

PARAM_WINDOWED_VALUE = PropertiesFromEnumValue(urn=u'beam:coder:param_windowed_value:v1', constant=u'', spec=, label_props=)

STATE_BACKED_ITERABLE = PropertiesFromEnumValue(urn=u'beam:coder:state_backed_iterable:v1', constant=u'', spec=, label_props=)

ROW = PropertiesFromEnumValue(urn=u'beam:coder:row:v1', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardEnvironments

Bases: object

class Environments

Bases: object

DOCKER = PropertiesFromEnumValue(urn=u'beam:env:docker:v1', constant=u'', spec=, label_props=)

PROCESS = PropertiesFromEnumValue(urn=u'beam:env:process:v1', constant=u'', spec=, label_props=)

EXTERNAL = PropertiesFromEnumValue(urn=u'beam:env:external:v1', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardPTransforms

Bases: object

class CombineComponents

Bases: object

COMBINE_PER_KEY_PRECOMBINE = PropertiesFromEnumValue(urn=u'beam:transform:combine_per_key_precombine:v1', constant=u'', spec=, label_props=)

COMBINE_PER_KEY_MERGE_ACCUMULATORS = PropertiesFromEnumValue(urn=u'beam:transform:combine_per_key_merge_accumulators:v1', constant=u'', spec=, label_props=)

COMBINE_PER_KEY_EXTRACT_OUTPUTS = PropertiesFromEnumValue(urn=u'beam:transform:combine_per_key_extract_outputs:v1', constant=u'', spec=, label_props=)

COMBINE_GROUPED_VALUES = PropertiesFromEnumValue(urn=u'beam:transform:combine_grouped_values:v1', constant=u'', spec=, label_props=)

class Composites

Bases: object

COMBINE_PER_KEY = PropertiesFromEnumValue(urn=u'beam:transform:combine_per_key:v1', constant=u'', spec=, label_props=)

COMBINE_GLOBALLY = PropertiesFromEnumValue(urn=u'beam:transform:combine_globally:v1', constant=u'', spec=, label_props=)

RESHUFFLE = PropertiesFromEnumValue(urn=u'beam:transform:reshuffle:v1', constant=u'', spec=, label_props=)

WRITE_FILES = PropertiesFromEnumValue(urn=u'beam:transform:write_files:v1', constant=u'', spec=, label_props=)

class DeprecatedPrimitives

Bases: object

READ = PropertiesFromEnumValue(urn=u'beam:transform:read:v1', constant=u'', spec=, label_props=)

CREATE_VIEW = PropertiesFromEnumValue(urn=u'beam:transform:create_view:v1', constant=u'', spec=, label_props=)

class Primitives

Bases: object

PAR_DO = PropertiesFromEnumValue(urn=u'beam:transform:pardo:v1', constant=u'', spec=, label_props=)

FLATTEN = PropertiesFromEnumValue(urn=u'beam:transform:flatten:v1', constant=u'', spec=, label_props=)

GROUP_BY_KEY = PropertiesFromEnumValue(urn=u'beam:transform:group_by_key:v1', constant=u'', spec=, label_props=)

IMPULSE = PropertiesFromEnumValue(urn=u'beam:transform:impulse:v1', constant=u'', spec=, label_props=)

ASSIGN_WINDOWS = PropertiesFromEnumValue(urn=u'beam:transform:window_into:v1', constant=u'', spec=, label_props=)

TEST_STREAM = PropertiesFromEnumValue(urn=u'beam:transform:teststream:v1', constant=u'', spec=, label_props=)

MAP_WINDOWS = PropertiesFromEnumValue(urn=u'beam:transform:map_windows:v1', constant=u'', spec=, label_props=)

MERGE_WINDOWS = PropertiesFromEnumValue(urn=u'beam:transform:merge_windows:v1', constant=u'', spec=, label_props=)

class SplittableParDoComponents

Bases: object

PAIR_WITH_RESTRICTION = PropertiesFromEnumValue(urn=u'beam:transform:sdf_pair_with_restriction:v1', constant=u'', spec=, label_props=)

SPLIT_RESTRICTION = PropertiesFromEnumValue(urn=u'beam:transform:sdf_split_restriction:v1', constant=u'', spec=, label_props=)

PROCESS_KEYED_ELEMENTS = PropertiesFromEnumValue(urn=u'beam:transform:sdf_process_keyed_elements:v1', constant=u'', spec=, label_props=)

PROCESS_ELEMENTS = PropertiesFromEnumValue(urn=u'beam:transform:sdf_process_elements:v1', constant=u'', spec=, label_props=)

SPLIT_AND_SIZE_RESTRICTIONS = PropertiesFromEnumValue(urn=u'beam:transform:sdf_split_and_size_restrictions:v1', constant=u'', spec=, label_props=)

PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS = PropertiesFromEnumValue(urn=u'beam:transform:sdf_process_sized_element_and_restrictions:v1', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardSideInputTypes

Bases: object

class Enum

Bases: object

ITERABLE = PropertiesFromEnumValue(urn=u'beam:side_input:iterable:v1', constant=u'', spec=, label_props=)

MULTIMAP = PropertiesFromEnumValue(urn=u'beam:side_input:multimap:v1', constant=u'', spec=, label_props=)

class apache_beam.portability.api.beam_runner_api_pb2_urns.TimeDomain

Bases: object

class Enum

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

EVENT_TIME = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

PROCESSING_TIME = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)

SYNCHRONIZED_PROCESSING_TIME = PropertiesFromEnumValue(urn=u'', constant=u'', spec=, label_props=)