apache_beam.portability.api.beam_runner_api_pb2_urns module

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.StandardArtifacts[source]

Bases: object

class Roles[source]

Bases: object

STAGING_TO = PropertiesFromEnumValue(urn='beam:artifact:role:staging_to:v1', constant='', spec=, label_props=)
PIP_REQUIREMENTS_FILE = PropertiesFromEnumValue(urn='beam:artifact:role:pip_requirements_file: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=)
CUSTOM_WINDOW = PropertiesFromEnumValue(urn='beam:coder:custom_window:v1', constant='', spec=, label_props=)
ROW = PropertiesFromEnumValue(urn='beam:coder:row:v1', constant='', spec=, label_props=)
SHARDED_KEY = PropertiesFromEnumValue(urn='beam:coder:sharded_key: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 = PropertiesFromEnumValue(urn='beam:display_data:labelled: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=)
DEFAULT = PropertiesFromEnumValue(urn='beam:env:default: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=)
PUBSUB_READ = PropertiesFromEnumValue(urn='beam:transform:pubsub_read:v1', constant='', spec=, label_props=)
PUBSUB_WRITE = PropertiesFromEnumValue(urn='beam:transform:pubsub_write:v1', constant='', spec=, label_props=)
GROUP_INTO_BATCHES_WITH_SHARDED_KEY = PropertiesFromEnumValue(urn='beam:transform:group_into_batches_with_sharded_key: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 GroupIntoBatchesComponents[source]

Bases: object

GROUP_INTO_BATCHES = PropertiesFromEnumValue(urn='beam:transform:group_into_batches: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=)
TO_STRING = PropertiesFromEnumValue(urn='beam:transform:to_string: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_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=)
TRUNCATE_SIZED_RESTRICTION = PropertiesFromEnumValue(urn='beam:transform:sdf_truncate_sized_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=)
SIBLING_WORKERS = PropertiesFromEnumValue(urn='beam:protocol:sibling_workers:v1', constant='', spec=, label_props=)
HARNESS_MONITORING_INFOS = PropertiesFromEnumValue(urn='beam:protocol:harness_monitoring_infos:v1', constant='', spec=, label_props=)
CONTROL_REQUEST_ELEMENTS_EMBEDDING = PropertiesFromEnumValue(urn='beam:protocol:control_request_elements_embedding:v1', constant='', spec=, label_props=)
STATE_CACHING = PropertiesFromEnumValue(urn='beam:protocol:state_caching: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=)
REQUIRES_ON_WINDOW_EXPIRATION = PropertiesFromEnumValue(urn='beam:requirement:pardo:on_window_expiration:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardResourceHints[source]

Bases: object

class Enum[source]

Bases: object

ACCELERATOR = PropertiesFromEnumValue(urn='beam:resources:accelerator:v1', constant='', spec=, label_props=)
MIN_RAM_BYTES = PropertiesFromEnumValue(urn='beam:resources:min_ram_bytes:v1', constant='', spec=, label_props=)
class apache_beam.portability.api.beam_runner_api_pb2_urns.StandardRunnerProtocols[source]

Bases: object

class Enum[source]

Bases: object

MONITORING_INFO_SHORT_IDS = PropertiesFromEnumValue(urn='beam:protocol:monitoring_info_short_ids:v1', constant='', spec=, label_props=)
CONTROL_RESPONSE_ELEMENTS_EMBEDDING = PropertiesFromEnumValue(urn='beam:protocol:control_response_elements_embedding: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=)