You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/04/24 21:52:45 UTC
[1/7] beam git commit: Generate python proto wrappers for runner and
fn API.
Repository: beam
Updated Branches:
refs/heads/master 0191e042b -> d7e7af8eb
http://git-wip-us.apache.org/repos/asf/beam/blob/2a59b057/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
new file mode 100644
index 0000000..f86861c
--- /dev/null
+++ b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
@@ -0,0 +1,186 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+import grpc
+from grpc.framework.common import cardinality
+from grpc.framework.interfaces.face import utilities as face_utilities
+
+import beam_fn_api_pb2 as beam__fn__api__pb2
+
+
+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=beam__fn__api__pb2.InstructionResponse.SerializeToString,
+ response_deserializer=beam__fn__api__pb2.InstructionRequest.FromString,
+ )
+
+
+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
+ """
+
+ 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!')
+
+
+def add_BeamFnControlServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'Control': grpc.stream_stream_rpc_method_handler(
+ servicer.Control,
+ request_deserializer=beam__fn__api__pb2.InstructionResponse.FromString,
+ response_serializer=beam__fn__api__pb2.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,))
+
+
+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=beam__fn__api__pb2.Elements.SerializeToString,
+ response_deserializer=beam__fn__api__pb2.Elements.FromString,
+ )
+
+
+class BeamFnDataServicer(object):
+ """Stable
+ """
+
+ 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!')
+
+
+def add_BeamFnDataServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'Data': grpc.stream_stream_rpc_method_handler(
+ servicer.Data,
+ request_deserializer=beam__fn__api__pb2.Elements.FromString,
+ response_serializer=beam__fn__api__pb2.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,))
+
+
+class BeamFnStateStub(object):
+
+ def __init__(self, channel):
+ """Constructor.
+
+ Args:
+ channel: A grpc.Channel.
+ """
+ self.State = channel.stream_stream(
+ '/org.apache.beam.fn.v1.BeamFnState/State',
+ request_serializer=beam__fn__api__pb2.StateRequest.SerializeToString,
+ response_deserializer=beam__fn__api__pb2.StateResponse.FromString,
+ )
+
+
+class BeamFnStateServicer(object):
+
+ 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!')
+
+
+def add_BeamFnStateServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'State': grpc.stream_stream_rpc_method_handler(
+ servicer.State,
+ request_deserializer=beam__fn__api__pb2.StateRequest.FromString,
+ response_serializer=beam__fn__api__pb2.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,))
+
+
+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=beam__fn__api__pb2.LogEntry.List.SerializeToString,
+ response_deserializer=beam__fn__api__pb2.LogControl.FromString,
+ )
+
+
+class BeamFnLoggingServicer(object):
+ """Stable
+ """
+
+ 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!')
+
+
+def add_BeamFnLoggingServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'Logging': grpc.stream_stream_rpc_method_handler(
+ servicer.Logging,
+ request_deserializer=beam__fn__api__pb2.LogEntry.List.FromString,
+ response_serializer=beam__fn__api__pb2.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,))
http://git-wip-us.apache.org/repos/asf/beam/blob/2a59b057/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py b/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
index abba50d..3c612a9 100644
--- a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
+++ b/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
@@ -1,20 +1,3 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: beam_runner_api.proto
@@ -38,7 +21,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
name='beam_runner_api.proto',
package='org.apache.beam.runner_api.v1',
syntax='proto3',
- serialized_pb=_b('\n\x15\x62\x65\x61m_runner_api.proto\x12\x1dorg.apache.beam.runner_api.v1\x1a\x19google/protobuf/any.proto\"\x8d\x07\n\nComponents\x12M\n\ntransforms\x18\x01 \x03(\x0b\x32\x39.org.apache.beam.runner_api.v1.Components.TransformsEntry\x12Q\n\x0cpcollections\x18\x02 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.Components.PcollectionsEntry\x12`\n\x14windowing_strategies\x18\x03 \x03(\x0b\x32\x42.org.apache.beam.runner_api.v1.Components.WindowingStrategiesEntry\x12\x45\n\x06\x63oders\x18\x04 \x03(\x0b\x32\x35.org.apache.beam.runner_api.v1.Components.CodersEntry\x12Q\n\x0c\x65nvironments\x18\x05 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.Components.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\x1aS\n\x0b\x43odersEntry\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\"\xe2\x06\n\x15MessageWithComponents\x12=\n\ncomponents\x18\x01 \x01(\x0b\x32).org.apache.beam.runner_api.v1.Components\x12\x35\n\x05\x63oder\x18\x02 \x01(\x0b\x32$.org.apache.beam.runner_api.v1.CoderH\x00\x12H\n\x0f\x63ombine_payload\x18\x03 \x01(\x0b\x32-.org.apache.beam.runner_api.v1.CombinePayloadH\x00\x12K\n\x11sdk_function_spec\x18\x04 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpecH\x00\x12\x45\n\x0epar_do_payload\x18\x06 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.ParDoPayloadH\x00
\x12?\n\nptransform\x18\x07 \x01(\x0b\x32).org.apache.beam.runner_api.v1.PTransformH\x00\x12\x41\n\x0bpcollection\x18\x08 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.PCollectionH\x00\x12\x42\n\x0cread_payload\x18\t \x01(\x0b\x32*.org.apache.beam.runner_api.v1.ReadPayloadH\x00\x12>\n\nside_input\x18\x0b \x01(\x0b\x32(.org.apache.beam.runner_api.v1.SideInputH\x00\x12O\n\x13window_into_payload\x18\x0c \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.WindowIntoPayloadH\x00\x12N\n\x12windowing_strategy\x18\r \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.WindowingStrategyH\x00\x12\x44\n\rfunction_spec\x18\x0e \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpecH\x00\x42\x06\n\x04root\"\xa6\x01\n\x08Pipeline\x12=\n\ncomponents\x18\x01 \x01(\x0b\x32).org.apache.beam.runner_api.v1.Components\x12\x19\n\x11root_transform_id\x18\x02 \x01(\t\x12@\n\x0c\x64isplay_data\x18\x03 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\"\xa4\x03\n\nPTransform\x12\x13\n\x0bunique_name\x18\x05 \
x01(\t\x12\x39\n\x04spec\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12\x15\n\rsubtransforms\x18\x02 \x03(\t\x12\x45\n\x06inputs\x18\x03 \x03(\x0b\x32\x35.org.apache.beam.runner_api.v1.PTransform.InputsEntry\x12G\n\x07outputs\x18\x04 \x03(\x0b\x32\x36.org.apache.beam.runner_api.v1.PTransform.OutputsEntry\x12@\n\x0c\x64isplay_data\x18\x06 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\x1a-\n\x0bInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a.\n\x0cOutputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xd3\x01\n\x0bPCollection\x12\x13\n\x0bunique_name\x18\x01 \x01(\t\x12\x10\n\x08\x63oder_id\x18\x02 \x01(\t\x12<\n\nis_bounded\x18\x03 \x01(\x0e\x32(.org.apache.beam.runner_api.v1.IsBounded\x12\x1d\n\x15windowing_strategy_id\x18\x04 \x01(\t\x12@\n\x0c\x64isplay_data\x18\x05 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\"\xb8\x03\n\x0cParDoPayload\x12=\n\x05\x6
4o_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12<\n\nparameters\x18\x02 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.Parameter\x12P\n\x0bside_inputs\x18\x03 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.ParDoPayload.SideInputsEntry\x12=\n\x0bstate_specs\x18\x04 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.StateSpec\x12=\n\x0btimer_specs\x18\x05 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.TimerSpec\x1a[\n\x0fSideInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.runner_api.v1.SideInput:\x02\x38\x01\"\x8b\x01\n\tParameter\x12;\n\x04type\x18\x01 \x01(\x0e\x32-.org.apache.beam.runner_api.v1.Parameter.Type\"A\n\x04Type\x12\n\n\x06WINDOW\x10\x00\x12\x14\n\x10PIPELINE_OPTIONS\x10\x01\x12\x17\n\x13RESTRICTION_TRACKER\x10\x02\"\x0b\n\tStateSpec\"\x0b\n\tTimerSpec\"\x8b\x01\n\x0bReadPayload\x12>\n\x06source\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12<\n\nis_bounded\x18\x02 \x01(\x0e\
x32(.org.apache.beam.runner_api.v1.IsBounded\"V\n\x11WindowIntoPayload\x12\x41\n\twindow_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\"\xe1\x02\n\x0e\x43ombinePayload\x12\x42\n\ncombine_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12\x1c\n\x14\x61\x63\x63umulator_coder_id\x18\x02 \x01(\t\x12<\n\nparameters\x18\x03 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.Parameter\x12R\n\x0bside_inputs\x18\x04 \x03(\x0b\x32=.org.apache.beam.runner_api.v1.CombinePayload.SideInputsEntry\x1a[\n\x0fSideInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.runner_api.v1.SideInput:\x02\x38\x01\"b\n\x05\x43oder\x12<\n\x04spec\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12\x1b\n\x13\x63omponent_coder_ids\x18\x02 \x03(\t\"\xda\x03\n\x11WindowingStrategy\x12\x41\n\twindow_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12@\n\x0cmerge_status\x18\x02 \x01
(\x0e\x32*.org.apache.beam.runner_api.v1.MergeStatus\x12\x17\n\x0fwindow_coder_id\x18\x03 \x01(\t\x12\x37\n\x07trigger\x18\x04 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12J\n\x11\x61\x63\x63umulation_mode\x18\x05 \x01(\x0e\x32/.org.apache.beam.runner_api.v1.AccumulationMode\x12>\n\x0boutput_time\x18\x06 \x01(\x0e\x32).org.apache.beam.runner_api.v1.OutputTime\x12H\n\x10\x63losing_behavior\x18\x07 \x01(\x0e\x32..org.apache.beam.runner_api.v1.ClosingBehavior\x12\x18\n\x10\x61llowed_lateness\x18\x08 \x01(\x03\"\xad\r\n\x07Trigger\x12\x44\n\tafter_all\x18\x01 \x01(\x0b\x32/.org.apache.beam.runner_api.v1.Trigger.AfterAllH\x00\x12\x44\n\tafter_any\x18\x02 \x01(\x0b\x32/.org.apache.beam.runner_api.v1.Trigger.AfterAnyH\x00\x12\x46\n\nafter_each\x18\x03 \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.Trigger.AfterEachH\x00\x12V\n\x13\x61\x66ter_end_of_window\x18\x04 \x01(\x0b\x32\x37.org.apache.beam.runner_api.v1.Trigger.AfterEndOfWindowH\x00\x12[\n\x15\x61\x66ter_processing_time\
x18\x05 \x01(\x0b\x32:.org.apache.beam.runner_api.v1.Trigger.AfterProcessingTimeH\x00\x12t\n\"after_synchronized_processing_time\x18\x06 \x01(\x0b\x32\x46.org.apache.beam.runner_api.v1.Trigger.AfterSynchronizedProcessingTimeH\x00\x12?\n\x06\x61lways\x18\x0c \x01(\x0b\x32-.org.apache.beam.runner_api.v1.Trigger.AlwaysH\x00\x12\x41\n\x07\x64\x65\x66\x61ult\x18\x07 \x01(\x0b\x32..org.apache.beam.runner_api.v1.Trigger.DefaultH\x00\x12L\n\relement_count\x18\x08 \x01(\x0b\x32\x33.org.apache.beam.runner_api.v1.Trigger.ElementCountH\x00\x12=\n\x05never\x18\t \x01(\x0b\x32,.org.apache.beam.runner_api.v1.Trigger.NeverH\x00\x12\x46\n\nor_finally\x18\n \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.Trigger.OrFinallyH\x00\x12?\n\x06repeat\x18\x0b \x01(\x0b\x32-.org.apache.beam.runner_api.v1.Trigger.RepeatH\x00\x1aG\n\x08\x41\x66terAll\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1aG\n\x08\x41\x66terAny\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache
.beam.runner_api.v1.Trigger\x1aH\n\tAfterEach\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x8f\x01\n\x10\x41\x66terEndOfWindow\x12=\n\rearly_firings\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12<\n\x0clate_firings\x18\x02 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x66\n\x13\x41\x66terProcessingTime\x12O\n\x14timestamp_transforms\x18\x01 \x03(\x0b\x32\x31.org.apache.beam.runner_api.v1.TimestampTransform\x1a!\n\x1f\x41\x66terSynchronizedProcessingTime\x1a\t\n\x07\x44\x65\x66\x61ult\x1a%\n\x0c\x45lementCount\x12\x15\n\relement_count\x18\x01 \x01(\x05\x1a\x07\n\x05Never\x1a\x08\n\x06\x41lways\x1az\n\tOrFinally\x12\x34\n\x04main\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12\x37\n\x07\x66inally\x18\x02 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x44\n\x06Repeat\x12:\n\nsubtrigger\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.TriggerB\t\n\x07trigger\"\x8e\x02\n\x12TimestampTran
sform\x12H\n\x05\x64\x65lay\x18\x01 \x01(\x0b\x32\x37.org.apache.beam.runner_api.v1.TimestampTransform.DelayH\x00\x12M\n\x08\x61lign_to\x18\x02 \x01(\x0b\x32\x39.org.apache.beam.runner_api.v1.TimestampTransform.AlignToH\x00\x1a\x1d\n\x05\x44\x65lay\x12\x14\n\x0c\x64\x65lay_millis\x18\x01 \x01(\x03\x1a)\n\x07\x41lignTo\x12\x0e\n\x06period\x18\x03 \x01(\x03\x12\x0e\n\x06offset\x18\x04 \x01(\x03\x42\x15\n\x13timestamp_transform\"\xdc\x01\n\tSideInput\x12\x43\n\x0e\x61\x63\x63\x65ss_pattern\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12?\n\x07view_fn\x18\x02 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12I\n\x11window_mapping_fn\x18\x03 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\"\x1a\n\x0b\x45nvironment\x12\x0b\n\x03url\x18\x01 \x01(\t\"d\n\x0fSdkFunctionSpec\x12\x39\n\x04spec\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12\x16\n\x0e\x65nvironment_id\x18\x02 \x01(\t\"D\n\x0c\x46unctionSpec\x12\x0b\n\x03urn\
x18\x01 \x01(\t\x12\'\n\tparameter\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\"\xf7\x03\n\x0b\x44isplayData\x12>\n\x05items\x18\x01 \x03(\x0b\x32/.org.apache.beam.runner_api.v1.DisplayData.Item\x1a\x46\n\nIdentifier\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x15\n\rtransform_urn\x18\x02 \x01(\t\x12\x0b\n\x03key\x18\x03 \x01(\t\x1a\xf9\x01\n\x04Item\x12\x41\n\x02id\x18\x01 \x01(\x0b\x32\x35.org.apache.beam.runner_api.v1.DisplayData.Identifier\x12=\n\x04type\x18\x02 \x01(\x0e\x32/.org.apache.beam.runner_api.v1.DisplayData.Type\x12#\n\x05value\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any\x12)\n\x0bshort_value\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\x12\r\n\x05label\x18\x05 \x01(\t\x12\x10\n\x08link_url\x18\x06 \x01(\t\"d\n\x04Type\x12\n\n\x06STRING\x10\x00\x12\x0b\n\x07INTEGER\x10\x01\x12\t\n\x05\x46LOAT\x10\x02\x12\x0b\n\x07\x42OOLEAN\x10\x03\x12\r\n\tTIMESTAMP\x10\x04\x12\x0c\n\x08\x44URATION\x10\x05\x12\x0e\n\nJAVA_CLASS\x10\x06*\'\n\tIsBounded\x12\x0b\n\x07\x42OUNDED\x
10\x00\x12\r\n\tUNBOUNDED\x10\x01*C\n\x0bMergeStatus\x12\x0f\n\x0bNON_MERGING\x10\x00\x12\x0f\n\x0bNEEDS_MERGE\x10\x01\x12\x12\n\x0e\x41LREADY_MERGED\x10\x02*4\n\x10\x41\x63\x63umulationMode\x12\x0e\n\nDISCARDING\x10\x00\x12\x10\n\x0c\x41\x43\x43UMULATING\x10\x01*8\n\x0f\x43losingBehavior\x12\x0f\n\x0b\x45MIT_ALWAYS\x10\x00\x12\x14\n\x10\x45MIT_IF_NONEMPTY\x10\x01*I\n\nOutputTime\x12\x11\n\rEND_OF_WINDOW\x10\x00\x12\x12\n\x0eLATEST_IN_PANE\x10\x01\x12\x14\n\x10\x45\x41RLIEST_IN_PANE\x10\x02*S\n\nTimeDomain\x12\x0e\n\nEVENT_TIME\x10\x00\x12\x13\n\x0fPROCESSING_TIME\x10\x01\x12 \n\x1cSYNCHRONIZED_PROCESSING_TIME\x10\x02\x42\x31\n$org.apache.beam.sdk.common.runner.v1B\tRunnerApib\x06proto3')
+ serialized_pb=_b('\n\x15\x62\x65\x61m_runner_api.proto\x12\x1dorg.apache.beam.runner_api.v1\x1a\x19google/protobuf/any.proto\"\x8d\x07\n\nComponents\x12M\n\ntransforms\x18\x01 \x03(\x0b\x32\x39.org.apache.beam.runner_api.v1.Components.TransformsEntry\x12Q\n\x0cpcollections\x18\x02 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.Components.PcollectionsEntry\x12`\n\x14windowing_strategies\x18\x03 \x03(\x0b\x32\x42.org.apache.beam.runner_api.v1.Components.WindowingStrategiesEntry\x12\x45\n\x06\x63oders\x18\x04 \x03(\x0b\x32\x35.org.apache.beam.runner_api.v1.Components.CodersEntry\x12Q\n\x0c\x65nvironments\x18\x05 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.Components.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\x1aS\n\x0b\x43odersEntry\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\"\xe2\x06\n\x15MessageWithComponents\x12=\n\ncomponents\x18\x01 \x01(\x0b\x32).org.apache.beam.runner_api.v1.Components\x12\x35\n\x05\x63oder\x18\x02 \x01(\x0b\x32$.org.apache.beam.runner_api.v1.CoderH\x00\x12H\n\x0f\x63ombine_payload\x18\x03 \x01(\x0b\x32-.org.apache.beam.runner_api.v1.CombinePayloadH\x00\x12K\n\x11sdk_function_spec\x18\x04 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpecH\x00\x12\x45\n\x0epar_do_payload\x18\x06 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.ParDoPayloadH\x00
\x12?\n\nptransform\x18\x07 \x01(\x0b\x32).org.apache.beam.runner_api.v1.PTransformH\x00\x12\x41\n\x0bpcollection\x18\x08 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.PCollectionH\x00\x12\x42\n\x0cread_payload\x18\t \x01(\x0b\x32*.org.apache.beam.runner_api.v1.ReadPayloadH\x00\x12>\n\nside_input\x18\x0b \x01(\x0b\x32(.org.apache.beam.runner_api.v1.SideInputH\x00\x12O\n\x13window_into_payload\x18\x0c \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.WindowIntoPayloadH\x00\x12N\n\x12windowing_strategy\x18\r \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.WindowingStrategyH\x00\x12\x44\n\rfunction_spec\x18\x0e \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpecH\x00\x42\x06\n\x04root\"\xa7\x01\n\x08Pipeline\x12=\n\ncomponents\x18\x01 \x01(\x0b\x32).org.apache.beam.runner_api.v1.Components\x12\x1a\n\x12root_transform_ids\x18\x02 \x03(\t\x12@\n\x0c\x64isplay_data\x18\x03 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\"\xa4\x03\n\nPTransform\x12\x13\n\x0bunique_name\x18\x05
\x01(\t\x12\x39\n\x04spec\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12\x15\n\rsubtransforms\x18\x02 \x03(\t\x12\x45\n\x06inputs\x18\x03 \x03(\x0b\x32\x35.org.apache.beam.runner_api.v1.PTransform.InputsEntry\x12G\n\x07outputs\x18\x04 \x03(\x0b\x32\x36.org.apache.beam.runner_api.v1.PTransform.OutputsEntry\x12@\n\x0c\x64isplay_data\x18\x06 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\x1a-\n\x0bInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a.\n\x0cOutputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xd3\x01\n\x0bPCollection\x12\x13\n\x0bunique_name\x18\x01 \x01(\t\x12\x10\n\x08\x63oder_id\x18\x02 \x01(\t\x12<\n\nis_bounded\x18\x03 \x01(\x0e\x32(.org.apache.beam.runner_api.v1.IsBounded\x12\x1d\n\x15windowing_strategy_id\x18\x04 \x01(\t\x12@\n\x0c\x64isplay_data\x18\x05 \x01(\x0b\x32*.org.apache.beam.runner_api.v1.DisplayData\"\x98\x05\n\x0cParDoPayload\x12=\n\x05\x
64o_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12<\n\nparameters\x18\x02 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.Parameter\x12P\n\x0bside_inputs\x18\x03 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.ParDoPayload.SideInputsEntry\x12P\n\x0bstate_specs\x18\x04 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.ParDoPayload.StateSpecsEntry\x12P\n\x0btimer_specs\x18\x05 \x03(\x0b\x32;.org.apache.beam.runner_api.v1.ParDoPayload.TimerSpecsEntry\x1a[\n\x0fSideInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.runner_api.v1.SideInput:\x02\x38\x01\x1a[\n\x0fStateSpecsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.runner_api.v1.StateSpec:\x02\x38\x01\x1a[\n\x0fTimerSpecsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.runner_api.v1.TimerSpec:\x02\x38\x01\"\x8b\x01\n\tParameter\x12;\n\x04type\x18\x01 \x01(\x0e\x32-.org.
apache.beam.runner_api.v1.Parameter.Type\"A\n\x04Type\x12\n\n\x06WINDOW\x10\x00\x12\x14\n\x10PIPELINE_OPTIONS\x10\x01\x12\x17\n\x13RESTRICTION_TRACKER\x10\x02\"\x0b\n\tStateSpec\"\x0b\n\tTimerSpec\"\x8b\x01\n\x0bReadPayload\x12>\n\x06source\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12<\n\nis_bounded\x18\x02 \x01(\x0e\x32(.org.apache.beam.runner_api.v1.IsBounded\"V\n\x11WindowIntoPayload\x12\x41\n\twindow_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\"\xe1\x02\n\x0e\x43ombinePayload\x12\x42\n\ncombine_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12\x1c\n\x14\x61\x63\x63umulator_coder_id\x18\x02 \x01(\t\x12<\n\nparameters\x18\x03 \x03(\x0b\x32(.org.apache.beam.runner_api.v1.Parameter\x12R\n\x0bside_inputs\x18\x04 \x03(\x0b\x32=.org.apache.beam.runner_api.v1.CombinePayload.SideInputsEntry\x1a[\n\x0fSideInputsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.r
unner_api.v1.SideInput:\x02\x38\x01\"b\n\x05\x43oder\x12<\n\x04spec\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12\x1b\n\x13\x63omponent_coder_ids\x18\x02 \x03(\t\"\xda\x03\n\x11WindowingStrategy\x12\x41\n\twindow_fn\x18\x01 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12@\n\x0cmerge_status\x18\x02 \x01(\x0e\x32*.org.apache.beam.runner_api.v1.MergeStatus\x12\x17\n\x0fwindow_coder_id\x18\x03 \x01(\t\x12\x37\n\x07trigger\x18\x04 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12J\n\x11\x61\x63\x63umulation_mode\x18\x05 \x01(\x0e\x32/.org.apache.beam.runner_api.v1.AccumulationMode\x12>\n\x0boutput_time\x18\x06 \x01(\x0e\x32).org.apache.beam.runner_api.v1.OutputTime\x12H\n\x10\x63losing_behavior\x18\x07 \x01(\x0e\x32..org.apache.beam.runner_api.v1.ClosingBehavior\x12\x18\n\x10\x61llowed_lateness\x18\x08 \x01(\x03\"\xad\r\n\x07Trigger\x12\x44\n\tafter_all\x18\x01 \x01(\x0b\x32/.org.apache.beam.runner_api.v1.Trigger.AfterAllH\x00\x12\x44\n\
tafter_any\x18\x02 \x01(\x0b\x32/.org.apache.beam.runner_api.v1.Trigger.AfterAnyH\x00\x12\x46\n\nafter_each\x18\x03 \x01(\x0b\x32\x30.org.apache.beam.runner_api.v1.Trigger.AfterEachH\x00\x12V\n\x13\x61\x66ter_end_of_window\x18\x04 \x01(\x0b\x32\x37.org.apache.beam.runner_api.v1.Trigger.AfterEndOfWindowH\x00\x12[\n\x15\x61\x66ter_processing_time\x18\x05 \x01(\x0b\x32:.org.apache.beam.runner_api.v1.Trigger.AfterProcessingTimeH\x00\x12t\n\"after_synchronized_processing_time\x18\x06 \x01(\x0b\x32\x46.org.apache.beam.runner_api.v1.Trigger.AfterSynchronizedProcessingTimeH\x00\x12?\n\x06\x61lways\x18\x0c \x01(\x0b\x32-.org.apache.beam.runner_api.v1.Trigger.AlwaysH\x00\x12\x41\n\x07\x64\x65\x66\x61ult\x18\x07 \x01(\x0b\x32..org.apache.beam.runner_api.v1.Trigger.DefaultH\x00\x12L\n\relement_count\x18\x08 \x01(\x0b\x32\x33.org.apache.beam.runner_api.v1.Trigger.ElementCountH\x00\x12=\n\x05never\x18\t \x01(\x0b\x32,.org.apache.beam.runner_api.v1.Trigger.NeverH\x00\x12\x46\n\nor_finally\x18\n \x
01(\x0b\x32\x30.org.apache.beam.runner_api.v1.Trigger.OrFinallyH\x00\x12?\n\x06repeat\x18\x0b \x01(\x0b\x32-.org.apache.beam.runner_api.v1.Trigger.RepeatH\x00\x1aG\n\x08\x41\x66terAll\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1aG\n\x08\x41\x66terAny\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1aH\n\tAfterEach\x12;\n\x0bsubtriggers\x18\x01 \x03(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x8f\x01\n\x10\x41\x66terEndOfWindow\x12=\n\rearly_firings\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12<\n\x0clate_firings\x18\x02 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x66\n\x13\x41\x66terProcessingTime\x12O\n\x14timestamp_transforms\x18\x01 \x03(\x0b\x32\x31.org.apache.beam.runner_api.v1.TimestampTransform\x1a!\n\x1f\x41\x66terSynchronizedProcessingTime\x1a\t\n\x07\x44\x65\x66\x61ult\x1a%\n\x0c\x45lementCount\x12\x15\n\relement_count\x18\x01 \x01(\x05\x1a\x07\n\x05Never\x1
a\x08\n\x06\x41lways\x1az\n\tOrFinally\x12\x34\n\x04main\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x12\x37\n\x07\x66inally\x18\x02 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.Trigger\x1a\x44\n\x06Repeat\x12:\n\nsubtrigger\x18\x01 \x01(\x0b\x32&.org.apache.beam.runner_api.v1.TriggerB\t\n\x07trigger\"\x8e\x02\n\x12TimestampTransform\x12H\n\x05\x64\x65lay\x18\x01 \x01(\x0b\x32\x37.org.apache.beam.runner_api.v1.TimestampTransform.DelayH\x00\x12M\n\x08\x61lign_to\x18\x02 \x01(\x0b\x32\x39.org.apache.beam.runner_api.v1.TimestampTransform.AlignToH\x00\x1a\x1d\n\x05\x44\x65lay\x12\x14\n\x0c\x64\x65lay_millis\x18\x01 \x01(\x03\x1a)\n\x07\x41lignTo\x12\x0e\n\x06period\x18\x03 \x01(\x03\x12\x0e\n\x06offset\x18\x04 \x01(\x03\x42\x15\n\x13timestamp_transform\"\xdc\x01\n\tSideInput\x12\x43\n\x0e\x61\x63\x63\x65ss_pattern\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12?\n\x07view_fn\x18\x02 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\x12I\
n\x11window_mapping_fn\x18\x03 \x01(\x0b\x32..org.apache.beam.runner_api.v1.SdkFunctionSpec\"\x1a\n\x0b\x45nvironment\x12\x0b\n\x03url\x18\x01 \x01(\t\"d\n\x0fSdkFunctionSpec\x12\x39\n\x04spec\x18\x01 \x01(\x0b\x32+.org.apache.beam.runner_api.v1.FunctionSpec\x12\x16\n\x0e\x65nvironment_id\x18\x02 \x01(\t\"D\n\x0c\x46unctionSpec\x12\x0b\n\x03urn\x18\x01 \x01(\t\x12\'\n\tparameter\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\"\xf7\x03\n\x0b\x44isplayData\x12>\n\x05items\x18\x01 \x03(\x0b\x32/.org.apache.beam.runner_api.v1.DisplayData.Item\x1a\x46\n\nIdentifier\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x15\n\rtransform_urn\x18\x02 \x01(\t\x12\x0b\n\x03key\x18\x03 \x01(\t\x1a\xf9\x01\n\x04Item\x12\x41\n\x02id\x18\x01 \x01(\x0b\x32\x35.org.apache.beam.runner_api.v1.DisplayData.Identifier\x12=\n\x04type\x18\x02 \x01(\x0e\x32/.org.apache.beam.runner_api.v1.DisplayData.Type\x12#\n\x05value\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any\x12)\n\x0bshort_value\x18\x04 \x01(\x0b\x32\x14.goo
gle.protobuf.Any\x12\r\n\x05label\x18\x05 \x01(\t\x12\x10\n\x08link_url\x18\x06 \x01(\t\"d\n\x04Type\x12\n\n\x06STRING\x10\x00\x12\x0b\n\x07INTEGER\x10\x01\x12\t\n\x05\x46LOAT\x10\x02\x12\x0b\n\x07\x42OOLEAN\x10\x03\x12\r\n\tTIMESTAMP\x10\x04\x12\x0c\n\x08\x44URATION\x10\x05\x12\x0e\n\nJAVA_CLASS\x10\x06*\'\n\tIsBounded\x12\x0b\n\x07\x42OUNDED\x10\x00\x12\r\n\tUNBOUNDED\x10\x01*C\n\x0bMergeStatus\x12\x0f\n\x0bNON_MERGING\x10\x00\x12\x0f\n\x0bNEEDS_MERGE\x10\x01\x12\x12\n\x0e\x41LREADY_MERGED\x10\x02*4\n\x10\x41\x63\x63umulationMode\x12\x0e\n\nDISCARDING\x10\x00\x12\x10\n\x0c\x41\x43\x43UMULATING\x10\x01*8\n\x0f\x43losingBehavior\x12\x0f\n\x0b\x45MIT_ALWAYS\x10\x00\x12\x14\n\x10\x45MIT_IF_NONEMPTY\x10\x01*I\n\nOutputTime\x12\x11\n\rEND_OF_WINDOW\x10\x00\x12\x12\n\x0eLATEST_IN_PANE\x10\x01\x12\x14\n\x10\x45\x41RLIEST_IN_PANE\x10\x02*S\n\nTimeDomain\x12\x0e\n\nEVENT_TIME\x10\x00\x12\x13\n\x0fPROCESSING_TIME\x10\x01\x12 \n\x1cSYNCHRONIZED_PROCESSING_TIME\x10\x02\x42\x31\n$org.apache.bea
m.sdk.common.runner.v1B\tRunnerApib\x06proto3')
,
dependencies=[google_dot_protobuf_dot_any__pb2.DESCRIPTOR,])
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
@@ -60,8 +43,8 @@ _ISBOUNDED = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7358,
- serialized_end=7397,
+ serialized_start=7583,
+ serialized_end=7622,
)
_sym_db.RegisterEnumDescriptor(_ISBOUNDED)
@@ -87,8 +70,8 @@ _MERGESTATUS = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7399,
- serialized_end=7466,
+ serialized_start=7624,
+ serialized_end=7691,
)
_sym_db.RegisterEnumDescriptor(_MERGESTATUS)
@@ -110,8 +93,8 @@ _ACCUMULATIONMODE = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7468,
- serialized_end=7520,
+ serialized_start=7693,
+ serialized_end=7745,
)
_sym_db.RegisterEnumDescriptor(_ACCUMULATIONMODE)
@@ -133,8 +116,8 @@ _CLOSINGBEHAVIOR = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7522,
- serialized_end=7578,
+ serialized_start=7747,
+ serialized_end=7803,
)
_sym_db.RegisterEnumDescriptor(_CLOSINGBEHAVIOR)
@@ -160,8 +143,8 @@ _OUTPUTTIME = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7580,
- serialized_end=7653,
+ serialized_start=7805,
+ serialized_end=7878,
)
_sym_db.RegisterEnumDescriptor(_OUTPUTTIME)
@@ -187,8 +170,8 @@ _TIMEDOMAIN = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7655,
- serialized_end=7738,
+ serialized_start=7880,
+ serialized_end=7963,
)
_sym_db.RegisterEnumDescriptor(_TIMEDOMAIN)
@@ -231,8 +214,8 @@ _PARAMETER_TYPE = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=3188,
- serialized_end=3253,
+ serialized_start=3413,
+ serialized_end=3478,
)
_sym_db.RegisterEnumDescriptor(_PARAMETER_TYPE)
@@ -273,8 +256,8 @@ _DISPLAYDATA_TYPE = _descriptor.EnumDescriptor(
],
containing_type=None,
options=None,
- serialized_start=7256,
- serialized_end=7356,
+ serialized_start=7481,
+ serialized_end=7581,
)
_sym_db.RegisterEnumDescriptor(_DISPLAYDATA_TYPE)
@@ -649,9 +632,9 @@ _PIPELINE = _descriptor.Descriptor(
is_extension=False, extension_scope=None,
options=None),
_descriptor.FieldDescriptor(
- name='root_transform_id', full_name='org.apache.beam.runner_api.v1.Pipeline.root_transform_id', index=1,
- number=2, type=9, cpp_type=9, label=1,
- has_default_value=False, default_value=_b("").decode('utf-8'),
+ name='root_transform_ids', full_name='org.apache.beam.runner_api.v1.Pipeline.root_transform_ids', 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=None),
@@ -675,7 +658,7 @@ _PIPELINE = _descriptor.Descriptor(
oneofs=[
],
serialized_start=1865,
- serialized_end=2031,
+ serialized_end=2032,
)
@@ -712,8 +695,8 @@ _PTRANSFORM_INPUTSENTRY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=2361,
- serialized_end=2406,
+ serialized_start=2362,
+ serialized_end=2407,
)
_PTRANSFORM_OUTPUTSENTRY = _descriptor.Descriptor(
@@ -749,8 +732,8 @@ _PTRANSFORM_OUTPUTSENTRY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=2408,
- serialized_end=2454,
+ serialized_start=2409,
+ serialized_end=2455,
)
_PTRANSFORM = _descriptor.Descriptor(
@@ -814,8 +797,8 @@ _PTRANSFORM = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=2034,
- serialized_end=2454,
+ serialized_start=2035,
+ serialized_end=2455,
)
@@ -873,8 +856,8 @@ _PCOLLECTION = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=2457,
- serialized_end=2668,
+ serialized_start=2458,
+ serialized_end=2669,
)
@@ -911,8 +894,82 @@ _PARDOPAYLOAD_SIDEINPUTSENTRY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3020,
- serialized_end=3111,
+ serialized_start=3059,
+ serialized_end=3150,
+)
+
+_PARDOPAYLOAD_STATESPECSENTRY = _descriptor.Descriptor(
+ name='StateSpecsEntry',
+ full_name='org.apache.beam.runner_api.v1.ParDoPayload.StateSpecsEntry',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='key', full_name='org.apache.beam.runner_api.v1.ParDoPayload.StateSpecsEntry.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.runner_api.v1.ParDoPayload.StateSpecsEntry.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=3152,
+ serialized_end=3243,
+)
+
+_PARDOPAYLOAD_TIMERSPECSENTRY = _descriptor.Descriptor(
+ name='TimerSpecsEntry',
+ full_name='org.apache.beam.runner_api.v1.ParDoPayload.TimerSpecsEntry',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='key', full_name='org.apache.beam.runner_api.v1.ParDoPayload.TimerSpecsEntry.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.runner_api.v1.ParDoPayload.TimerSpecsEntry.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=3245,
+ serialized_end=3336,
)
_PARDOPAYLOAD = _descriptor.Descriptor(
@@ -960,7 +1017,7 @@ _PARDOPAYLOAD = _descriptor.Descriptor(
],
extensions=[
],
- nested_types=[_PARDOPAYLOAD_SIDEINPUTSENTRY, ],
+ nested_types=[_PARDOPAYLOAD_SIDEINPUTSENTRY, _PARDOPAYLOAD_STATESPECSENTRY, _PARDOPAYLOAD_TIMERSPECSENTRY, ],
enum_types=[
],
options=None,
@@ -969,8 +1026,8 @@ _PARDOPAYLOAD = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=2671,
- serialized_end=3111,
+ serialized_start=2672,
+ serialized_end=3336,
)
@@ -1001,8 +1058,8 @@ _PARAMETER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3114,
- serialized_end=3253,
+ serialized_start=3339,
+ serialized_end=3478,
)
@@ -1025,8 +1082,8 @@ _STATESPEC = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3255,
- serialized_end=3266,
+ serialized_start=3480,
+ serialized_end=3491,
)
@@ -1049,8 +1106,8 @@ _TIMERSPEC = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3268,
- serialized_end=3279,
+ serialized_start=3493,
+ serialized_end=3504,
)
@@ -1087,8 +1144,8 @@ _READPAYLOAD = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3282,
- serialized_end=3421,
+ serialized_start=3507,
+ serialized_end=3646,
)
@@ -1118,8 +1175,8 @@ _WINDOWINTOPAYLOAD = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3423,
- serialized_end=3509,
+ serialized_start=3648,
+ serialized_end=3734,
)
@@ -1156,8 +1213,8 @@ _COMBINEPAYLOAD_SIDEINPUTSENTRY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3020,
- serialized_end=3111,
+ serialized_start=3059,
+ serialized_end=3150,
)
_COMBINEPAYLOAD = _descriptor.Descriptor(
@@ -1207,8 +1264,8 @@ _COMBINEPAYLOAD = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3512,
- serialized_end=3865,
+ serialized_start=3737,
+ serialized_end=4090,
)
@@ -1245,8 +1302,8 @@ _CODER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3867,
- serialized_end=3965,
+ serialized_start=4092,
+ serialized_end=4190,
)
@@ -1325,8 +1382,8 @@ _WINDOWINGSTRATEGY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=3968,
- serialized_end=4442,
+ serialized_start=4193,
+ serialized_end=4667,
)
@@ -1356,8 +1413,8 @@ _TRIGGER_AFTERALL = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5377,
- serialized_end=5448,
+ serialized_start=5602,
+ serialized_end=5673,
)
_TRIGGER_AFTERANY = _descriptor.Descriptor(
@@ -1386,8 +1443,8 @@ _TRIGGER_AFTERANY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5450,
- serialized_end=5521,
+ serialized_start=5675,
+ serialized_end=5746,
)
_TRIGGER_AFTEREACH = _descriptor.Descriptor(
@@ -1416,8 +1473,8 @@ _TRIGGER_AFTEREACH = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5523,
- serialized_end=5595,
+ serialized_start=5748,
+ serialized_end=5820,
)
_TRIGGER_AFTERENDOFWINDOW = _descriptor.Descriptor(
@@ -1453,8 +1510,8 @@ _TRIGGER_AFTERENDOFWINDOW = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5598,
- serialized_end=5741,
+ serialized_start=5823,
+ serialized_end=5966,
)
_TRIGGER_AFTERPROCESSINGTIME = _descriptor.Descriptor(
@@ -1483,8 +1540,8 @@ _TRIGGER_AFTERPROCESSINGTIME = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5743,
- serialized_end=5845,
+ serialized_start=5968,
+ serialized_end=6070,
)
_TRIGGER_AFTERSYNCHRONIZEDPROCESSINGTIME = _descriptor.Descriptor(
@@ -1506,8 +1563,8 @@ _TRIGGER_AFTERSYNCHRONIZEDPROCESSINGTIME = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5847,
- serialized_end=5880,
+ serialized_start=6072,
+ serialized_end=6105,
)
_TRIGGER_DEFAULT = _descriptor.Descriptor(
@@ -1529,8 +1586,8 @@ _TRIGGER_DEFAULT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5882,
- serialized_end=5891,
+ serialized_start=6107,
+ serialized_end=6116,
)
_TRIGGER_ELEMENTCOUNT = _descriptor.Descriptor(
@@ -1559,8 +1616,8 @@ _TRIGGER_ELEMENTCOUNT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5893,
- serialized_end=5930,
+ serialized_start=6118,
+ serialized_end=6155,
)
_TRIGGER_NEVER = _descriptor.Descriptor(
@@ -1582,8 +1639,8 @@ _TRIGGER_NEVER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5932,
- serialized_end=5939,
+ serialized_start=6157,
+ serialized_end=6164,
)
_TRIGGER_ALWAYS = _descriptor.Descriptor(
@@ -1605,8 +1662,8 @@ _TRIGGER_ALWAYS = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5941,
- serialized_end=5949,
+ serialized_start=6166,
+ serialized_end=6174,
)
_TRIGGER_ORFINALLY = _descriptor.Descriptor(
@@ -1642,8 +1699,8 @@ _TRIGGER_ORFINALLY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=5951,
- serialized_end=6073,
+ serialized_start=6176,
+ serialized_end=6298,
)
_TRIGGER_REPEAT = _descriptor.Descriptor(
@@ -1672,8 +1729,8 @@ _TRIGGER_REPEAT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6075,
- serialized_end=6143,
+ serialized_start=6300,
+ serialized_end=6368,
)
_TRIGGER = _descriptor.Descriptor(
@@ -1782,8 +1839,8 @@ _TRIGGER = _descriptor.Descriptor(
name='trigger', full_name='org.apache.beam.runner_api.v1.Trigger.trigger',
index=0, containing_type=None, fields=[]),
],
- serialized_start=4445,
- serialized_end=6154,
+ serialized_start=4670,
+ serialized_end=6379,
)
@@ -1813,8 +1870,8 @@ _TIMESTAMPTRANSFORM_DELAY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6332,
- serialized_end=6361,
+ serialized_start=6557,
+ serialized_end=6586,
)
_TIMESTAMPTRANSFORM_ALIGNTO = _descriptor.Descriptor(
@@ -1850,8 +1907,8 @@ _TIMESTAMPTRANSFORM_ALIGNTO = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6363,
- serialized_end=6404,
+ serialized_start=6588,
+ serialized_end=6629,
)
_TIMESTAMPTRANSFORM = _descriptor.Descriptor(
@@ -1890,8 +1947,8 @@ _TIMESTAMPTRANSFORM = _descriptor.Descriptor(
name='timestamp_transform', full_name='org.apache.beam.runner_api.v1.TimestampTransform.timestamp_transform',
index=0, containing_type=None, fields=[]),
],
- serialized_start=6157,
- serialized_end=6427,
+ serialized_start=6382,
+ serialized_end=6652,
)
@@ -1935,8 +1992,8 @@ _SIDEINPUT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6430,
- serialized_end=6650,
+ serialized_start=6655,
+ serialized_end=6875,
)
@@ -1966,8 +2023,8 @@ _ENVIRONMENT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6652,
- serialized_end=6678,
+ serialized_start=6877,
+ serialized_end=6903,
)
@@ -2004,8 +2061,8 @@ _SDKFUNCTIONSPEC = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6680,
- serialized_end=6780,
+ serialized_start=6905,
+ serialized_end=7005,
)
@@ -2042,8 +2099,8 @@ _FUNCTIONSPEC = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6782,
- serialized_end=6850,
+ serialized_start=7007,
+ serialized_end=7075,
)
@@ -2087,8 +2144,8 @@ _DISPLAYDATA_IDENTIFIER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6932,
- serialized_end=7002,
+ serialized_start=7157,
+ serialized_end=7227,
)
_DISPLAYDATA_ITEM = _descriptor.Descriptor(
@@ -2152,8 +2209,8 @@ _DISPLAYDATA_ITEM = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=7005,
- serialized_end=7254,
+ serialized_start=7230,
+ serialized_end=7479,
)
_DISPLAYDATA = _descriptor.Descriptor(
@@ -2183,8 +2240,8 @@ _DISPLAYDATA = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
- serialized_start=6853,
- serialized_end=7356,
+ serialized_start=7078,
+ serialized_end=7581,
)
_COMPONENTS_TRANSFORMSENTRY.fields_by_name['value'].message_type = _PTRANSFORM
@@ -2259,11 +2316,15 @@ _PCOLLECTION.fields_by_name['is_bounded'].enum_type = _ISBOUNDED
_PCOLLECTION.fields_by_name['display_data'].message_type = _DISPLAYDATA
_PARDOPAYLOAD_SIDEINPUTSENTRY.fields_by_name['value'].message_type = _SIDEINPUT
_PARDOPAYLOAD_SIDEINPUTSENTRY.containing_type = _PARDOPAYLOAD
+_PARDOPAYLOAD_STATESPECSENTRY.fields_by_name['value'].message_type = _STATESPEC
+_PARDOPAYLOAD_STATESPECSENTRY.containing_type = _PARDOPAYLOAD
+_PARDOPAYLOAD_TIMERSPECSENTRY.fields_by_name['value'].message_type = _TIMERSPEC
+_PARDOPAYLOAD_TIMERSPECSENTRY.containing_type = _PARDOPAYLOAD
_PARDOPAYLOAD.fields_by_name['do_fn'].message_type = _SDKFUNCTIONSPEC
_PARDOPAYLOAD.fields_by_name['parameters'].message_type = _PARAMETER
_PARDOPAYLOAD.fields_by_name['side_inputs'].message_type = _PARDOPAYLOAD_SIDEINPUTSENTRY
-_PARDOPAYLOAD.fields_by_name['state_specs'].message_type = _STATESPEC
-_PARDOPAYLOAD.fields_by_name['timer_specs'].message_type = _TIMERSPEC
+_PARDOPAYLOAD.fields_by_name['state_specs'].message_type = _PARDOPAYLOAD_STATESPECSENTRY
+_PARDOPAYLOAD.fields_by_name['timer_specs'].message_type = _PARDOPAYLOAD_TIMERSPECSENTRY
_PARAMETER.fields_by_name['type'].enum_type = _PARAMETER_TYPE
_PARAMETER_TYPE.containing_type = _PARAMETER
_READPAYLOAD.fields_by_name['source'].message_type = _SDKFUNCTIONSPEC
@@ -2500,12 +2561,28 @@ ParDoPayload = _reflection.GeneratedProtocolMessageType('ParDoPayload', (_messag
# @@protoc_insertion_point(class_scope:org.apache.beam.runner_api.v1.ParDoPayload.SideInputsEntry)
))
,
+
+ StateSpecsEntry = _reflection.GeneratedProtocolMessageType('StateSpecsEntry', (_message.Message,), dict(
+ DESCRIPTOR = _PARDOPAYLOAD_STATESPECSENTRY,
+ __module__ = 'beam_runner_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.runner_api.v1.ParDoPayload.StateSpecsEntry)
+ ))
+ ,
+
+ TimerSpecsEntry = _reflection.GeneratedProtocolMessageType('TimerSpecsEntry', (_message.Message,), dict(
+ DESCRIPTOR = _PARDOPAYLOAD_TIMERSPECSENTRY,
+ __module__ = 'beam_runner_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.runner_api.v1.ParDoPayload.TimerSpecsEntry)
+ ))
+ ,
DESCRIPTOR = _PARDOPAYLOAD,
__module__ = 'beam_runner_api_pb2'
# @@protoc_insertion_point(class_scope:org.apache.beam.runner_api.v1.ParDoPayload)
))
_sym_db.RegisterMessage(ParDoPayload)
_sym_db.RegisterMessage(ParDoPayload.SideInputsEntry)
+_sym_db.RegisterMessage(ParDoPayload.StateSpecsEntry)
+_sym_db.RegisterMessage(ParDoPayload.TimerSpecsEntry)
Parameter = _reflection.GeneratedProtocolMessageType('Parameter', (_message.Message,), dict(
DESCRIPTOR = _PARAMETER,
@@ -2767,6 +2844,10 @@ _PTRANSFORM_OUTPUTSENTRY.has_options = True
_PTRANSFORM_OUTPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PARDOPAYLOAD_SIDEINPUTSENTRY.has_options = True
_PARDOPAYLOAD_SIDEINPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
+_PARDOPAYLOAD_STATESPECSENTRY.has_options = True
+_PARDOPAYLOAD_STATESPECSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
+_PARDOPAYLOAD_TIMERSPECSENTRY.has_options = True
+_PARDOPAYLOAD_TIMERSPECSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_COMBINEPAYLOAD_SIDEINPUTSENTRY.has_options = True
_COMBINEPAYLOAD_SIDEINPUTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
# @@protoc_insertion_point(module_scope)
[5/7] beam git commit: Add apache licence to generated files.
Posted by ro...@apache.org.
Add apache licence to generated files.
Also add needed dependency (for docs) and fix lint.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fbeb7e13
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fbeb7e13
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fbeb7e13
Branch: refs/heads/master
Commit: fbeb7e13a2d678ddb2852c2e270eb972280a40f3
Parents: 2a59b05
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Apr 21 12:15:02 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Apr 24 14:52:28 2017 -0700
----------------------------------------------------------------------
pom.xml | 3 +++
.../apache_beam/runners/api/beam_fn_api_pb2.py | 17 +++++++++++++++++
.../runners/api/beam_fn_api_pb2_grpc.py | 17 +++++++++++++++++
.../apache_beam/runners/api/beam_runner_api_pb2.py | 17 +++++++++++++++++
sdks/python/run_pylint.sh | 5 ++++-
sdks/python/setup.py | 1 +
6 files changed, 59 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 5764204..8723ed9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1193,6 +1193,9 @@
<exclude>**/.factorypath</exclude>
<exclude>**/.project</exclude>
<exclude>**/.settings/**/*</exclude>
+
+ <!-- Proto/grpc generated wrappers -->
+ <exclude>**/sdks/python/apache_beam/runners/api/*.py</exclude>
</excludes>
</configuration>
</plugin>
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
index dea47e3..769b13c 100644
--- a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
+++ b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
@@ -1,3 +1,20 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: beam_fn_api.proto
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
index f86861c..7fbe4c1 100644
--- a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
+++ b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2_grpc.py
@@ -1,3 +1,20 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from grpc.framework.common import cardinality
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py b/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
index 3c612a9..d2006d7 100644
--- a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
+++ b/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py
@@ -1,3 +1,20 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: beam_runner_api.proto
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/sdks/python/run_pylint.sh
----------------------------------------------------------------------
diff --git a/sdks/python/run_pylint.sh b/sdks/python/run_pylint.sh
index f733a79..11e0526 100755
--- a/sdks/python/run_pylint.sh
+++ b/sdks/python/run_pylint.sh
@@ -46,7 +46,10 @@ EXCLUDED_GENERATED_FILES=(
"apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py"
"apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py"
"apache_beam/coders/proto2_coder_test_messages_pb2.py"
-"apache_beam/runners/api/beam_runner_api_pb2.py")
+"apache_beam/runners/api/beam_fn_api_pb2.py"
+"apache_beam/runners/api/beam_fn_api_pb2_grpc.py"
+"apache_beam/runners/api/beam_runner_api_pb2.py"
+)
FILES_TO_IGNORE=""
for file in "${EXCLUDED_GENERATED_FILES[@]}"; do
http://git-wip-us.apache.org/repos/asf/beam/blob/fbeb7e13/sdks/python/setup.py
----------------------------------------------------------------------
diff --git a/sdks/python/setup.py b/sdks/python/setup.py
index 6c3f426..a6efe21 100644
--- a/sdks/python/setup.py
+++ b/sdks/python/setup.py
@@ -90,6 +90,7 @@ REQUIRED_PACKAGES = [
'avro>=1.8.1,<2.0.0',
'crcmod>=1.7,<2.0',
'dill==0.2.6',
+ 'grpcio>=1.0,<2.0',
'httplib2>=0.8,<0.10',
'mock>=1.0.1,<3.0.0',
'oauth2client>=2.0.1,<4.0.0',
[2/7] beam git commit: Generate python proto wrappers for runner and
fn API.
Posted by ro...@apache.org.
http://git-wip-us.apache.org/repos/asf/beam/blob/2a59b057/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
new file mode 100644
index 0000000..dea47e3
--- /dev/null
+++ b/sdks/python/apache_beam/runners/api/beam_fn_api_pb2.py
@@ -0,0 +1,2723 @@
+# 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()
+
+
+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\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\x17\n\x0f\x63oder_reference\x18\x01 \x01(\t\"\xcb\x04\n\x12PrimitiveTransform\x12\n\n\x02id\x18\x01 \x01(\t\x12:\n\rfunction_spec\x18\x02 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpec\x12\x45\n\x06inputs\x18\x03 \x03(\x0b\x32\x35.org.apache.beam.fn.v1.PrimitiveTransform.InputsEntry\x12G\n\x07outputs\x18\x04 \x03(\x0b\x32\x36.org.apache.beam.fn.v1.PrimitiveTransform.OutputsEntry\x12N\n\x0bside_inputs\x18\x05 \x03(\x0b\x32\x39.org.apache.beam.fn.v1.PrimitiveTransform.SideInputsEntry\x12\x11\n\tstep_name\x18\x06 \x01(\t\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\"j\n\x0c\x46unctionSpec\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0b\n\x03urn\x18\x02 \x01(\t\x12\x1d\n\x15\x65nvironment_reference\x18\x03 \x01(\t\x12\"\n\x04\x64\x61ta\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\"o\n\tSideInput\x12,\n\x05input\x18\x01 \x01(\x0b\x32\x1d.org.apache.beam.fn.v1.Target\x12\x34\n\x07view_fn\x18\x02 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpec\"f\n\x05\x43oder\x12:\n\rfunction_spec\x18\x01 \x01(\x0b\x32#.org.apache.beam.fn.v1.FunctionSpec\x12!\n\x19\x63omponent_coder_reference\x18\x02 \x03(\t\"]\n\x0eRemoteGrpcPort\x12K\n\x16\x61pi_service_descriptor\x18\x01 \x01(\x0b\x32+.org.apache.beam.fn.v1.ApiServiceDescriptor\"\xe8\x0
2\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\x
32\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\"\x9b\x01\n\x17ProcessBundleDescriptor\x12\n\n\x02id\x18\x01 \x01(\t\x12\x46\n\x13primitive_transform\x18\x02 \x03(\x0b\x32).org.apache.beam.fn.v1.PrimitiveTransform\x12,\n\x06\x63oders\x18\x04 \x03(\x0b\x32\x1c.org.apache.beam.fn.v1.Coder\"|\n\x14ProcessBundleRequest\x12+\n#process_bundle_descriptor_reference\x18\x01 \x01(\t\x12\x37\n\x0c\x63\x61\x63he_tokens\x18\x02 \x03(\x0b\x32!.org.apache.beam.fn.v1.CacheToken\"\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\x
10\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 \x0
1(\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\"\xeb\x01\n\rStateResponse\x12\n\n\x02id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\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\"J\n\nCacheToken\x12-\n\x06target\x18\x01 \x01(\x0b\x32\x1d.org.apache.beam.fn.v1.Target\x12\r\n\x05token\x18\x02 \x01(\x0c\"V\n\x08StateKey\x12-\n\x06target\x18\x01 \x01(\x0b\x32\x1d.org.apache.beam.fn.v1.Target\x12\x0e\n\x06window\x18
\x02 \x01(\x0c\x12\x0b\n\x03key\x18\x03 \x01(\x0c\"=\n\x11\x43ontinuableStream\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"-\n\x0fStateGetRequest\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\"L\n\x10StateGetResponse\x12\x38\n\x06stream\x18\x01 \x01(\x0b\x32(.org.apache.beam.fn.v1.ContinuableStream\"\"\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.b
eam.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=[google_dot_protobuf_dot_any__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,])
+_sym_db.RegisterFileDescriptor(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=4529,
+ serialized_end=4618,
+)
+_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=167,
+ serialized_end=220,
+)
+
+_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=104,
+ serialized_end=220,
+)
+
+
+_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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=222,
+ serialized_end=260,
+)
+
+
+_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=600,
+ serialized_end=681,
+)
+
+_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=683,
+ serialized_end=765,
+)
+
+_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=767,
+ serialized_end=850,
+)
+
+_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=None),
+ _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=None),
+ _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=None),
+ _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=None),
+ _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=None),
+ _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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[_PRIMITIVETRANSFORM_INPUTSENTRY, _PRIMITIVETRANSFORM_OUTPUTSENTRY, _PRIMITIVETRANSFORM_SIDEINPUTSENTRY, ],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=263,
+ serialized_end=850,
+)
+
+
+_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=None),
+ _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=None),
+ _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=None),
+ _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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=852,
+ serialized_end=958,
+)
+
+
+_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=None),
+ _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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=960,
+ serialized_end=1071,
+)
+
+
+_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=None),
+ _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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=1073,
+ serialized_end=1175,
+)
+
+
+_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=1177,
+ serialized_end=1270,
+)
+
+
+_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=1273,
+ serialized_end=1633,
+)
+
+
+_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=1636,
+ serialized_end=2017,
+)
+
+
+_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=2019,
+ serialized_end=2119,
+)
+
+
+_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=2121,
+ serialized_end=2139,
+)
+
+
+_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=None),
+ _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=None),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=2142,
+ serialized_end=2297,
+)
+
+
+_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=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=2299,
+ serialized_end=2423,
+)
+
+
+_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=2425,
+ serialized_end=2448,
+)
+
+
+_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=2450,
+ serialized_end=2511,
+)
+
+
+_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=2513,
+ serialized_end=2584,
+)
+
+
+_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=2586,
+ serialized_end=2662,
+)
+
+
+_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=2664,
+ serialized_end=2704,
+)
+
+
+_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=2706,
+ serialized_end=2750,
+)
+
+
+_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=2753,
+ serialized_end=2953,
+)
+
+
+_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=2955,
+ serialized_end=3047,
+)
+
+
+_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=3114,
+ serialized_end=3212,
+)
+
+_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=3050,
+ serialized_end=3212,
+)
+
+
+_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=3215,
+ serialized_end=3513,
+)
+
+
+_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='get', full_name='org.apache.beam.fn.v1.StateResponse.get', 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='append', full_name='org.apache.beam.fn.v1.StateResponse.append', 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='clear', full_name='org.apache.beam.fn.v1.StateResponse.clear', 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),
+ ],
+ 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=3516,
+ serialized_end=3751,
+)
+
+
+_CACHETOKEN = _descriptor.Descriptor(
+ name='CacheToken',
+ full_name='org.apache.beam.fn.v1.CacheToken',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='target', full_name='org.apache.beam.fn.v1.CacheToken.target', 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='token', full_name='org.apache.beam.fn.v1.CacheToken.token', 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=3753,
+ serialized_end=3827,
+)
+
+
+_STATEKEY = _descriptor.Descriptor(
+ name='StateKey',
+ full_name='org.apache.beam.fn.v1.StateKey',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='target', full_name='org.apache.beam.fn.v1.StateKey.target', 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='window', full_name='org.apache.beam.fn.v1.StateKey.window', 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),
+ _descriptor.FieldDescriptor(
+ name='key', full_name='org.apache.beam.fn.v1.StateKey.key', 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=3829,
+ serialized_end=3915,
+)
+
+
+_CONTINUABLESTREAM = _descriptor.Descriptor(
+ name='ContinuableStream',
+ full_name='org.apache.beam.fn.v1.ContinuableStream',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='continuation_token', full_name='org.apache.beam.fn.v1.ContinuableStream.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.ContinuableStream.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=3917,
+ serialized_end=3978,
+)
+
+
+_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=3980,
+ serialized_end=4025,
+)
+
+
+_STATEGETRESPONSE = _descriptor.Descriptor(
+ name='StateGetResponse',
+ full_name='org.apache.beam.fn.v1.StateGetResponse',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='stream', full_name='org.apache.beam.fn.v1.StateGetResponse.stream', 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=4027,
+ serialized_end=4103,
+)
+
+
+_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=4105,
+ serialized_end=4139,
+)
+
+
+_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=4141,
+ serialized_end=4162,
+)
+
+
+_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=4164,
+ serialized_end=4183,
+)
+
+
+_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=4185,
+ serialized_end=4205,
+)
+
+
+_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=4467,
+ serialized_end=4527,
+)
+
+_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=4208,
+ serialized_end=4618,
+)
+
+
+_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=4620,
+ serialized_end=4632,
+)
+
+
+_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=4635,
+ serialized_end=4796,
+)
+
+
+_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=4798,
+ serialized_end=4841,
+)
+
+
+_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=4843,
+ serialized_end=4913,
+)
+
+_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.fields_by_name['primitive_transform'].message_type = _PRIMITIVETRANSFORM
+_PROCESSBUNDLEDESCRIPTOR.fields_by_name['coders'].message_type = _CODER
+_PROCESSBUNDLEREQUEST.fields_by_name['cache_tokens'].message_type = _CACHETOKEN
+_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']
+_CACHETOKEN.fields_by_name['target'].message_type = _TARGET
+_STATEKEY.fields_by_name['target'].message_type = _TARGET
+_STATEGETRESPONSE.fields_by_name['stream'].message_type = _CONTINUABLESTREAM
+_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['CacheToken'] = _CACHETOKEN
+DESCRIPTOR.message_types_by_name['StateKey'] = _STATEKEY
+DESCRIPTOR.message_types_by_name['ContinuableStream'] = _CONTINUABLESTREAM
+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
+
+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(
+ DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR,
+ __module__ = 'beam_fn_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ProcessBundleDescriptor)
+ ))
+_sym_db.RegisterMessage(ProcessBundleDescriptor)
+
+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)
+
+CacheToken = _reflection.GeneratedProtocolMessageType('CacheToken', (_message.Message,), dict(
+ DESCRIPTOR = _CACHETOKEN,
+ __module__ = 'beam_fn_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.CacheToken)
+ ))
+_sym_db.RegisterMessage(CacheToken)
+
+StateKey = _reflection.GeneratedProtocolMessageType('StateKey', (_message.Message,), dict(
+ DESCRIPTOR = _STATEKEY,
+ __module__ = 'beam_fn_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.StateKey)
+ ))
+_sym_db.RegisterMessage(StateKey)
+
+ContinuableStream = _reflection.GeneratedProtocolMessageType('ContinuableStream', (_message.Message,), dict(
+ DESCRIPTOR = _CONTINUABLESTREAM,
+ __module__ = 'beam_fn_api_pb2'
+ # @@protoc_insertion_point(class_scope:org.apache.beam.fn.v1.ContinuableStream)
+ ))
+_sym_db.RegisterMessage(ContinuableStream)
+
+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.
<TRUNCATED>
[3/7] beam git commit: Generate python proto wrappers for runner and
fn API.
Posted by ro...@apache.org.
Generate python proto wrappers for runner and fn API.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a59b057
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2a59b057
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2a59b057
Branch: refs/heads/master
Commit: 2a59b0574c988661a17b57c2380a16227f5e6529
Parents: 11103af
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Apr 21 10:00:20 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Apr 24 14:52:27 2017 -0700
----------------------------------------------------------------------
.../apache_beam/runners/api/beam_fn_api_pb2.py | 2723 ++++++++++++++++++
.../runners/api/beam_fn_api_pb2_grpc.py | 186 ++
.../runners/api/beam_runner_api_pb2.py | 315 +-
3 files changed, 3107 insertions(+), 117 deletions(-)
----------------------------------------------------------------------
[6/7] beam git commit: Adapt to PR #2505 changes to protos.
Posted by ro...@apache.org.
Adapt to PR #2505 changes to protos.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/488f3c67
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/488f3c67
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/488f3c67
Branch: refs/heads/master
Commit: 488f3c6730edd4a22005132f5d8c819fa2deb3a1
Parents: fbeb7e1
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Apr 21 14:22:07 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Apr 24 14:52:28 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/pipeline.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/488f3c67/sdks/python/apache_beam/pipeline.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/pipeline.py b/sdks/python/apache_beam/pipeline.py
index 8e811bc..0f4c8db 100644
--- a/sdks/python/apache_beam/pipeline.py
+++ b/sdks/python/apache_beam/pipeline.py
@@ -336,7 +336,7 @@ class Pipeline(object):
# argument evaluation order.
root_transform_id = context.transforms.get_id(self._root_transform())
proto = beam_runner_api_pb2.Pipeline(
- root_transform_id=root_transform_id,
+ root_transform_ids=[root_transform_id],
components=context.to_runner_api())
return proto
@@ -345,8 +345,9 @@ class Pipeline(object):
p = Pipeline(runner=runner, options=options)
from apache_beam.runners import pipeline_context
context = pipeline_context.PipelineContext(proto.components)
+ root_transform_id, = proto.root_transform_ids
p.transforms_stack = [
- context.transforms.get_by_id(proto.root_transform_id)]
+ context.transforms.get_by_id(root_transform_id)]
# TODO(robertwb): These are only needed to continue construction. Omit?
p.applied_labels = set([
t.unique_name for t in proto.components.transforms.values()])
[7/7] beam git commit: Closes #2632
Posted by ro...@apache.org.
Closes #2632
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d7e7af8e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d7e7af8e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d7e7af8e
Branch: refs/heads/master
Commit: d7e7af8eb8aac09e189d4dfb6f103783d0c7ca05
Parents: 0191e04 488f3c6
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Mon Apr 24 14:52:29 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Apr 24 14:52:29 2017 -0700
----------------------------------------------------------------------
pom.xml | 3 +
sdks/python/apache_beam/pipeline.py | 5 +-
sdks/python/apache_beam/runners/api/__init__.py | 14 +
.../apache_beam/runners/api/beam_fn_api_pb2.py | 2740 ++++++++++++++++++
.../runners/api/beam_fn_api_pb2_grpc.py | 203 ++
.../runners/api/beam_runner_api_pb2.py | 298 +-
sdks/python/run_pylint.sh | 5 +-
sdks/python/setup.py | 1 +
8 files changed, 3166 insertions(+), 103 deletions(-)
----------------------------------------------------------------------
[4/7] beam git commit: Add instructions to regenerate Python proto
wrappers.
Posted by ro...@apache.org.
Add instructions to regenerate Python proto wrappers.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11103afa
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11103afa
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/11103afa
Branch: refs/heads/master
Commit: 11103afa4a46cc1835f1479651bcd7c808d6a33c
Parents: 0191e04
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Apr 21 09:59:52 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Apr 24 14:52:27 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/api/__init__.py | 14 ++++++++++++++
1 file changed, 14 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/11103afa/sdks/python/apache_beam/runners/api/__init__.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/api/__init__.py b/sdks/python/apache_beam/runners/api/__init__.py
index cce3aca..e94673c 100644
--- a/sdks/python/apache_beam/runners/api/__init__.py
+++ b/sdks/python/apache_beam/runners/api/__init__.py
@@ -14,3 +14,17 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
+
+"""Checked in to avoid protoc dependency for Python development.
+
+Regenerate files with::
+
+ protoc -I../common/runner-api/src/main/proto/ \
+ --python_out=apache_beam/runners/api/ \
+ ../common/runner-api/src/main/proto/*.proto
+
+ protoc -I../common/{fn,runner}-api/src/main/proto/ \
+ --python_out=apache_beam/runners/api/ \
+ --grpc_python_out=apache_beam/runners/api/ \
+ ../common/fn-api/src/main/proto/*.proto
+"""