apache_beam.portability.api.beam_runner_api_pb2_urns module

class apache_beam.portability.api.beam_runner_api_pb2_urns.AccumulationMode[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
DISCARDING = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
ACCUMULATING = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
RETRACTING = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.BeamConstants[source]

Bases: object

class Constants[source]

Bases: object

MIN_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn='', constant='-9223372036854775', spec=, label_props=)
MAX_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn='', constant='9223372036854775', spec=, label_props=)
GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS = PropertiesFromEnumValue(urn='', constant='9223371950454775', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.ClosingBehavior[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
EMIT_ALWAYS = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
EMIT_IF_NONEMPTY = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.IsBounded[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
UNBOUNDED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
BOUNDED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.MergeStatus[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
NON_MERGING = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
NEEDS_MERGE = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
ALREADY_MERGED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.OnTimeBehavior[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
FIRE_ALWAYS = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
FIRE_IF_NONEMPTY = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.OutputTime[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
END_OF_WINDOW = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
LATEST_IN_PANE = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
EARLIEST_IN_PANE = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardArtifacts[source]

Bases: object

class Roles[source]

Bases: object

STAGING_TO = PropertiesFromEnumValue(urn='beam:artifact:role:staging_to:v1', constant='', spec=, label_props=)
class Types[source]

Bases: object

FILE = PropertiesFromEnumValue(urn='beam:artifact:type:file:v1', constant='', spec=, label_props=)
URL = PropertiesFromEnumValue(urn='beam:artifact:type:url:v1', constant='', spec=, label_props=)
EMBEDDED = PropertiesFromEnumValue(urn='beam:artifact:type:embedded:v1', constant='', spec=, label_props=)
PYPI = PropertiesFromEnumValue(urn='beam:artifact:type:pypi:v1', constant='', spec=, label_props=)
MAVEN = PropertiesFromEnumValue(urn='beam:artifact:type:maven:v1', constant='', spec=, label_props=)
DEFERRED = PropertiesFromEnumValue(urn='beam:artifact:type:deferred:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardCoders[source]

Bases: object

class Enum[source]

Bases: object

BYTES = PropertiesFromEnumValue(urn='beam:coder:bytes:v1', constant='', spec=, label_props=)
STRING_UTF8 = PropertiesFromEnumValue(urn='beam:coder:string_utf8:v1', constant='', spec=, label_props=)
KV = PropertiesFromEnumValue(urn='beam:coder:kv:v1', constant='', spec=, label_props=)
BOOL = PropertiesFromEnumValue(urn='beam:coder:bool:v1', constant='', spec=, label_props=)
VARINT = PropertiesFromEnumValue(urn='beam:coder:varint:v1', constant='', spec=, label_props=)
DOUBLE = PropertiesFromEnumValue(urn='beam:coder:double:v1', constant='', spec=, label_props=)
ITERABLE = PropertiesFromEnumValue(urn='beam:coder:iterable:v1', constant='', spec=, label_props=)
TIMER = PropertiesFromEnumValue(urn='beam:coder:timer:v1', constant='', spec=, label_props=)
INTERVAL_WINDOW = PropertiesFromEnumValue(urn='beam:coder:interval_window:v1', constant='', spec=, label_props=)
LENGTH_PREFIX = PropertiesFromEnumValue(urn='beam:coder:length_prefix:v1', constant='', spec=, label_props=)
GLOBAL_WINDOW = PropertiesFromEnumValue(urn='beam:coder:global_window:v1', constant='', spec=, label_props=)
WINDOWED_VALUE = PropertiesFromEnumValue(urn='beam:coder:windowed_value:v1', constant='', spec=, label_props=)
PARAM_WINDOWED_VALUE = PropertiesFromEnumValue(urn='beam:coder:param_windowed_value:v1', constant='', spec=, label_props=)
STATE_BACKED_ITERABLE = PropertiesFromEnumValue(urn='beam:coder:state_backed_iterable:v1', constant='', spec=, label_props=)
ROW = PropertiesFromEnumValue(urn='beam:coder:row:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardDisplayData[source]

Bases: object

class DisplayData[source]

Bases: object

LABELLED_STRING = PropertiesFromEnumValue(urn='beam:display_data:labelled_string:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardEnvironments[source]

Bases: object

class Environments[source]

Bases: object

DOCKER = PropertiesFromEnumValue(urn='beam:env:docker:v1', constant='', spec=, label_props=)
PROCESS = PropertiesFromEnumValue(urn='beam:env:process:v1', constant='', spec=, label_props=)
EXTERNAL = PropertiesFromEnumValue(urn='beam:env:external:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardPTransforms[source]

Bases: object

class CombineComponents[source]

Bases: object

COMBINE_PER_KEY_PRECOMBINE = PropertiesFromEnumValue(urn='beam:transform:combine_per_key_precombine:v1', constant='', spec=, label_props=)
COMBINE_PER_KEY_MERGE_ACCUMULATORS = PropertiesFromEnumValue(urn='beam:transform:combine_per_key_merge_accumulators:v1', constant='', spec=, label_props=)
COMBINE_PER_KEY_EXTRACT_OUTPUTS = PropertiesFromEnumValue(urn='beam:transform:combine_per_key_extract_outputs:v1', constant='', spec=, label_props=)
COMBINE_GROUPED_VALUES = PropertiesFromEnumValue(urn='beam:transform:combine_grouped_values:v1', constant='', spec=, label_props=)
COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS = PropertiesFromEnumValue(urn='beam:transform:combine_per_key_convert_to_accumulators:v1', constant='', spec=, label_props=)
class Composites[source]

Bases: object

COMBINE_PER_KEY = PropertiesFromEnumValue(urn='beam:transform:combine_per_key:v1', constant='', spec=, label_props=)
COMBINE_GLOBALLY = PropertiesFromEnumValue(urn='beam:transform:combine_globally:v1', constant='', spec=, label_props=)
RESHUFFLE = PropertiesFromEnumValue(urn='beam:transform:reshuffle:v1', constant='', spec=, label_props=)
WRITE_FILES = PropertiesFromEnumValue(urn='beam:transform:write_files:v1', constant='', spec=, label_props=)
class DeprecatedPrimitives[source]

Bases: object

READ = PropertiesFromEnumValue(urn='beam:transform:read:v1', constant='', spec=, label_props=)
CREATE_VIEW = PropertiesFromEnumValue(urn='beam:transform:create_view:v1', constant='', spec=, label_props=)
class Primitives[source]

Bases: object

PAR_DO = PropertiesFromEnumValue(urn='beam:transform:pardo:v1', constant='', spec=, label_props=)
FLATTEN = PropertiesFromEnumValue(urn='beam:transform:flatten:v1', constant='', spec=, label_props=)
GROUP_BY_KEY = PropertiesFromEnumValue(urn='beam:transform:group_by_key:v1', constant='', spec=, label_props=)
IMPULSE = PropertiesFromEnumValue(urn='beam:transform:impulse:v1', constant='', spec=, label_props=)
ASSIGN_WINDOWS = PropertiesFromEnumValue(urn='beam:transform:window_into:v1', constant='', spec=, label_props=)
TEST_STREAM = PropertiesFromEnumValue(urn='beam:transform:teststream:v1', constant='', spec=, label_props=)
MAP_WINDOWS = PropertiesFromEnumValue(urn='beam:transform:map_windows:v1', constant='', spec=, label_props=)
MERGE_WINDOWS = PropertiesFromEnumValue(urn='beam:transform:merge_windows:v1', constant='', spec=, label_props=)
class SplittableParDoComponents[source]

Bases: object

PAIR_WITH_RESTRICTION = PropertiesFromEnumValue(urn='beam:transform:sdf_pair_with_restriction:v1', constant='', spec=, label_props=)
SPLIT_RESTRICTION = PropertiesFromEnumValue(urn='beam:transform:sdf_split_restriction:v1', constant='', spec=, label_props=)
PROCESS_KEYED_ELEMENTS = PropertiesFromEnumValue(urn='beam:transform:sdf_process_keyed_elements:v1', constant='', spec=, label_props=)
PROCESS_ELEMENTS = PropertiesFromEnumValue(urn='beam:transform:sdf_process_elements:v1', constant='', spec=, label_props=)
SPLIT_AND_SIZE_RESTRICTIONS = PropertiesFromEnumValue(urn='beam:transform:sdf_split_and_size_restrictions:v1', constant='', spec=, label_props=)
PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS = PropertiesFromEnumValue(urn='beam:transform:sdf_process_sized_element_and_restrictions:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardProtocols[source]

Bases: object

class Enum[source]

Bases: object

LEGACY_PROGRESS_REPORTING = PropertiesFromEnumValue(urn='beam:protocol:progress_reporting:v0', constant='', spec=, label_props=)
PROGRESS_REPORTING = PropertiesFromEnumValue(urn='beam:protocol:progress_reporting:v1', constant='', spec=, label_props=)
WORKER_STATUS = PropertiesFromEnumValue(urn='beam:protocol:worker_status:v1', constant='', spec=, label_props=)
MULTI_CORE_BUNDLE_PROCESSING = PropertiesFromEnumValue(urn='beam:protocol:multi_core_bundle_processing:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardRequirements[source]

Bases: object

class Enum[source]

Bases: object

REQUIRES_STATEFUL_PROCESSING = PropertiesFromEnumValue(urn='beam:requirement:pardo:stateful:v1', constant='', spec=, label_props=)
REQUIRES_BUNDLE_FINALIZATION = PropertiesFromEnumValue(urn='beam:requirement:pardo:finalization:v1', constant='', spec=, label_props=)
REQUIRES_STABLE_INPUT = PropertiesFromEnumValue(urn='beam:requirement:pardo:stable_input:v1', constant='', spec=, label_props=)
REQUIRES_TIME_SORTED_INPUT = PropertiesFromEnumValue(urn='beam:requirement:pardo:time_sorted_input:v1', constant='', spec=, label_props=)
REQUIRES_SPLITTABLE_DOFN = PropertiesFromEnumValue(urn='beam:requirement:pardo:splittable_dofn:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardSideInputTypes[source]

Bases: object

class Enum[source]

Bases: object

ITERABLE = PropertiesFromEnumValue(urn='beam:side_input:iterable:v1', constant='', spec=, label_props=)
MULTIMAP = PropertiesFromEnumValue(urn='beam:side_input:multimap:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.TimeDomain[source]

Bases: object

class Enum[source]

Bases: object

UNSPECIFIED = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
EVENT_TIME = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
PROCESSING_TIME = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)
SYNCHRONIZED_PROCESSING_TIME = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=)