# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: beam_fn_api.proto
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
from google.protobuf import descriptor_pb2
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
import beam_runner_api_pb2 as beam__runner__api__pb2
from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
DESCRIPTOR = _descriptor.FileDescriptor(
name='beam_fn_api.proto',
package='org.apache.beam.fn.v1',
syntax='proto3',
serialized_pb=_b('\n\x11\x62\x65\x61m_fn_api.proto\x12\x15org.apache.beam.fn.v1\x1a\x15\x62\x65\x61m_runner_api.proto\x1a\x19google/protobuf/any.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"t\n\x06Target\x12%\n\x1dprimitive_transform_reference\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x1a\x35\n\x04List\x12-\n\x06target\x18\x01 \x03(\x0b\x32\x1d.org.apache.beam.fn.v1.Target\"*\n\x0bPCollection\x12\x1b\n\x0f\x63oder_reference\x18\x01 \x01(\tB\x02\x18\x01\"\xe3\x04\n\x12PrimitiveTransform\x12\x0e\n\x02id\x18\x01 \x01(\tB\x02\x18\x01\x12>\n\rfunction_spec\x18\x02 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpecB\x02\x18\x01\x12I\n\x06inputs\x18\x03 \x03(\x0b\x32\x35.org.apache.beam.fn.v1.PrimitiveTransform.InputsEntryB\x02\x18\x01\x12K\n\x07outputs\x18\x04 \x03(\x0b\x32\x36.org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntryB\x02\x18\x01\x12R\n\x0bside_inputs\x18\x05 \x03(\x0b\x32\x39.org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntryB\x02\x18\x01\x12\x15\n\tstep_name\x18\x06 \x01(\tB\x02\x18\x01\x1aQ\n\x0bInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x31\n\x05value\x18\x02 \x01(\x0b\x32\".org.apache.beam.fn.v1.Target.List:\x02\x38\x01\x1aR\n\x0cOutputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x31\n\x05value\x18\x02 \x01(\x0b\x32\".org.apache.beam.fn.v1.PCollection:\x02\x38\x01\x1aS\n\x0fSideInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12/\n\x05value\x18\x02 \x01(\x0b\x32 .org.apache.beam.fn.v1.SideInput:\x02\x38\x01\"z\n\x0c\x46unctionSpec\x12\x0e\n\x02id\x18\x01 \x01(\tB\x02\x18\x01\x12\x0f\n\x03urn\x18\x02 \x01(\tB\x02\x18\x01\x12!\n\x15\x65nvironment_reference\x18\x03 \x01(\tB\x02\x18\x01\x12&\n\x04\x64\x61ta\x18\x04 \x01(\x0b\x32\x14.google.protobuf.AnyB\x02\x18\x01\"w\n\tSideInput\x12\x30\n\x05input\x18\x01 \x01(\x0b\x32\x1d.org.apache.beam.fn.v1.TargetB\x02\x18\x01\x12\x38\n\x07view_fn\x18\x02 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpecB\x02\x18\x01\"n\n\x05\x43oder\x12>\n\rfunction_spec\x18\x01 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpecB\x02\x18\x01\x12%\n\x19\x63omponent_coder_reference\x18\x02 \x03(\tB\x02\x18\x01\"]\n\x0eRemoteGrpcPort\x12K\n\x16\x61pi_service_descriptor\x18\x01 \x01(\x0b\x32+.org.apache.beam.fn.v1.ApiServiceDescriptor\"\xe8\x02\n\x12InstructionRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12;\n\x08register\x18\xe8\x07 \x01(\x0b\x32&.org.apache.beam.fn.v1.RegisterRequestH\x00\x12\x46\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32+.org.apache.beam.fn.v1.ProcessBundleRequestH\x00\x12W\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x33.org.apache.beam.fn.v1.ProcessBundleProgressRequestH\x00\x12Q\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32\x30.org.apache.beam.fn.v1.ProcessBundleSplitRequestH\x00\x42\t\n\x07request\"\xfd\x02\n\x13InstructionResponse\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12<\n\x08register\x18\xe8\x07 \x01(\x0b\x32\'.org.apache.beam.fn.v1.RegisterResponseH\x00\x12G\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32,.org.apache.beam.fn.v1.ProcessBundleResponseH\x00\x12X\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x34.org.apache.beam.fn.v1.ProcessBundleProgressResponseH\x00\x12R\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32\x31.org.apache.beam.fn.v1.ProcessBundleSplitResponseH\x00\x42\n\n\x08response\"d\n\x0fRegisterRequest\x12Q\n\x19process_bundle_descriptor\x18\x01 \x03(\x0b\x32..org.apache.beam.fn.v1.ProcessBundleDescriptor\"\x12\n\x10RegisterResponse\"\xc6\x08\n\x17ProcessBundleDescriptor\x12\n\n\x02id\x18\x01 \x01(\t\x12J\n\x13primitive_transform\x18\x02 \x03(\x0b\x32).org.apache.beam.fn.v1.PrimitiveTransformB\x02\x18\x01\x12\x30\n\x06\x63oders\x18\x04 \x03(\x0b\x32\x1c.org.apache.beam.fn.v1.CoderB\x02\x18\x01\x12R\n\ntransforms\x18\x05 \x03(\x0b\x32>.org.apache.beam.fn.v1.ProcessBundleDescriptor.TransformsEntry\x12V\n\x0cpcollections\x18\x06 \x03(\x0b\x32@.org.apache.beam.fn.v1.ProcessBundleDescriptor.PcollectionsEntry\x12\x65\n\x14windowing_strategies\x18\x07 \x03(\x0b\x32G.org.apache.beam.fn.v1.ProcessBundleDescriptor.WindowingStrategiesEntry\x12P\n\tcodersyyy\x18\x08 \x03(\x0b\x32=.org.apache.beam.fn.v1.ProcessBundleDescriptor.CodersyyyEntry\x12V\n\x0c\x65nvironments\x18\t \x03(\x0b\x32@.org.apache.beam.fn.v1.ProcessBundleDescriptor.EnvironmentsEntry\x1a\\\n\x0fTransformsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x38\n\x05value\x18\x02 \x01(\x0b\x32).org.apache.beam.runner_api.v1.PTransform:\x02\x38\x01\x1a_\n\x11PcollectionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x39\n\x05value\x18\x02 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.PCollection:\x02\x38\x01\x1al\n\x18WindowingStrategiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12?\n\x05value\x18\x02 \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.WindowingStrategy:\x02\x38\x01\x1aV\n\x0e\x43odersyyyEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x33\n\x05value\x18\x02 \x01(\x0b\x32$.org.apache.beam.runner_api.v1.Coder:\x02\x38\x01\x1a_\n\x11\x45nvironmentsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x39\n\x05value\x18\x02 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.Environment:\x02\x38\x01\"Y\n\x14ProcessBundleRequest\x12+\n#process_bundle_descriptor_reference\x18\x01 \x01(\t\x12\x14\n\x0c\x63\x61\x63he_tokens\x18\x02 \x03(\x0c\"\x17\n\x15ProcessBundleResponse\"=\n\x1cProcessBundleProgressRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\"G\n\x1dProcessBundleProgressResponse\x12\x15\n\rfinished_work\x18\x01 \x01(\x01\x12\x0f\n\x07\x62\x61\x63klog\x18\x02 \x01(\x01\"L\n\x19ProcessBundleSplitRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\x12\x10\n\x08\x66raction\x18\x02 \x01(\x01\"(\n\x17\x45lementCountRestriction\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\",\n\x1b\x45lementCountSkipRestriction\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\"\xc8\x01\n\x17PrimitiveTransformSplit\x12%\n\x1dprimitive_transform_reference\x18\x01 \x01(\t\x12\x42\n\x15\x63ompleted_restriction\x18\x02 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpec\x12\x42\n\x15remaining_restriction\x18\x03 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpec\"\\\n\x1aProcessBundleSplitResponse\x12>\n\x06splits\x18\x01 \x03(\x0b\x32..org.apache.beam.fn.v1.PrimitiveTransformSplit\"\xa2\x01\n\x08\x45lements\x12\x32\n\x04\x64\x61ta\x18\x01 \x03(\x0b\x32$.org.apache.beam.fn.v1.Elements.Data\x1a\x62\n\x04\x44\x61ta\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\x12-\n\x06target\x18\x02 \x01(\x0b\x32\x1d.org.apache.beam.fn.v1.Target\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\"\xaa\x02\n\x0cStateRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x1d\n\x15instruction_reference\x18\x02 \x01(\t\x12\x32\n\tstate_key\x18\x03 \x01(\x0b\x32\x1f.org.apache.beam.fn.v1.StateKey\x12\x36\n\x03get\x18\xe8\x07 \x01(\x0b\x32&.org.apache.beam.fn.v1.StateGetRequestH\x00\x12<\n\x06\x61ppend\x18\xe9\x07 \x01(\x0b\x32).org.apache.beam.fn.v1.StateAppendRequestH\x00\x12:\n\x05\x63lear\x18\xea\x07 \x01(\x0b\x32(.org.apache.beam.fn.v1.StateClearRequestH\x00\x42\t\n\x07request\"\x80\x02\n\rStateResponse\x12\n\n\x02id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12\x13\n\x0b\x63\x61\x63he_token\x18\x03 \x01(\x0c\x12\x37\n\x03get\x18\xe8\x07 \x01(\x0b\x32\'.org.apache.beam.fn.v1.StateGetResponseH\x00\x12=\n\x06\x61ppend\x18\xe9\x07 \x01(\x0b\x32*.org.apache.beam.fn.v1.StateAppendResponseH\x00\x12;\n\x05\x63lear\x18\xea\x07 \x01(\x0b\x32).org.apache.beam.fn.v1.StateClearResponseH\x00\x42\n\n\x08response\"\xb8\x03\n\x08StateKey\x12\x38\n\x06runner\x18\x01 \x01(\x0b\x32&.org.apache.beam.fn.v1.StateKey.RunnerH\x00\x12P\n\x13multimap_side_input\x18\x02 \x01(\x0b\x32\x31.org.apache.beam.fn.v1.StateKey.MultimapSideInputH\x00\x12\x46\n\x0e\x62\x61g_user_state\x18\x03 \x01(\x0b\x32,.org.apache.beam.fn.v1.StateKey.BagUserStateH\x00\x1a\x15\n\x06Runner\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x1a^\n\x11MultimapSideInput\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x15\n\rside_input_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x12\x0b\n\x03key\x18\x04 \x01(\x0c\x1aY\n\x0c\x42\x61gUserState\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x15\n\ruser_state_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x12\x0b\n\x03key\x18\x04 \x01(\x0c\x42\x06\n\x04type\"-\n\x0fStateGetRequest\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\"<\n\x10StateGetResponse\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"\"\n\x12StateAppendRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"\x15\n\x13StateAppendResponse\"\x13\n\x11StateClearRequest\"\x14\n\x12StateClearResponse\"\x9a\x03\n\x08LogEntry\x12:\n\x08severity\x18\x01 \x01(\x0e\x32(.org.apache.beam.fn.v1.LogEntry.Severity\x12-\n\ttimestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0f\n\x07message\x18\x03 \x01(\t\x12\r\n\x05trace\x18\x04 \x01(\t\x12\x1d\n\x15instruction_reference\x18\x05 \x01(\t\x12%\n\x1dprimitive_transform_reference\x18\x06 \x01(\t\x12\x14\n\x0clog_location\x18\x07 \x01(\t\x12\x0e\n\x06thread\x18\x08 \x01(\t\x1a<\n\x04List\x12\x34\n\x0blog_entries\x18\x01 \x03(\x0b\x32\x1f.org.apache.beam.fn.v1.LogEntry\"Y\n\x08Severity\x12\t\n\x05TRACE\x10\x00\x12\t\n\x05\x44\x45\x42UG\x10\n\x12\x08\n\x04INFO\x10\x14\x12\n\n\x06NOTICE\x10\x1e\x12\x08\n\x04WARN\x10(\x12\t\n\x05\x45RROR\x10\x32\x12\x0c\n\x08\x43RITICAL\x10<\"\x0c\n\nLogControl\"\xa1\x01\n\x14\x41piServiceDescriptor\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\x12^\n\x1foauth2_client_credentials_grant\x18\x03 \x01(\x0b\x32\x33.org.apache.beam.fn.v1.OAuth2ClientCredentialsGrantH\x00\x42\x10\n\x0e\x61uthentication\"+\n\x1cOAuth2ClientCredentialsGrant\x12\x0b\n\x03url\x18\x01 \x01(\t\"F\n\x0f\x44ockerContainer\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0b\n\x03uri\x18\x02 \x01(\t\x12\x1a\n\x12registry_reference\x18\x03 \x01(\t2w\n\rBeamFnControl\x12\x66\n\x07\x43ontrol\x12*.org.apache.beam.fn.v1.InstructionResponse\x1a).org.apache.beam.fn.v1.InstructionRequest\"\x00(\x01\x30\x01\x32\\\n\nBeamFnData\x12N\n\x04\x44\x61ta\x12\x1f.org.apache.beam.fn.v1.Elements\x1a\x1f.org.apache.beam.fn.v1.Elements\"\x00(\x01\x30\x01\x32g\n\x0b\x42\x65\x61mFnState\x12X\n\x05State\x12#.org.apache.beam.fn.v1.StateRequest\x1a$.org.apache.beam.fn.v1.StateResponse\"\x00(\x01\x30\x01\x32i\n\rBeamFnLogging\x12X\n\x07Logging\x12$.org.apache.beam.fn.v1.LogEntry.List\x1a!.org.apache.beam.fn.v1.LogControl\"\x00(\x01\x30\x01\x42\"\n\x15org.apache.beam.fn.v1B\tBeamFnApib\x06proto3')
,
dependencies=[beam__runner__api__pb2.DESCRIPTOR,google_dot_protobuf_dot_any__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,])
_LOGENTRY_SEVERITY = _descriptor.EnumDescriptor(
name='Severity',
full_name='org.apache.beam.fn.v1.LogEntry.Severity',
filename=None,
file=DESCRIPTOR,
values=[
_descriptor.EnumValueDescriptor(
name='TRACE', index=0, number=0,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='DEBUG', index=1, number=10,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='INFO', index=2, number=20,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='NOTICE', index=3, number=30,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='WARN', index=4, number=40,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='ERROR', index=5, number=50,
options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='CRITICAL', index=6, number=60,
options=None,
type=None),
],
containing_type=None,
options=None,
serialized_start=5737,
serialized_end=5826,
)
_sym_db.RegisterEnumDescriptor(_LOGENTRY_SEVERITY)
_TARGET_LIST = _descriptor.Descriptor(
name='List',
full_name='org.apache.beam.fn.v1.Target.List',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='target', full_name='org.apache.beam.fn.v1.Target.List.target', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=190,
serialized_end=243,
)
_TARGET = _descriptor.Descriptor(
name='Target',
full_name='org.apache.beam.fn.v1.Target',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='primitive_transform_reference', full_name='org.apache.beam.fn.v1.Target.primitive_transform_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='name', full_name='org.apache.beam.fn.v1.Target.name', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[_TARGET_LIST, ],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=127,
serialized_end=243,
)
_PCOLLECTION = _descriptor.Descriptor(
name='PCollection',
full_name='org.apache.beam.fn.v1.PCollection',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='coder_reference', full_name='org.apache.beam.fn.v1.PCollection.coder_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=245,
serialized_end=287,
)
_PRIMITIVETRANSFORM_INPUTSENTRY = _descriptor.Descriptor(
name='InputsEntry',
full_name='org.apache.beam.fn.v1.PrimitiveTransform.InputsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.PrimitiveTransform.InputsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.PrimitiveTransform.InputsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=651,
serialized_end=732,
)
_PRIMITIVETRANSFORM_OUTPUTSENTRY = _descriptor.Descriptor(
name='OutputsEntry',
full_name='org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=734,
serialized_end=816,
)
_PRIMITIVETRANSFORM_SIDEINPUTSENTRY = _descriptor.Descriptor(
name='SideInputsEntry',
full_name='org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=818,
serialized_end=901,
)
_PRIMITIVETRANSFORM = _descriptor.Descriptor(
name='PrimitiveTransform',
full_name='org.apache.beam.fn.v1.PrimitiveTransform',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.PrimitiveTransform.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='function_spec', full_name='org.apache.beam.fn.v1.PrimitiveTransform.function_spec', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='inputs', full_name='org.apache.beam.fn.v1.PrimitiveTransform.inputs', index=2,
number=3, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='outputs', full_name='org.apache.beam.fn.v1.PrimitiveTransform.outputs', index=3,
number=4, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='side_inputs', full_name='org.apache.beam.fn.v1.PrimitiveTransform.side_inputs', index=4,
number=5, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='step_name', full_name='org.apache.beam.fn.v1.PrimitiveTransform.step_name', index=5,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
],
extensions=[
],
nested_types=[_PRIMITIVETRANSFORM_INPUTSENTRY, _PRIMITIVETRANSFORM_OUTPUTSENTRY, _PRIMITIVETRANSFORM_SIDEINPUTSENTRY, ],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=290,
serialized_end=901,
)
_FUNCTIONSPEC = _descriptor.Descriptor(
name='FunctionSpec',
full_name='org.apache.beam.fn.v1.FunctionSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.FunctionSpec.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='urn', full_name='org.apache.beam.fn.v1.FunctionSpec.urn', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='environment_reference', full_name='org.apache.beam.fn.v1.FunctionSpec.environment_reference', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='data', full_name='org.apache.beam.fn.v1.FunctionSpec.data', index=3,
number=4, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=903,
serialized_end=1025,
)
_SIDEINPUT = _descriptor.Descriptor(
name='SideInput',
full_name='org.apache.beam.fn.v1.SideInput',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='input', full_name='org.apache.beam.fn.v1.SideInput.input', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='view_fn', full_name='org.apache.beam.fn.v1.SideInput.view_fn', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1027,
serialized_end=1146,
)
_CODER = _descriptor.Descriptor(
name='Coder',
full_name='org.apache.beam.fn.v1.Coder',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='function_spec', full_name='org.apache.beam.fn.v1.Coder.function_spec', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='component_coder_reference', full_name='org.apache.beam.fn.v1.Coder.component_coder_reference', index=1,
number=2, type=9, cpp_type=9, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1148,
serialized_end=1258,
)
_REMOTEGRPCPORT = _descriptor.Descriptor(
name='RemoteGrpcPort',
full_name='org.apache.beam.fn.v1.RemoteGrpcPort',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='api_service_descriptor', full_name='org.apache.beam.fn.v1.RemoteGrpcPort.api_service_descriptor', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1260,
serialized_end=1353,
)
_INSTRUCTIONREQUEST = _descriptor.Descriptor(
name='InstructionRequest',
full_name='org.apache.beam.fn.v1.InstructionRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='instruction_id', full_name='org.apache.beam.fn.v1.InstructionRequest.instruction_id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='register', full_name='org.apache.beam.fn.v1.InstructionRequest.register', index=1,
number=1000, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle', full_name='org.apache.beam.fn.v1.InstructionRequest.process_bundle', index=2,
number=1001, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle_progress', full_name='org.apache.beam.fn.v1.InstructionRequest.process_bundle_progress', index=3,
number=1002, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle_split', full_name='org.apache.beam.fn.v1.InstructionRequest.process_bundle_split', index=4,
number=1003, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='request', full_name='org.apache.beam.fn.v1.InstructionRequest.request',
index=0, containing_type=None, fields=[]),
],
serialized_start=1356,
serialized_end=1716,
)
_INSTRUCTIONRESPONSE = _descriptor.Descriptor(
name='InstructionResponse',
full_name='org.apache.beam.fn.v1.InstructionResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='instruction_id', full_name='org.apache.beam.fn.v1.InstructionResponse.instruction_id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='error', full_name='org.apache.beam.fn.v1.InstructionResponse.error', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='register', full_name='org.apache.beam.fn.v1.InstructionResponse.register', index=2,
number=1000, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle', full_name='org.apache.beam.fn.v1.InstructionResponse.process_bundle', index=3,
number=1001, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle_progress', full_name='org.apache.beam.fn.v1.InstructionResponse.process_bundle_progress', index=4,
number=1002, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='process_bundle_split', full_name='org.apache.beam.fn.v1.InstructionResponse.process_bundle_split', index=5,
number=1003, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='response', full_name='org.apache.beam.fn.v1.InstructionResponse.response',
index=0, containing_type=None, fields=[]),
],
serialized_start=1719,
serialized_end=2100,
)
_REGISTERREQUEST = _descriptor.Descriptor(
name='RegisterRequest',
full_name='org.apache.beam.fn.v1.RegisterRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='process_bundle_descriptor', full_name='org.apache.beam.fn.v1.RegisterRequest.process_bundle_descriptor', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2102,
serialized_end=2202,
)
_REGISTERRESPONSE = _descriptor.Descriptor(
name='RegisterResponse',
full_name='org.apache.beam.fn.v1.RegisterResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2204,
serialized_end=2222,
)
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY = _descriptor.Descriptor(
name='TransformsEntry',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.TransformsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.TransformsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.TransformsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2835,
serialized_end=2927,
)
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY = _descriptor.Descriptor(
name='PcollectionsEntry',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.PcollectionsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.PcollectionsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.PcollectionsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2929,
serialized_end=3024,
)
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY = _descriptor.Descriptor(
name='WindowingStrategiesEntry',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.WindowingStrategiesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.WindowingStrategiesEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.WindowingStrategiesEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3026,
serialized_end=3134,
)
_PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY = _descriptor.Descriptor(
name='CodersyyyEntry',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.CodersyyyEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.CodersyyyEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.CodersyyyEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3136,
serialized_end=3222,
)
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY = _descriptor.Descriptor(
name='EnvironmentsEntry',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.EnvironmentsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.EnvironmentsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='value', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.EnvironmentsEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3224,
serialized_end=3319,
)
_PROCESSBUNDLEDESCRIPTOR = _descriptor.Descriptor(
name='ProcessBundleDescriptor',
full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='primitive_transform', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.primitive_transform', index=1,
number=2, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='coders', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.coders', index=2,
number=4, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))),
_descriptor.FieldDescriptor(
name='transforms', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.transforms', index=3,
number=5, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='pcollections', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.pcollections', index=4,
number=6, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='windowing_strategies', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.windowing_strategies', index=5,
number=7, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='codersyyy', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.codersyyy', index=6,
number=8, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='environments', full_name='org.apache.beam.fn.v1.ProcessBundleDescriptor.environments', index=7,
number=9, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY, _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY, _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY, _PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY, _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY, ],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2225,
serialized_end=3319,
)
_PROCESSBUNDLEREQUEST = _descriptor.Descriptor(
name='ProcessBundleRequest',
full_name='org.apache.beam.fn.v1.ProcessBundleRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='process_bundle_descriptor_reference', full_name='org.apache.beam.fn.v1.ProcessBundleRequest.process_bundle_descriptor_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='cache_tokens', full_name='org.apache.beam.fn.v1.ProcessBundleRequest.cache_tokens', index=1,
number=2, type=12, cpp_type=9, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3321,
serialized_end=3410,
)
_PROCESSBUNDLERESPONSE = _descriptor.Descriptor(
name='ProcessBundleResponse',
full_name='org.apache.beam.fn.v1.ProcessBundleResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3412,
serialized_end=3435,
)
_PROCESSBUNDLEPROGRESSREQUEST = _descriptor.Descriptor(
name='ProcessBundleProgressRequest',
full_name='org.apache.beam.fn.v1.ProcessBundleProgressRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='instruction_reference', full_name='org.apache.beam.fn.v1.ProcessBundleProgressRequest.instruction_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3437,
serialized_end=3498,
)
_PROCESSBUNDLEPROGRESSRESPONSE = _descriptor.Descriptor(
name='ProcessBundleProgressResponse',
full_name='org.apache.beam.fn.v1.ProcessBundleProgressResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='finished_work', full_name='org.apache.beam.fn.v1.ProcessBundleProgressResponse.finished_work', index=0,
number=1, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='backlog', full_name='org.apache.beam.fn.v1.ProcessBundleProgressResponse.backlog', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3500,
serialized_end=3571,
)
_PROCESSBUNDLESPLITREQUEST = _descriptor.Descriptor(
name='ProcessBundleSplitRequest',
full_name='org.apache.beam.fn.v1.ProcessBundleSplitRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='instruction_reference', full_name='org.apache.beam.fn.v1.ProcessBundleSplitRequest.instruction_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='fraction', full_name='org.apache.beam.fn.v1.ProcessBundleSplitRequest.fraction', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3573,
serialized_end=3649,
)
_ELEMENTCOUNTRESTRICTION = _descriptor.Descriptor(
name='ElementCountRestriction',
full_name='org.apache.beam.fn.v1.ElementCountRestriction',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='count', full_name='org.apache.beam.fn.v1.ElementCountRestriction.count', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3651,
serialized_end=3691,
)
_ELEMENTCOUNTSKIPRESTRICTION = _descriptor.Descriptor(
name='ElementCountSkipRestriction',
full_name='org.apache.beam.fn.v1.ElementCountSkipRestriction',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='count', full_name='org.apache.beam.fn.v1.ElementCountSkipRestriction.count', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3693,
serialized_end=3737,
)
_PRIMITIVETRANSFORMSPLIT = _descriptor.Descriptor(
name='PrimitiveTransformSplit',
full_name='org.apache.beam.fn.v1.PrimitiveTransformSplit',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='primitive_transform_reference', full_name='org.apache.beam.fn.v1.PrimitiveTransformSplit.primitive_transform_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='completed_restriction', full_name='org.apache.beam.fn.v1.PrimitiveTransformSplit.completed_restriction', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='remaining_restriction', full_name='org.apache.beam.fn.v1.PrimitiveTransformSplit.remaining_restriction', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3740,
serialized_end=3940,
)
_PROCESSBUNDLESPLITRESPONSE = _descriptor.Descriptor(
name='ProcessBundleSplitResponse',
full_name='org.apache.beam.fn.v1.ProcessBundleSplitResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='splits', full_name='org.apache.beam.fn.v1.ProcessBundleSplitResponse.splits', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3942,
serialized_end=4034,
)
_ELEMENTS_DATA = _descriptor.Descriptor(
name='Data',
full_name='org.apache.beam.fn.v1.Elements.Data',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='instruction_reference', full_name='org.apache.beam.fn.v1.Elements.Data.instruction_reference', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='target', full_name='org.apache.beam.fn.v1.Elements.Data.target', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='data', full_name='org.apache.beam.fn.v1.Elements.Data.data', index=2,
number=3, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4101,
serialized_end=4199,
)
_ELEMENTS = _descriptor.Descriptor(
name='Elements',
full_name='org.apache.beam.fn.v1.Elements',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='data', full_name='org.apache.beam.fn.v1.Elements.data', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[_ELEMENTS_DATA, ],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4037,
serialized_end=4199,
)
_STATEREQUEST = _descriptor.Descriptor(
name='StateRequest',
full_name='org.apache.beam.fn.v1.StateRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.StateRequest.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='instruction_reference', full_name='org.apache.beam.fn.v1.StateRequest.instruction_reference', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='state_key', full_name='org.apache.beam.fn.v1.StateRequest.state_key', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='get', full_name='org.apache.beam.fn.v1.StateRequest.get', index=3,
number=1000, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='append', full_name='org.apache.beam.fn.v1.StateRequest.append', index=4,
number=1001, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='clear', full_name='org.apache.beam.fn.v1.StateRequest.clear', index=5,
number=1002, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='request', full_name='org.apache.beam.fn.v1.StateRequest.request',
index=0, containing_type=None, fields=[]),
],
serialized_start=4202,
serialized_end=4500,
)
_STATERESPONSE = _descriptor.Descriptor(
name='StateResponse',
full_name='org.apache.beam.fn.v1.StateResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.StateResponse.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='error', full_name='org.apache.beam.fn.v1.StateResponse.error', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='cache_token', full_name='org.apache.beam.fn.v1.StateResponse.cache_token', index=2,
number=3, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='get', full_name='org.apache.beam.fn.v1.StateResponse.get', index=3,
number=1000, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='append', full_name='org.apache.beam.fn.v1.StateResponse.append', index=4,
number=1001, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='clear', full_name='org.apache.beam.fn.v1.StateResponse.clear', index=5,
number=1002, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='response', full_name='org.apache.beam.fn.v1.StateResponse.response',
index=0, containing_type=None, fields=[]),
],
serialized_start=4503,
serialized_end=4759,
)
_STATEKEY_RUNNER = _descriptor.Descriptor(
name='Runner',
full_name='org.apache.beam.fn.v1.StateKey.Runner',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.StateKey.Runner.key', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4986,
serialized_end=5007,
)
_STATEKEY_MULTIMAPSIDEINPUT = _descriptor.Descriptor(
name='MultimapSideInput',
full_name='org.apache.beam.fn.v1.StateKey.MultimapSideInput',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='ptransform_id', full_name='org.apache.beam.fn.v1.StateKey.MultimapSideInput.ptransform_id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='side_input_id', full_name='org.apache.beam.fn.v1.StateKey.MultimapSideInput.side_input_id', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='window', full_name='org.apache.beam.fn.v1.StateKey.MultimapSideInput.window', index=2,
number=3, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.StateKey.MultimapSideInput.key', index=3,
number=4, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5009,
serialized_end=5103,
)
_STATEKEY_BAGUSERSTATE = _descriptor.Descriptor(
name='BagUserState',
full_name='org.apache.beam.fn.v1.StateKey.BagUserState',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='ptransform_id', full_name='org.apache.beam.fn.v1.StateKey.BagUserState.ptransform_id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='user_state_id', full_name='org.apache.beam.fn.v1.StateKey.BagUserState.user_state_id', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='window', full_name='org.apache.beam.fn.v1.StateKey.BagUserState.window', index=2,
number=3, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='key', full_name='org.apache.beam.fn.v1.StateKey.BagUserState.key', index=3,
number=4, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5105,
serialized_end=5194,
)
_STATEKEY = _descriptor.Descriptor(
name='StateKey',
full_name='org.apache.beam.fn.v1.StateKey',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='runner', full_name='org.apache.beam.fn.v1.StateKey.runner', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='multimap_side_input', full_name='org.apache.beam.fn.v1.StateKey.multimap_side_input', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='bag_user_state', full_name='org.apache.beam.fn.v1.StateKey.bag_user_state', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[_STATEKEY_RUNNER, _STATEKEY_MULTIMAPSIDEINPUT, _STATEKEY_BAGUSERSTATE, ],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='type', full_name='org.apache.beam.fn.v1.StateKey.type',
index=0, containing_type=None, fields=[]),
],
serialized_start=4762,
serialized_end=5202,
)
_STATEGETREQUEST = _descriptor.Descriptor(
name='StateGetRequest',
full_name='org.apache.beam.fn.v1.StateGetRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='continuation_token', full_name='org.apache.beam.fn.v1.StateGetRequest.continuation_token', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5204,
serialized_end=5249,
)
_STATEGETRESPONSE = _descriptor.Descriptor(
name='StateGetResponse',
full_name='org.apache.beam.fn.v1.StateGetResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='continuation_token', full_name='org.apache.beam.fn.v1.StateGetResponse.continuation_token', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='data', full_name='org.apache.beam.fn.v1.StateGetResponse.data', index=1,
number=2, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5251,
serialized_end=5311,
)
_STATEAPPENDREQUEST = _descriptor.Descriptor(
name='StateAppendRequest',
full_name='org.apache.beam.fn.v1.StateAppendRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='data', full_name='org.apache.beam.fn.v1.StateAppendRequest.data', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5313,
serialized_end=5347,
)
_STATEAPPENDRESPONSE = _descriptor.Descriptor(
name='StateAppendResponse',
full_name='org.apache.beam.fn.v1.StateAppendResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5349,
serialized_end=5370,
)
_STATECLEARREQUEST = _descriptor.Descriptor(
name='StateClearRequest',
full_name='org.apache.beam.fn.v1.StateClearRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5372,
serialized_end=5391,
)
_STATECLEARRESPONSE = _descriptor.Descriptor(
name='StateClearResponse',
full_name='org.apache.beam.fn.v1.StateClearResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5393,
serialized_end=5413,
)
_LOGENTRY_LIST = _descriptor.Descriptor(
name='List',
full_name='org.apache.beam.fn.v1.LogEntry.List',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='log_entries', full_name='org.apache.beam.fn.v1.LogEntry.List.log_entries', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5675,
serialized_end=5735,
)
_LOGENTRY = _descriptor.Descriptor(
name='LogEntry',
full_name='org.apache.beam.fn.v1.LogEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='severity', full_name='org.apache.beam.fn.v1.LogEntry.severity', index=0,
number=1, type=14, cpp_type=8, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='timestamp', full_name='org.apache.beam.fn.v1.LogEntry.timestamp', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='message', full_name='org.apache.beam.fn.v1.LogEntry.message', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='trace', full_name='org.apache.beam.fn.v1.LogEntry.trace', index=3,
number=4, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='instruction_reference', full_name='org.apache.beam.fn.v1.LogEntry.instruction_reference', index=4,
number=5, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='primitive_transform_reference', full_name='org.apache.beam.fn.v1.LogEntry.primitive_transform_reference', index=5,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='log_location', full_name='org.apache.beam.fn.v1.LogEntry.log_location', index=6,
number=7, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='thread', full_name='org.apache.beam.fn.v1.LogEntry.thread', index=7,
number=8, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[_LOGENTRY_LIST, ],
enum_types=[
_LOGENTRY_SEVERITY,
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5416,
serialized_end=5826,
)
_LOGCONTROL = _descriptor.Descriptor(
name='LogControl',
full_name='org.apache.beam.fn.v1.LogControl',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5828,
serialized_end=5840,
)
_APISERVICEDESCRIPTOR = _descriptor.Descriptor(
name='ApiServiceDescriptor',
full_name='org.apache.beam.fn.v1.ApiServiceDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.ApiServiceDescriptor.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='url', full_name='org.apache.beam.fn.v1.ApiServiceDescriptor.url', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='oauth2_client_credentials_grant', full_name='org.apache.beam.fn.v1.ApiServiceDescriptor.oauth2_client_credentials_grant', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='authentication', full_name='org.apache.beam.fn.v1.ApiServiceDescriptor.authentication',
index=0, containing_type=None, fields=[]),
],
serialized_start=5843,
serialized_end=6004,
)
_OAUTH2CLIENTCREDENTIALSGRANT = _descriptor.Descriptor(
name='OAuth2ClientCredentialsGrant',
full_name='org.apache.beam.fn.v1.OAuth2ClientCredentialsGrant',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='url', full_name='org.apache.beam.fn.v1.OAuth2ClientCredentialsGrant.url', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=6006,
serialized_end=6049,
)
_DOCKERCONTAINER = _descriptor.Descriptor(
name='DockerContainer',
full_name='org.apache.beam.fn.v1.DockerContainer',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='org.apache.beam.fn.v1.DockerContainer.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='uri', full_name='org.apache.beam.fn.v1.DockerContainer.uri', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
name='registry_reference', full_name='org.apache.beam.fn.v1.DockerContainer.registry_reference', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=6051,
serialized_end=6121,
)
_TARGET_LIST.fields_by_name['target'].message_type = _TARGET
_TARGET_LIST.containing_type = _TARGET
_PRIMITIVETRANSFORM_INPUTSENTRY.fields_by_name['value'].message_type = _TARGET_LIST
_PRIMITIVETRANSFORM_INPUTSENTRY.containing_type = _PRIMITIVETRANSFORM
_PRIMITIVETRANSFORM_OUTPUTSENTRY.fields_by_name['value'].message_type = _PCOLLECTION
_PRIMITIVETRANSFORM_OUTPUTSENTRY.containing_type = _PRIMITIVETRANSFORM
_PRIMITIVETRANSFORM_SIDEINPUTSENTRY.fields_by_name['value'].message_type = _SIDEINPUT
_PRIMITIVETRANSFORM_SIDEINPUTSENTRY.containing_type = _PRIMITIVETRANSFORM
_PRIMITIVETRANSFORM.fields_by_name['function_spec'].message_type = _FUNCTIONSPEC
_PRIMITIVETRANSFORM.fields_by_name['inputs'].message_type = _PRIMITIVETRANSFORM_INPUTSENTRY
_PRIMITIVETRANSFORM.fields_by_name['outputs'].message_type = _PRIMITIVETRANSFORM_OUTPUTSENTRY
_PRIMITIVETRANSFORM.fields_by_name['side_inputs'].message_type = _PRIMITIVETRANSFORM_SIDEINPUTSENTRY
_FUNCTIONSPEC.fields_by_name['data'].message_type = google_dot_protobuf_dot_any__pb2._ANY
_SIDEINPUT.fields_by_name['input'].message_type = _TARGET
_SIDEINPUT.fields_by_name['view_fn'].message_type = _FUNCTIONSPEC
_CODER.fields_by_name['function_spec'].message_type = _FUNCTIONSPEC
_REMOTEGRPCPORT.fields_by_name['api_service_descriptor'].message_type = _APISERVICEDESCRIPTOR
_INSTRUCTIONREQUEST.fields_by_name['register'].message_type = _REGISTERREQUEST
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'].message_type = _PROCESSBUNDLEREQUEST
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'].message_type = _PROCESSBUNDLEPROGRESSREQUEST
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'].message_type = _PROCESSBUNDLESPLITREQUEST
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
_INSTRUCTIONREQUEST.fields_by_name['register'])
_INSTRUCTIONREQUEST.fields_by_name['register'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONRESPONSE.fields_by_name['register'].message_type = _REGISTERRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].message_type = _PROCESSBUNDLERESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].message_type = _PROCESSBUNDLEPROGRESSRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].message_type = _PROCESSBUNDLESPLITRESPONSE
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
_INSTRUCTIONRESPONSE.fields_by_name['register'])
_INSTRUCTIONRESPONSE.fields_by_name['register'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_REGISTERREQUEST.fields_by_name['process_bundle_descriptor'].message_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PTRANSFORM
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PCOLLECTION
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._WINDOWINGSTRATEGY
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._CODER
_PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._ENVIRONMENT
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['primitive_transform'].message_type = _PRIMITIVETRANSFORM
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['coders'].message_type = _CODER
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['transforms'].message_type = _PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['pcollections'].message_type = _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['windowing_strategies'].message_type = _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['codersyyy'].message_type = _PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['environments'].message_type = _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY
_PRIMITIVETRANSFORMSPLIT.fields_by_name['completed_restriction'].message_type = _FUNCTIONSPEC
_PRIMITIVETRANSFORMSPLIT.fields_by_name['remaining_restriction'].message_type = _FUNCTIONSPEC
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['splits'].message_type = _PRIMITIVETRANSFORMSPLIT
_ELEMENTS_DATA.fields_by_name['target'].message_type = _TARGET
_ELEMENTS_DATA.containing_type = _ELEMENTS
_ELEMENTS.fields_by_name['data'].message_type = _ELEMENTS_DATA
_STATEREQUEST.fields_by_name['state_key'].message_type = _STATEKEY
_STATEREQUEST.fields_by_name['get'].message_type = _STATEGETREQUEST
_STATEREQUEST.fields_by_name['append'].message_type = _STATEAPPENDREQUEST
_STATEREQUEST.fields_by_name['clear'].message_type = _STATECLEARREQUEST
_STATEREQUEST.oneofs_by_name['request'].fields.append(
_STATEREQUEST.fields_by_name['get'])
_STATEREQUEST.fields_by_name['get'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATEREQUEST.oneofs_by_name['request'].fields.append(
_STATEREQUEST.fields_by_name['append'])
_STATEREQUEST.fields_by_name['append'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATEREQUEST.oneofs_by_name['request'].fields.append(
_STATEREQUEST.fields_by_name['clear'])
_STATEREQUEST.fields_by_name['clear'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATERESPONSE.fields_by_name['get'].message_type = _STATEGETRESPONSE
_STATERESPONSE.fields_by_name['append'].message_type = _STATEAPPENDRESPONSE
_STATERESPONSE.fields_by_name['clear'].message_type = _STATECLEARRESPONSE
_STATERESPONSE.oneofs_by_name['response'].fields.append(
_STATERESPONSE.fields_by_name['get'])
_STATERESPONSE.fields_by_name['get'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATERESPONSE.oneofs_by_name['response'].fields.append(
_STATERESPONSE.fields_by_name['append'])
_STATERESPONSE.fields_by_name['append'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATERESPONSE.oneofs_by_name['response'].fields.append(
_STATERESPONSE.fields_by_name['clear'])
_STATERESPONSE.fields_by_name['clear'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATEKEY_RUNNER.containing_type = _STATEKEY
_STATEKEY_MULTIMAPSIDEINPUT.containing_type = _STATEKEY
_STATEKEY_BAGUSERSTATE.containing_type = _STATEKEY
_STATEKEY.fields_by_name['runner'].message_type = _STATEKEY_RUNNER
_STATEKEY.fields_by_name['multimap_side_input'].message_type = _STATEKEY_MULTIMAPSIDEINPUT
_STATEKEY.fields_by_name['bag_user_state'].message_type = _STATEKEY_BAGUSERSTATE
_STATEKEY.oneofs_by_name['type'].fields.append(
_STATEKEY.fields_by_name['runner'])
_STATEKEY.fields_by_name['runner'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
_STATEKEY.fields_by_name['multimap_side_input'])
_STATEKEY.fields_by_name['multimap_side_input'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
_STATEKEY.fields_by_name['bag_user_state'])
_STATEKEY.fields_by_name['bag_user_state'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_LOGENTRY_LIST.fields_by_name['log_entries'].message_type = _LOGENTRY
_LOGENTRY_LIST.containing_type = _LOGENTRY
_LOGENTRY.fields_by_name['severity'].enum_type = _LOGENTRY_SEVERITY
_LOGENTRY.fields_by_name['timestamp'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_LOGENTRY_SEVERITY.containing_type = _LOGENTRY
_APISERVICEDESCRIPTOR.fields_by_name['oauth2_client_credentials_grant'].message_type = _OAUTH2CLIENTCREDENTIALSGRANT
_APISERVICEDESCRIPTOR.oneofs_by_name['authentication'].fields.append(
_APISERVICEDESCRIPTOR.fields_by_name['oauth2_client_credentials_grant'])
_APISERVICEDESCRIPTOR.fields_by_name['oauth2_client_credentials_grant'].containing_oneof = _APISERVICEDESCRIPTOR.oneofs_by_name['authentication']
DESCRIPTOR.message_types_by_name['Target'] = _TARGET
DESCRIPTOR.message_types_by_name['PCollection'] = _PCOLLECTION
DESCRIPTOR.message_types_by_name['PrimitiveTransform'] = _PRIMITIVETRANSFORM
DESCRIPTOR.message_types_by_name['FunctionSpec'] = _FUNCTIONSPEC
DESCRIPTOR.message_types_by_name['SideInput'] = _SIDEINPUT
DESCRIPTOR.message_types_by_name['Coder'] = _CODER
DESCRIPTOR.message_types_by_name['RemoteGrpcPort'] = _REMOTEGRPCPORT
DESCRIPTOR.message_types_by_name['InstructionRequest'] = _INSTRUCTIONREQUEST
DESCRIPTOR.message_types_by_name['InstructionResponse'] = _INSTRUCTIONRESPONSE
DESCRIPTOR.message_types_by_name['RegisterRequest'] = _REGISTERREQUEST
DESCRIPTOR.message_types_by_name['RegisterResponse'] = _REGISTERRESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleDescriptor'] = _PROCESSBUNDLEDESCRIPTOR
DESCRIPTOR.message_types_by_name['ProcessBundleRequest'] = _PROCESSBUNDLEREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleResponse'] = _PROCESSBUNDLERESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleProgressRequest'] = _PROCESSBUNDLEPROGRESSREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleProgressResponse'] = _PROCESSBUNDLEPROGRESSRESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleSplitRequest'] = _PROCESSBUNDLESPLITREQUEST
DESCRIPTOR.message_types_by_name['ElementCountRestriction'] = _ELEMENTCOUNTRESTRICTION
DESCRIPTOR.message_types_by_name['ElementCountSkipRestriction'] = _ELEMENTCOUNTSKIPRESTRICTION
DESCRIPTOR.message_types_by_name['PrimitiveTransformSplit'] = _PRIMITIVETRANSFORMSPLIT
DESCRIPTOR.message_types_by_name['ProcessBundleSplitResponse'] = _PROCESSBUNDLESPLITRESPONSE
DESCRIPTOR.message_types_by_name['Elements'] = _ELEMENTS
DESCRIPTOR.message_types_by_name['StateRequest'] = _STATEREQUEST
DESCRIPTOR.message_types_by_name['StateResponse'] = _STATERESPONSE
DESCRIPTOR.message_types_by_name['StateKey'] = _STATEKEY
DESCRIPTOR.message_types_by_name['StateGetRequest'] = _STATEGETREQUEST
DESCRIPTOR.message_types_by_name['StateGetResponse'] = _STATEGETRESPONSE
DESCRIPTOR.message_types_by_name['StateAppendRequest'] = _STATEAPPENDREQUEST
DESCRIPTOR.message_types_by_name['StateAppendResponse'] = _STATEAPPENDRESPONSE
DESCRIPTOR.message_types_by_name['StateClearRequest'] = _STATECLEARREQUEST
DESCRIPTOR.message_types_by_name['StateClearResponse'] = _STATECLEARRESPONSE
DESCRIPTOR.message_types_by_name['LogEntry'] = _LOGENTRY
DESCRIPTOR.message_types_by_name['LogControl'] = _LOGCONTROL
DESCRIPTOR.message_types_by_name['ApiServiceDescriptor'] = _APISERVICEDESCRIPTOR
DESCRIPTOR.message_types_by_name['OAuth2ClientCredentialsGrant'] = _OAUTH2CLIENTCREDENTIALSGRANT
DESCRIPTOR.message_types_by_name['DockerContainer'] = _DOCKERCONTAINER
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
Target = _reflection.GeneratedProtocolMessageType('Target', (_message.Message,), dict(
List = _reflection.GeneratedProtocolMessageType('List', (_message.Message,), dict(
DESCRIPTOR = _TARGET_LIST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.Target.List)
))
,
DESCRIPTOR = _TARGET,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.Target)
))
_sym_db.RegisterMessage(Target)
_sym_db.RegisterMessage(Target.List)
PCollection = _reflection.GeneratedProtocolMessageType('PCollection', (_message.Message,), dict(
DESCRIPTOR = _PCOLLECTION,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PCollection)
))
_sym_db.RegisterMessage(PCollection)
PrimitiveTransform = _reflection.GeneratedProtocolMessageType('PrimitiveTransform', (_message.Message,), dict(
InputsEntry = _reflection.GeneratedProtocolMessageType('InputsEntry', (_message.Message,), dict(
DESCRIPTOR = _PRIMITIVETRANSFORM_INPUTSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PrimitiveTransform.InputsEntry)
))
,
OutputsEntry = _reflection.GeneratedProtocolMessageType('OutputsEntry', (_message.Message,), dict(
DESCRIPTOR = _PRIMITIVETRANSFORM_OUTPUTSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntry)
))
,
SideInputsEntry = _reflection.GeneratedProtocolMessageType('SideInputsEntry', (_message.Message,), dict(
DESCRIPTOR = _PRIMITIVETRANSFORM_SIDEINPUTSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntry)
))
,
DESCRIPTOR = _PRIMITIVETRANSFORM,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PrimitiveTransform)
))
_sym_db.RegisterMessage(PrimitiveTransform)
_sym_db.RegisterMessage(PrimitiveTransform.InputsEntry)
_sym_db.RegisterMessage(PrimitiveTransform.OutputsEntry)
_sym_db.RegisterMessage(PrimitiveTransform.SideInputsEntry)
FunctionSpec = _reflection.GeneratedProtocolMessageType('FunctionSpec', (_message.Message,), dict(
DESCRIPTOR = _FUNCTIONSPEC,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.FunctionSpec)
))
_sym_db.RegisterMessage(FunctionSpec)
SideInput = _reflection.GeneratedProtocolMessageType('SideInput', (_message.Message,), dict(
DESCRIPTOR = _SIDEINPUT,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.SideInput)
))
_sym_db.RegisterMessage(SideInput)
Coder = _reflection.GeneratedProtocolMessageType('Coder', (_message.Message,), dict(
DESCRIPTOR = _CODER,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.Coder)
))
_sym_db.RegisterMessage(Coder)
RemoteGrpcPort = _reflection.GeneratedProtocolMessageType('RemoteGrpcPort', (_message.Message,), dict(
DESCRIPTOR = _REMOTEGRPCPORT,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.RemoteGrpcPort)
))
_sym_db.RegisterMessage(RemoteGrpcPort)
InstructionRequest = _reflection.GeneratedProtocolMessageType('InstructionRequest', (_message.Message,), dict(
DESCRIPTOR = _INSTRUCTIONREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.InstructionRequest)
))
_sym_db.RegisterMessage(InstructionRequest)
InstructionResponse = _reflection.GeneratedProtocolMessageType('InstructionResponse', (_message.Message,), dict(
DESCRIPTOR = _INSTRUCTIONRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.InstructionResponse)
))
_sym_db.RegisterMessage(InstructionResponse)
RegisterRequest = _reflection.GeneratedProtocolMessageType('RegisterRequest', (_message.Message,), dict(
DESCRIPTOR = _REGISTERREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.RegisterRequest)
))
_sym_db.RegisterMessage(RegisterRequest)
RegisterResponse = _reflection.GeneratedProtocolMessageType('RegisterResponse', (_message.Message,), dict(
DESCRIPTOR = _REGISTERRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.RegisterResponse)
))
_sym_db.RegisterMessage(RegisterResponse)
ProcessBundleDescriptor = _reflection.GeneratedProtocolMessageType('ProcessBundleDescriptor', (_message.Message,), dict(
TransformsEntry = _reflection.GeneratedProtocolMessageType('TransformsEntry', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor.TransformsEntry)
))
,
PcollectionsEntry = _reflection.GeneratedProtocolMessageType('PcollectionsEntry', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor.PcollectionsEntry)
))
,
WindowingStrategiesEntry = _reflection.GeneratedProtocolMessageType('WindowingStrategiesEntry', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor.WindowingStrategiesEntry)
))
,
CodersyyyEntry = _reflection.GeneratedProtocolMessageType('CodersyyyEntry', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor.CodersyyyEntry)
))
,
EnvironmentsEntry = _reflection.GeneratedProtocolMessageType('EnvironmentsEntry', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor.EnvironmentsEntry)
))
,
DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor)
))
_sym_db.RegisterMessage(ProcessBundleDescriptor)
_sym_db.RegisterMessage(ProcessBundleDescriptor.TransformsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.PcollectionsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.WindowingStrategiesEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.CodersyyyEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.EnvironmentsEntry)
ProcessBundleRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleRequest', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleRequest)
))
_sym_db.RegisterMessage(ProcessBundleRequest)
ProcessBundleResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleResponse', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLERESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleResponse)
))
_sym_db.RegisterMessage(ProcessBundleResponse)
ProcessBundleProgressRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleProgressRequest', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEPROGRESSREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleProgressRequest)
))
_sym_db.RegisterMessage(ProcessBundleProgressRequest)
ProcessBundleProgressResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleProgressResponse', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLEPROGRESSRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleProgressResponse)
))
_sym_db.RegisterMessage(ProcessBundleProgressResponse)
ProcessBundleSplitRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleSplitRequest', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLESPLITREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleSplitRequest)
))
_sym_db.RegisterMessage(ProcessBundleSplitRequest)
ElementCountRestriction = _reflection.GeneratedProtocolMessageType('ElementCountRestriction', (_message.Message,), dict(
DESCRIPTOR = _ELEMENTCOUNTRESTRICTION,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ElementCountRestriction)
))
_sym_db.RegisterMessage(ElementCountRestriction)
ElementCountSkipRestriction = _reflection.GeneratedProtocolMessageType('ElementCountSkipRestriction', (_message.Message,), dict(
DESCRIPTOR = _ELEMENTCOUNTSKIPRESTRICTION,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ElementCountSkipRestriction)
))
_sym_db.RegisterMessage(ElementCountSkipRestriction)
PrimitiveTransformSplit = _reflection.GeneratedProtocolMessageType('PrimitiveTransformSplit', (_message.Message,), dict(
DESCRIPTOR = _PRIMITIVETRANSFORMSPLIT,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.PrimitiveTransformSplit)
))
_sym_db.RegisterMessage(PrimitiveTransformSplit)
ProcessBundleSplitResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleSplitResponse', (_message.Message,), dict(
DESCRIPTOR = _PROCESSBUNDLESPLITRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleSplitResponse)
))
_sym_db.RegisterMessage(ProcessBundleSplitResponse)
Elements = _reflection.GeneratedProtocolMessageType('Elements', (_message.Message,), dict(
Data = _reflection.GeneratedProtocolMessageType('Data', (_message.Message,), dict(
DESCRIPTOR = _ELEMENTS_DATA,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.Elements.Data)
))
,
DESCRIPTOR = _ELEMENTS,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.Elements)
))
_sym_db.RegisterMessage(Elements)
_sym_db.RegisterMessage(Elements.Data)
StateRequest = _reflection.GeneratedProtocolMessageType('StateRequest', (_message.Message,), dict(
DESCRIPTOR = _STATEREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateRequest)
))
_sym_db.RegisterMessage(StateRequest)
StateResponse = _reflection.GeneratedProtocolMessageType('StateResponse', (_message.Message,), dict(
DESCRIPTOR = _STATERESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateResponse)
))
_sym_db.RegisterMessage(StateResponse)
StateKey = _reflection.GeneratedProtocolMessageType('StateKey', (_message.Message,), dict(
Runner = _reflection.GeneratedProtocolMessageType('Runner', (_message.Message,), dict(
DESCRIPTOR = _STATEKEY_RUNNER,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateKey.Runner)
))
,
MultimapSideInput = _reflection.GeneratedProtocolMessageType('MultimapSideInput', (_message.Message,), dict(
DESCRIPTOR = _STATEKEY_MULTIMAPSIDEINPUT,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateKey.MultimapSideInput)
))
,
BagUserState = _reflection.GeneratedProtocolMessageType('BagUserState', (_message.Message,), dict(
DESCRIPTOR = _STATEKEY_BAGUSERSTATE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateKey.BagUserState)
))
,
DESCRIPTOR = _STATEKEY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateKey)
))
_sym_db.RegisterMessage(StateKey)
_sym_db.RegisterMessage(StateKey.Runner)
_sym_db.RegisterMessage(StateKey.MultimapSideInput)
_sym_db.RegisterMessage(StateKey.BagUserState)
StateGetRequest = _reflection.GeneratedProtocolMessageType('StateGetRequest', (_message.Message,), dict(
DESCRIPTOR = _STATEGETREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateGetRequest)
))
_sym_db.RegisterMessage(StateGetRequest)
StateGetResponse = _reflection.GeneratedProtocolMessageType('StateGetResponse', (_message.Message,), dict(
DESCRIPTOR = _STATEGETRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateGetResponse)
))
_sym_db.RegisterMessage(StateGetResponse)
StateAppendRequest = _reflection.GeneratedProtocolMessageType('StateAppendRequest', (_message.Message,), dict(
DESCRIPTOR = _STATEAPPENDREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateAppendRequest)
))
_sym_db.RegisterMessage(StateAppendRequest)
StateAppendResponse = _reflection.GeneratedProtocolMessageType('StateAppendResponse', (_message.Message,), dict(
DESCRIPTOR = _STATEAPPENDRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateAppendResponse)
))
_sym_db.RegisterMessage(StateAppendResponse)
StateClearRequest = _reflection.GeneratedProtocolMessageType('StateClearRequest', (_message.Message,), dict(
DESCRIPTOR = _STATECLEARREQUEST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateClearRequest)
))
_sym_db.RegisterMessage(StateClearRequest)
StateClearResponse = _reflection.GeneratedProtocolMessageType('StateClearResponse', (_message.Message,), dict(
DESCRIPTOR = _STATECLEARRESPONSE,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateClearResponse)
))
_sym_db.RegisterMessage(StateClearResponse)
LogEntry = _reflection.GeneratedProtocolMessageType('LogEntry', (_message.Message,), dict(
List = _reflection.GeneratedProtocolMessageType('List', (_message.Message,), dict(
DESCRIPTOR = _LOGENTRY_LIST,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.LogEntry.List)
))
,
DESCRIPTOR = _LOGENTRY,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.LogEntry)
))
_sym_db.RegisterMessage(LogEntry)
_sym_db.RegisterMessage(LogEntry.List)
LogControl = _reflection.GeneratedProtocolMessageType('LogControl', (_message.Message,), dict(
DESCRIPTOR = _LOGCONTROL,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.LogControl)
))
_sym_db.RegisterMessage(LogControl)
ApiServiceDescriptor = _reflection.GeneratedProtocolMessageType('ApiServiceDescriptor', (_message.Message,), dict(
DESCRIPTOR = _APISERVICEDESCRIPTOR,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ApiServiceDescriptor)
))
_sym_db.RegisterMessage(ApiServiceDescriptor)
OAuth2ClientCredentialsGrant = _reflection.GeneratedProtocolMessageType('OAuth2ClientCredentialsGrant', (_message.Message,), dict(
DESCRIPTOR = _OAUTH2CLIENTCREDENTIALSGRANT,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.OAuth2ClientCredentialsGrant)
))
_sym_db.RegisterMessage(OAuth2ClientCredentialsGrant)
DockerContainer = _reflection.GeneratedProtocolMessageType('DockerContainer', (_message.Message,), dict(
DESCRIPTOR = _DOCKERCONTAINER,
__module__ = 'beam_fn_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.DockerContainer)
))
_sym_db.RegisterMessage(DockerContainer)
DESCRIPTOR.has_options = True
DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n\025org.apache.beam.fn.v1B\tBeamFnApi'))
_PCOLLECTION.fields_by_name['coder_reference'].has_options = True
_PCOLLECTION.fields_by_name['coder_reference']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM_INPUTSENTRY.has_options = True
_PRIMITIVETRANSFORM_INPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PRIMITIVETRANSFORM_OUTPUTSENTRY.has_options = True
_PRIMITIVETRANSFORM_OUTPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PRIMITIVETRANSFORM_SIDEINPUTSENTRY.has_options = True
_PRIMITIVETRANSFORM_SIDEINPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PRIMITIVETRANSFORM.fields_by_name['id'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['id']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM.fields_by_name['function_spec'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['function_spec']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM.fields_by_name['inputs'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['inputs']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM.fields_by_name['outputs'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['outputs']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM.fields_by_name['side_inputs'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['side_inputs']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PRIMITIVETRANSFORM.fields_by_name['step_name'].has_options = True
_PRIMITIVETRANSFORM.fields_by_name['step_name']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_FUNCTIONSPEC.fields_by_name['id'].has_options = True
_FUNCTIONSPEC.fields_by_name['id']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_FUNCTIONSPEC.fields_by_name['urn'].has_options = True
_FUNCTIONSPEC.fields_by_name['urn']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_FUNCTIONSPEC.fields_by_name['environment_reference'].has_options = True
_FUNCTIONSPEC.fields_by_name['environment_reference']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_FUNCTIONSPEC.fields_by_name['data'].has_options = True
_FUNCTIONSPEC.fields_by_name['data']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_SIDEINPUT.fields_by_name['input'].has_options = True
_SIDEINPUT.fields_by_name['input']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_SIDEINPUT.fields_by_name['view_fn'].has_options = True
_SIDEINPUT.fields_by_name['view_fn']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_CODER.fields_by_name['function_spec'].has_options = True
_CODER.fields_by_name['function_spec']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_CODER.fields_by_name['component_coder_reference'].has_options = True
_CODER.fields_by_name['component_coder_reference']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_CODERSYYYENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['primitive_transform'].has_options = True
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['primitive_transform']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['coders'].has_options = True
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['coders']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\030\001'))
try:
# THESE ELEMENTS WILL BE DEPRECATED.
# Please use the generated *_pb2_grpc.py files instead.
import grpc
from grpc.beta import implementations as beta_implementations
from grpc.beta import interfaces as beta_interfaces
from grpc.framework.common import cardinality
from grpc.framework.interfaces.face import utilities as face_utilities
[docs] class BeamFnControlStub(object):
"""
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change
with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do.
Stable
"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Control = channel.stream_stream(
'/org.apache.beam.fn.v1.BeamFnControl/Control',
request_serializer=InstructionResponse.SerializeToString,
response_deserializer=InstructionRequest.FromString,
)
[docs] class BeamFnControlServicer(object):
"""
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change
with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do.
Stable
"""
[docs] def Control(self, request_iterator, context):
"""Instructions sent by the runner to the SDK requesting different types
of work.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def add_BeamFnControlServicer_to_server(servicer, server):
rpc_method_handlers = {
'Control': grpc.stream_stream_rpc_method_handler(
servicer.Control,
request_deserializer=InstructionResponse.FromString,
response_serializer=InstructionRequest.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.apache.beam.fn.v1.BeamFnControl', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
[docs] class BeamFnDataStub(object):
"""Stable
"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Data = channel.stream_stream(
'/org.apache.beam.fn.v1.BeamFnData/Data',
request_serializer=Elements.SerializeToString,
response_deserializer=Elements.FromString,
)
[docs] class BeamFnDataServicer(object):
"""Stable
"""
[docs] def Data(self, request_iterator, context):
"""Used to send data between harnesses.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def add_BeamFnDataServicer_to_server(servicer, server):
rpc_method_handlers = {
'Data': grpc.stream_stream_rpc_method_handler(
servicer.Data,
request_deserializer=Elements.FromString,
response_serializer=Elements.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.apache.beam.fn.v1.BeamFnData', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
[docs] class BeamFnStateStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.State = channel.stream_stream(
'/org.apache.beam.fn.v1.BeamFnState/State',
request_serializer=StateRequest.SerializeToString,
response_deserializer=StateResponse.FromString,
)
[docs] class BeamFnStateServicer(object):
# missing associated documentation comment in .proto file
pass
[docs] def State(self, request_iterator, context):
"""Used to get/append/clear state stored by the runner on behalf of the SDK.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def add_BeamFnStateServicer_to_server(servicer, server):
rpc_method_handlers = {
'State': grpc.stream_stream_rpc_method_handler(
servicer.State,
request_deserializer=StateRequest.FromString,
response_serializer=StateResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.apache.beam.fn.v1.BeamFnState', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
[docs] class BeamFnLoggingStub(object):
"""Stable
"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Logging = channel.stream_stream(
'/org.apache.beam.fn.v1.BeamFnLogging/Logging',
request_serializer=LogEntry.List.SerializeToString,
response_deserializer=LogControl.FromString,
)
[docs] class BeamFnLoggingServicer(object):
"""Stable
"""
[docs] def Logging(self, request_iterator, context):
"""Allows for the SDK to emit log entries which the runner can
associate with the active job.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def add_BeamFnLoggingServicer_to_server(servicer, server):
rpc_method_handlers = {
'Logging': grpc.stream_stream_rpc_method_handler(
servicer.Logging,
request_deserializer=LogEntry.List.FromString,
response_serializer=LogControl.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.apache.beam.fn.v1.BeamFnLogging', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
[docs] class BetaBeamFnControlServicer(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change
with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do.
Stable
"""
[docs] def Control(self, request_iterator, context):
"""Instructions sent by the runner to the SDK requesting different types
of work.
"""
context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
[docs] class BetaBeamFnControlStub(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""
Control Plane API
Progress reporting and splitting still need further vetting. Also, this may change
with the addition of new types of instructions/responses related to metrics.
An API that describes the work that a SDK harness is meant to do.
Stable
"""
[docs] def Control(self, request_iterator, timeout, metadata=None, with_call=False, protocol_options=None):
"""Instructions sent by the runner to the SDK requesting different types
of work.
"""
raise NotImplementedError()
[docs] def beta_create_BeamFnControl_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_deserializers = {
('org.apache.beam.fn.v1.BeamFnControl', 'Control'): InstructionResponse.FromString,
}
response_serializers = {
('org.apache.beam.fn.v1.BeamFnControl', 'Control'): InstructionRequest.SerializeToString,
}
method_implementations = {
('org.apache.beam.fn.v1.BeamFnControl', 'Control'): face_utilities.stream_stream_inline(servicer.Control),
}
server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
return beta_implementations.server(method_implementations, options=server_options)
[docs] def beta_create_BeamFnControl_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_serializers = {
('org.apache.beam.fn.v1.BeamFnControl', 'Control'): InstructionResponse.SerializeToString,
}
response_deserializers = {
('org.apache.beam.fn.v1.BeamFnControl', 'Control'): InstructionRequest.FromString,
}
cardinalities = {
'Control': cardinality.Cardinality.STREAM_STREAM,
}
stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
return beta_implementations.dynamic_stub(channel, 'org.apache.beam.fn.v1.BeamFnControl', cardinalities, options=stub_options)
[docs] class BetaBeamFnDataServicer(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""Stable
"""
[docs] def Data(self, request_iterator, context):
"""Used to send data between harnesses.
"""
context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
[docs] class BetaBeamFnDataStub(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""Stable
"""
[docs] def Data(self, request_iterator, timeout, metadata=None, with_call=False, protocol_options=None):
"""Used to send data between harnesses.
"""
raise NotImplementedError()
[docs] def beta_create_BeamFnData_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_deserializers = {
('org.apache.beam.fn.v1.BeamFnData', 'Data'): Elements.FromString,
}
response_serializers = {
('org.apache.beam.fn.v1.BeamFnData', 'Data'): Elements.SerializeToString,
}
method_implementations = {
('org.apache.beam.fn.v1.BeamFnData', 'Data'): face_utilities.stream_stream_inline(servicer.Data),
}
server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
return beta_implementations.server(method_implementations, options=server_options)
[docs] def beta_create_BeamFnData_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_serializers = {
('org.apache.beam.fn.v1.BeamFnData', 'Data'): Elements.SerializeToString,
}
response_deserializers = {
('org.apache.beam.fn.v1.BeamFnData', 'Data'): Elements.FromString,
}
cardinalities = {
'Data': cardinality.Cardinality.STREAM_STREAM,
}
stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
return beta_implementations.dynamic_stub(channel, 'org.apache.beam.fn.v1.BeamFnData', cardinalities, options=stub_options)
[docs] class BetaBeamFnStateServicer(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
# missing associated documentation comment in .proto file
pass
[docs] def State(self, request_iterator, context):
"""Used to get/append/clear state stored by the runner on behalf of the SDK.
"""
context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
[docs] class BetaBeamFnStateStub(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
# missing associated documentation comment in .proto file
pass
[docs] def State(self, request_iterator, timeout, metadata=None, with_call=False, protocol_options=None):
"""Used to get/append/clear state stored by the runner on behalf of the SDK.
"""
raise NotImplementedError()
[docs] def beta_create_BeamFnState_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_deserializers = {
('org.apache.beam.fn.v1.BeamFnState', 'State'): StateRequest.FromString,
}
response_serializers = {
('org.apache.beam.fn.v1.BeamFnState', 'State'): StateResponse.SerializeToString,
}
method_implementations = {
('org.apache.beam.fn.v1.BeamFnState', 'State'): face_utilities.stream_stream_inline(servicer.State),
}
server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
return beta_implementations.server(method_implementations, options=server_options)
[docs] def beta_create_BeamFnState_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_serializers = {
('org.apache.beam.fn.v1.BeamFnState', 'State'): StateRequest.SerializeToString,
}
response_deserializers = {
('org.apache.beam.fn.v1.BeamFnState', 'State'): StateResponse.FromString,
}
cardinalities = {
'State': cardinality.Cardinality.STREAM_STREAM,
}
stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
return beta_implementations.dynamic_stub(channel, 'org.apache.beam.fn.v1.BeamFnState', cardinalities, options=stub_options)
[docs] class BetaBeamFnLoggingServicer(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""Stable
"""
[docs] def Logging(self, request_iterator, context):
"""Allows for the SDK to emit log entries which the runner can
associate with the active job.
"""
context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
[docs] class BetaBeamFnLoggingStub(object):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This class was generated
only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
"""Stable
"""
[docs] def Logging(self, request_iterator, timeout, metadata=None, with_call=False, protocol_options=None):
"""Allows for the SDK to emit log entries which the runner can
associate with the active job.
"""
raise NotImplementedError()
[docs] def beta_create_BeamFnLogging_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_deserializers = {
('org.apache.beam.fn.v1.BeamFnLogging', 'Logging'): LogEntry.List.FromString,
}
response_serializers = {
('org.apache.beam.fn.v1.BeamFnLogging', 'Logging'): LogControl.SerializeToString,
}
method_implementations = {
('org.apache.beam.fn.v1.BeamFnLogging', 'Logging'): face_utilities.stream_stream_inline(servicer.Logging),
}
server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
return beta_implementations.server(method_implementations, options=server_options)
[docs] def beta_create_BeamFnLogging_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
"""The Beta API is deprecated for 0.15.0 and later.
It is recommended to use the GA API (classes and functions in this
file not marked beta) for all further purposes. This function was
generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
request_serializers = {
('org.apache.beam.fn.v1.BeamFnLogging', 'Logging'): LogEntry.List.SerializeToString,
}
response_deserializers = {
('org.apache.beam.fn.v1.BeamFnLogging', 'Logging'): LogControl.FromString,
}
cardinalities = {
'Logging': cardinality.Cardinality.STREAM_STREAM,
}
stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
return beta_implementations.dynamic_stub(channel, 'org.apache.beam.fn.v1.BeamFnLogging', cardinalities, options=stub_options)
except ImportError:
pass
# @@protoc_insertion_point(module_scope)