from __future__ import absolute_import
# 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 . import beam_runner_api_pb2 as beam__runner__api__pb2
from . import endpoints_pb2 as endpoints__pb2
from google.protobuf import descriptor_pb2 as google_dot_protobuf_dot_descriptor__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2
from . import metrics_pb2 as metrics__pb2


DESCRIPTOR = _descriptor.FileDescriptor(
  name='beam_fn_api.proto',
  package='org.apache.beam.model.fn_execution.v1',
  syntax='proto3',
  serialized_pb=_b('\n\x11\x62\x65\x61m_fn_api.proto\x12%org.apache.beam.model.fn_execution.v1\x1a\x15\x62\x65\x61m_runner_api.proto\x1a\x0f\x65ndpoints.proto\x1a google/protobuf/descriptor.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\rmetrics.proto\"\x84\x01\n\x06Target\x12%\n\x1dprimitive_transform_reference\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x1a\x45\n\x04List\x12=\n\x06target\x18\x01 \x03(\x0b\x32-.org.apache.beam.model.fn_execution.v1.Target\"{\n\x0eRemoteGrpcPort\x12W\n\x16\x61pi_service_descriptor\x18\x01 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12\x10\n\x08\x63oder_id\x18\x02 \x01(\t\"\x82\x04\n\x12InstructionRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12K\n\x08register\x18\xe8\x07 \x01(\x0b\x32\x36.org.apache.beam.model.fn_execution.v1.RegisterRequestH\x00\x12V\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32;.org.apache.beam.model.fn_execution.v1.ProcessBundleRequestH\x00\x12g\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x43.org.apache.beam.model.fn_execution.v1.ProcessBundleProgressRequestH\x00\x12\x61\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32@.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequestH\x00\x12X\n\x0f\x66inalize_bundle\x18\xec\x07 \x01(\x0b\x32<.org.apache.beam.model.fn_execution.v1.FinalizeBundleRequestH\x00\x42\t\n\x07request\"\x98\x04\n\x13InstructionResponse\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12L\n\x08register\x18\xe8\x07 \x01(\x0b\x32\x37.org.apache.beam.model.fn_execution.v1.RegisterResponseH\x00\x12W\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32<.org.apache.beam.model.fn_execution.v1.ProcessBundleResponseH\x00\x12h\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x44.org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponseH\x00\x12\x62\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponseH\x00\x12Y\n\x0f\x66inalize_bundle\x18\xec\x07 \x01(\x0b\x32=.org.apache.beam.model.fn_execution.v1.FinalizeBundleResponseH\x00\x42\n\n\x08response\"t\n\x0fRegisterRequest\x12\x61\n\x19process_bundle_descriptor\x18\x01 \x03(\x0b\x32>.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor\"\x12\n\x10RegisterResponse\"\x82\t\n\x17ProcessBundleDescriptor\x12\n\n\x02id\x18\x01 \x01(\t\x12\x62\n\ntransforms\x18\x02 \x03(\x0b\x32N.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry\x12\x66\n\x0cpcollections\x18\x03 \x03(\x0b\x32P.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry\x12u\n\x14windowing_strategies\x18\x04 \x03(\x0b\x32W.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry\x12Z\n\x06\x63oders\x18\x05 \x03(\x0b\x32J.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry\x12\x66\n\x0c\x65nvironments\x18\x06 \x03(\x0b\x32P.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry\x12]\n\x1cstate_api_service_descriptor\x18\x07 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x1a`\n\x0fTransformsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12<\n\x05value\x18\x02 \x01(\x0b\x32-.org.apache.beam.model.pipeline.v1.PTransform:\x02\x38\x01\x1a\x63\n\x11PcollectionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12=\n\x05value\x18\x02 \x01(\x0b\x32..org.apache.beam.model.pipeline.v1.PCollection:\x02\x38\x01\x1ap\n\x18WindowingStrategiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x43\n\x05value\x18\x02 \x01(\x0b\x32\x34.org.apache.beam.model.pipeline.v1.WindowingStrategy:\x02\x38\x01\x1aW\n\x0b\x43odersEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.org.apache.beam.model.pipeline.v1.Coder:\x02\x38\x01\x1a\x63\n\x11\x45nvironmentsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12=\n\x05value\x18\x02 \x01(\x0b\x32..org.apache.beam.model.pipeline.v1.Environment:\x02\x38\x01\"\xc4\x04\n\x11\x42undleApplication\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x10\n\x08input_id\x18\x02 \x01(\t\x12\x0f\n\x07\x65lement\x18\x03 \x01(\x0c\x12i\n\x11output_watermarks\x18\x04 \x03(\x0b\x32N.org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry\x12Q\n\x07\x62\x61\x63klog\x18\x05 \x01(\x0b\x32@.org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog\x12\x45\n\nis_bounded\x18\x06 \x01(\x0e\x32\x31.org.apache.beam.model.pipeline.v1.IsBounded.Enum\x12K\n\x10monitoring_infos\x18\x07 \x03(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo\x1aS\n\x15OutputWatermarksEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12)\n\x05value\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp:\x02\x38\x01\x1aN\n\x07\x42\x61\x63klog\x12\x11\n\tpartition\x18\x01 \x01(\x0c\x12\x10\n\x05\x62ytes\x18\xe8\x07 \x01(\x0cH\x00\x12\x15\n\nis_unknown\x18\xe9\x07 \x01(\x08H\x00\x42\x07\n\x05value\"\xa7\x01\n\x18\x44\x65layedBundleApplication\x12<\n\x18requested_execution_time\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12M\n\x0b\x61pplication\x18\x02 \x01(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.BundleApplication\"Y\n\x14ProcessBundleRequest\x12+\n#process_bundle_descriptor_reference\x18\x01 \x01(\t\x12\x14\n\x0c\x63\x61\x63he_tokens\x18\x02 \x03(\x0c\"\x9d\x02\n\x15ProcessBundleResponse\x12?\n\x07metrics\x18\x01 \x01(\x0b\x32..org.apache.beam.model.fn_execution.v1.Metrics\x12W\n\x0eresidual_roots\x18\x02 \x03(\x0b\x32?.org.apache.beam.model.fn_execution.v1.DelayedBundleApplication\x12K\n\x10monitoring_infos\x18\x03 \x03(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo\x12\x1d\n\x15requires_finalization\x18\x04 \x01(\x08\"=\n\x1cProcessBundleProgressRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\"\xa9\x10\n\x07Metrics\x12T\n\x0bptransforms\x18\x01 \x03(\x0b\x32?.org.apache.beam.model.fn_execution.v1.Metrics.PtransformsEntry\x1a\xfc\t\n\nPTransform\x12g\n\x12processed_elements\x18\x01 \x01(\x0b\x32K.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ProcessedElements\x12\x61\n\x0f\x61\x63tive_elements\x18\x02 \x01(\x0b\x32H.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements\x12]\n\nwatermarks\x18\x03 \x03(\x0b\x32I.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.WatermarksEntry\x12\x41\n\x04user\x18\x04 \x03(\x0b\x32\x33.org.apache.beam.model.fn_execution.v1.Metrics.User\x1a\x91\x03\n\x08Measured\x12x\n\x14input_element_counts\x18\x01 \x03(\x0b\x32Z.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.InputElementCountsEntry\x12z\n\x15output_element_counts\x18\x02 \x03(\x0b\x32[.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.OutputElementCountsEntry\x12\x18\n\x10total_time_spent\x18\x03 \x01(\x01\x1a\x39\n\x17InputElementCountsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\x1a:\n\x18OutputElementCountsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\x1ai\n\x11ProcessedElements\x12T\n\x08measured\x18\x01 \x01(\x0b\x32\x42.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured\x1a\xcd\x02\n\x0e\x41\x63tiveElements\x12T\n\x08measured\x18\x01 \x01(\x0b\x32\x42.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured\x12\x1a\n\x12\x66raction_remaining\x18\x02 \x01(\x01\x12\x88\x01\n\x19output_elements_remaining\x18\x03 \x03(\x0b\x32\x65.org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry\x1a>\n\x1cOutputElementsRemainingEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\x1a\x31\n\x0fWatermarksEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\x1a\xd9\x04\n\x04User\x12S\n\x0bmetric_name\x18\x01 \x01(\x0b\x32>.org.apache.beam.model.fn_execution.v1.Metrics.User.MetricName\x12X\n\x0c\x63ounter_data\x18\xe9\x07 \x01(\x0b\x32?.org.apache.beam.model.fn_execution.v1.Metrics.User.CounterDataH\x00\x12\x62\n\x11\x64istribution_data\x18\xea\x07 \x01(\x0b\x32\x44.org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionDataH\x00\x12T\n\ngauge_data\x18\xeb\x07 \x01(\x0b\x32=.org.apache.beam.model.fn_execution.v1.Metrics.User.GaugeDataH\x00\x1a-\n\nMetricName\x12\x11\n\tnamespace\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x1a\x1c\n\x0b\x43ounterData\x12\r\n\x05value\x18\x01 \x01(\x03\x1aH\n\x10\x44istributionData\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x0b\n\x03sum\x18\x02 \x01(\x03\x12\x0b\n\x03min\x18\x03 \x01(\x03\x12\x0b\n\x03max\x18\x04 \x01(\x03\x1aI\n\tGaugeData\x12\r\n\x05value\x18\x01 \x01(\x03\x12-\n\ttimestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x06\n\x04\x64\x61ta\x1am\n\x10PtransformsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12H\n\x05value\x18\x02 \x01(\x0b\x32\x39.org.apache.beam.model.fn_execution.v1.Metrics.PTransform:\x02\x38\x01\"\xfe\x01\n\x1dProcessBundleProgressResponse\x12?\n\x07metrics\x18\x01 \x01(\x0b\x32..org.apache.beam.model.fn_execution.v1.Metrics\x12K\n\x10monitoring_infos\x18\x03 \x03(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo\x12O\n\rprimary_roots\x18\x04 \x03(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.BundleApplication\"\xc8\x04\n\x19ProcessBundleSplitRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\x12q\n\x11\x62\x61\x63klog_remaining\x18\x02 \x03(\x0b\x32V.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.BacklogRemainingEntry\x12k\n\x0e\x64\x65sired_splits\x18\x03 \x03(\x0b\x32S.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry\x1a\x37\n\x15\x42\x61\x63klogRemainingEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\x1am\n\x0c\x44\x65siredSplit\x12\x1d\n\x15\x66raction_of_remainder\x18\x01 \x01(\x02\x12\x1c\n\x14\x61llowed_split_points\x18\x03 \x03(\x03\x12 \n\x18\x65stimated_input_elements\x18\x02 \x01(\x03\x1a\x83\x01\n\x12\x44\x65siredSplitsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\\\n\x05value\x18\x02 \x01(\x0b\x32M.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit:\x02\x38\x01\"\xa5\x03\n\x1aProcessBundleSplitResponse\x12O\n\rprimary_roots\x18\x01 \x03(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.BundleApplication\x12W\n\x0eresidual_roots\x18\x02 \x03(\x0b\x32?.org.apache.beam.model.fn_execution.v1.DelayedBundleApplication\x12\x66\n\x0e\x63hannel_splits\x18\x03 \x03(\x0b\x32N.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit\x1au\n\x0c\x43hannelSplit\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x10\n\x08input_id\x18\x02 \x01(\t\x12\x1c\n\x14last_primary_element\x18\x03 \x01(\x05\x12\x1e\n\x16\x66irst_residual_element\x18\x04 \x01(\x05\"6\n\x15\x46inalizeBundleRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\"\x18\n\x16\x46inalizeBundleResponse\"\xc2\x01\n\x08\x45lements\x12\x42\n\x04\x64\x61ta\x18\x01 \x03(\x0b\x32\x34.org.apache.beam.model.fn_execution.v1.Elements.Data\x1ar\n\x04\x44\x61ta\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\x12=\n\x06target\x18\x02 \x01(\x0b\x32-.org.apache.beam.model.fn_execution.v1.Target\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\"\xea\x02\n\x0cStateRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x1d\n\x15instruction_reference\x18\x02 \x01(\t\x12\x42\n\tstate_key\x18\x03 \x01(\x0b\x32/.org.apache.beam.model.fn_execution.v1.StateKey\x12\x46\n\x03get\x18\xe8\x07 \x01(\x0b\x32\x36.org.apache.beam.model.fn_execution.v1.StateGetRequestH\x00\x12L\n\x06\x61ppend\x18\xe9\x07 \x01(\x0b\x32\x39.org.apache.beam.model.fn_execution.v1.StateAppendRequestH\x00\x12J\n\x05\x63lear\x18\xea\x07 \x01(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.StateClearRequestH\x00\x42\t\n\x07request\"\xb0\x02\n\rStateResponse\x12\n\n\x02id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12\x13\n\x0b\x63\x61\x63he_token\x18\x03 \x01(\x0c\x12G\n\x03get\x18\xe8\x07 \x01(\x0b\x32\x37.org.apache.beam.model.fn_execution.v1.StateGetResponseH\x00\x12M\n\x06\x61ppend\x18\xe9\x07 \x01(\x0b\x32:.org.apache.beam.model.fn_execution.v1.StateAppendResponseH\x00\x12K\n\x05\x63lear\x18\xea\x07 \x01(\x0b\x32\x39.org.apache.beam.model.fn_execution.v1.StateClearResponseH\x00\x42\n\n\x08response\"\xe8\x03\n\x08StateKey\x12H\n\x06runner\x18\x01 \x01(\x0b\x32\x36.org.apache.beam.model.fn_execution.v1.StateKey.RunnerH\x00\x12`\n\x13multimap_side_input\x18\x02 \x01(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInputH\x00\x12V\n\x0e\x62\x61g_user_state\x18\x03 \x01(\x0b\x32<.org.apache.beam.model.fn_execution.v1.StateKey.BagUserStateH\x00\x1a\x15\n\x06Runner\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x1a^\n\x11MultimapSideInput\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x15\n\rside_input_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x12\x0b\n\x03key\x18\x04 \x01(\x0c\x1aY\n\x0c\x42\x61gUserState\x12\x15\n\rptransform_id\x18\x01 \x01(\t\x12\x15\n\ruser_state_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x12\x0b\n\x03key\x18\x04 \x01(\x0c\x42\x06\n\x04type\"-\n\x0fStateGetRequest\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\"<\n\x10StateGetResponse\x12\x1a\n\x12\x63ontinuation_token\x18\x01 \x01(\x0c\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"\"\n\x12StateAppendRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"\x15\n\x13StateAppendResponse\"\x13\n\x11StateClearRequest\"\x14\n\x12StateClearResponse\"\xd8\x03\n\x08LogEntry\x12O\n\x08severity\x18\x01 \x01(\x0e\x32=.org.apache.beam.model.fn_execution.v1.LogEntry.Severity.Enum\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\x1aL\n\x04List\x12\x44\n\x0blog_entries\x18\x01 \x03(\x0b\x32/.org.apache.beam.model.fn_execution.v1.LogEntry\x1ar\n\x08Severity\"f\n\x04\x45num\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\t\n\x05TRACE\x10\x01\x12\t\n\x05\x44\x45\x42UG\x10\x02\x12\x08\n\x04INFO\x10\x03\x12\n\n\x06NOTICE\x10\x04\x12\x08\n\x04WARN\x10\x05\x12\t\n\x05\x45RROR\x10\x06\x12\x0c\n\x08\x43RITICAL\x10\x07\"\x0c\n\nLogControl\"\x90\x04\n\x1cNotifyRunnerAvailableRequest\x12\x11\n\tworker_id\x18\x01 \x01(\t\x12Q\n\x10\x63ontrol_endpoint\x18\x02 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12Q\n\x10logging_endpoint\x18\x03 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12R\n\x11\x61rtifact_endpoint\x18\x04 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12S\n\x12provision_endpoint\x18\x05 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12_\n\x06params\x18\n \x03(\x0b\x32O.org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.ParamsEntry\x1a-\n\x0bParamsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\".\n\x1dNotifyRunnerAvailableResponse\x12\r\n\x05\x65rror\x18\x01 \x01(\t2\x98\x01\n\rBeamFnControl\x12\x86\x01\n\x07\x43ontrol\x12:.org.apache.beam.model.fn_execution.v1.InstructionResponse\x1a\x39.org.apache.beam.model.fn_execution.v1.InstructionRequest\"\x00(\x01\x30\x01\x32|\n\nBeamFnData\x12n\n\x04\x44\x61ta\x12/.org.apache.beam.model.fn_execution.v1.Elements\x1a/.org.apache.beam.model.fn_execution.v1.Elements\"\x00(\x01\x30\x01\x32\x87\x01\n\x0b\x42\x65\x61mFnState\x12x\n\x05State\x12\x33.org.apache.beam.model.fn_execution.v1.StateRequest\x1a\x34.org.apache.beam.model.fn_execution.v1.StateResponse\"\x00(\x01\x30\x01\x32\x89\x01\n\rBeamFnLogging\x12x\n\x07Logging\x12\x34.org.apache.beam.model.fn_execution.v1.LogEntry.List\x1a\x31.org.apache.beam.model.fn_execution.v1.LogControl\"\x00(\x01\x30\x01\x32\xc1\x01\n\x18\x42\x65\x61mFnExternalWorkerPool\x12\xa4\x01\n\x15NotifyRunnerAvailable\x12\x43.org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest\x1a\x44.org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableResponse\"\x00\x42\x41\n$org.apache.beam.model.fnexecution.v1B\tBeamFnApiZ\x0e\x66nexecution_v1b\x06proto3')
  ,
  dependencies=[beam__runner__api__pb2.DESCRIPTOR,endpoints__pb2.DESCRIPTOR,google_dot_protobuf_dot_descriptor__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,google_dot_protobuf_dot_wrappers__pb2.DESCRIPTOR,metrics__pb2.DESCRIPTOR,])



_LOGENTRY_SEVERITY_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.fn_execution.v1.LogEntry.Severity.Enum',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='UNSPECIFIED', index=0, number=0,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='TRACE', index=1, number=1,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='DEBUG', index=2, number=2,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='INFO', index=3, number=3,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='NOTICE', index=4, number=4,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='WARN', index=5, number=5,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='ERROR', index=6, number=6,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='CRITICAL', index=7, number=7,
      options=None,
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=9404,
  serialized_end=9506,
)
_sym_db.RegisterEnumDescriptor(_LOGENTRY_SEVERITY_ENUM)


_TARGET_LIST = _descriptor.Descriptor(
  name='List',
  full_name='org.apache.beam.model.fn_execution.v1.Target.List',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='target', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=278,
  serialized_end=347,
)

_TARGET = _descriptor.Descriptor(
  name='Target',
  full_name='org.apache.beam.model.fn_execution.v1.Target',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='primitive_transform_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='name', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_TARGET_LIST, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=215,
  serialized_end=347,
)


_REMOTEGRPCPORT = _descriptor.Descriptor(
  name='RemoteGrpcPort',
  full_name='org.apache.beam.model.fn_execution.v1.RemoteGrpcPort',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='api_service_descriptor', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='coder_id', full_name='org.apache.beam.model.fn_execution.v1.RemoteGrpcPort.coder_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=349,
  serialized_end=472,
)


_INSTRUCTIONREQUEST = _descriptor.Descriptor(
  name='InstructionRequest',
  full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='register', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle_progress', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle_split', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='finalize_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.finalize_bundle', index=5,
      number=1004, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='request', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.request',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=475,
  serialized_end=989,
)


_INSTRUCTIONRESPONSE = _descriptor.Descriptor(
  name='InstructionResponse',
  full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='register', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle_progress', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='process_bundle_split', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='finalize_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.finalize_bundle', index=6,
      number=1004, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='response', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.response',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=992,
  serialized_end=1528,
)


_REGISTERREQUEST = _descriptor.Descriptor(
  name='RegisterRequest',
  full_name='org.apache.beam.model.fn_execution.v1.RegisterRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='process_bundle_descriptor', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1530,
  serialized_end=1646,
)


_REGISTERRESPONSE = _descriptor.Descriptor(
  name='RegisterResponse',
  full_name='org.apache.beam.model.fn_execution.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=1648,
  serialized_end=1666,
)


_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY = _descriptor.Descriptor(
  name='TransformsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2322,
  serialized_end=2418,
)

_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY = _descriptor.Descriptor(
  name='PcollectionsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2420,
  serialized_end=2519,
)

_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY = _descriptor.Descriptor(
  name='WindowingStrategiesEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2521,
  serialized_end=2633,
)

_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY = _descriptor.Descriptor(
  name='CodersEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2635,
  serialized_end=2722,
)

_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY = _descriptor.Descriptor(
  name='EnvironmentsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2724,
  serialized_end=2823,
)

_PROCESSBUNDLEDESCRIPTOR = _descriptor.Descriptor(
  name='ProcessBundleDescriptor',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='transforms', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.transforms', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='pcollections', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.pcollections', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='windowing_strategies', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.windowing_strategies', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='coders', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.coders', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='environments', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.environments', index=5,
      number=6, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='state_api_service_descriptor', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.state_api_service_descriptor', index=6,
      number=7, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY, _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY, _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY, _PROCESSBUNDLEDESCRIPTOR_CODERSENTRY, _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1669,
  serialized_end=2823,
)


_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY = _descriptor.Descriptor(
  name='OutputWatermarksEntry',
  full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3243,
  serialized_end=3326,
)

_BUNDLEAPPLICATION_BACKLOG = _descriptor.Descriptor(
  name='Backlog',
  full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='partition', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog.partition', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='bytes', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog.bytes', index=1,
      number=1000, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='is_unknown', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog.is_unknown', index=2,
      number=1001, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog.value',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=3328,
  serialized_end=3406,
)

_BUNDLEAPPLICATION = _descriptor.Descriptor(
  name='BundleApplication',
  full_name='org.apache.beam.model.fn_execution.v1.BundleApplication',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransform_id', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.ptransform_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='input_id', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.input_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='element', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.element', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='output_watermarks', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.output_watermarks', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='backlog', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.backlog', index=4,
      number=5, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='is_bounded', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.is_bounded', index=5,
      number=6, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.monitoring_infos', index=6,
      number=7, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY, _BUNDLEAPPLICATION_BACKLOG, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2826,
  serialized_end=3406,
)


_DELAYEDBUNDLEAPPLICATION = _descriptor.Descriptor(
  name='DelayedBundleApplication',
  full_name='org.apache.beam.model.fn_execution.v1.DelayedBundleApplication',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='requested_execution_time', full_name='org.apache.beam.model.fn_execution.v1.DelayedBundleApplication.requested_execution_time', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='application', full_name='org.apache.beam.model.fn_execution.v1.DelayedBundleApplication.application', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3409,
  serialized_end=3576,
)


_PROCESSBUNDLEREQUEST = _descriptor.Descriptor(
  name='ProcessBundleRequest',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='process_bundle_descriptor_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='cache_tokens', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.cache_tokens', index=1,
      number=2, type=12, cpp_type=9, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3578,
  serialized_end=3667,
)


_PROCESSBUNDLERESPONSE = _descriptor.Descriptor(
  name='ProcessBundleResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='metrics', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.metrics', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='residual_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.residual_roots', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.monitoring_infos', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='requires_finalization', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.requires_finalization', index=3,
      number=4, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3670,
  serialized_end=3955,
)


_PROCESSBUNDLEPROGRESSREQUEST = _descriptor.Descriptor(
  name='ProcessBundleProgressRequest',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3957,
  serialized_end=4018,
)


_METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY = _descriptor.Descriptor(
  name='InputElementCountsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.InputElementCountsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.InputElementCountsEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.InputElementCountsEntry.value', index=1,
      number=2, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4784,
  serialized_end=4841,
)

_METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY = _descriptor.Descriptor(
  name='OutputElementCountsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.OutputElementCountsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.OutputElementCountsEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.OutputElementCountsEntry.value', index=1,
      number=2, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4843,
  serialized_end=4901,
)

_METRICS_PTRANSFORM_MEASURED = _descriptor.Descriptor(
  name='Measured',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='input_element_counts', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.input_element_counts', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='output_element_counts', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.output_element_counts', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='total_time_spent', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.total_time_spent', index=2,
      number=3, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY, _METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4500,
  serialized_end=4901,
)

_METRICS_PTRANSFORM_PROCESSEDELEMENTS = _descriptor.Descriptor(
  name='ProcessedElements',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ProcessedElements',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='measured', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ProcessedElements.measured', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4903,
  serialized_end=5008,
)

_METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY = _descriptor.Descriptor(
  name='OutputElementsRemainingEntry',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry.value', index=1,
      number=2, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5282,
  serialized_end=5344,
)

_METRICS_PTRANSFORM_ACTIVEELEMENTS = _descriptor.Descriptor(
  name='ActiveElements',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='measured', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.measured', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='fraction_remaining', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.fraction_remaining', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='output_elements_remaining', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.output_elements_remaining', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5011,
  serialized_end=5344,
)

_METRICS_PTRANSFORM_WATERMARKSENTRY = _descriptor.Descriptor(
  name='WatermarksEntry',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.WatermarksEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.WatermarksEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.WatermarksEntry.value', index=1,
      number=2, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5346,
  serialized_end=5395,
)

_METRICS_PTRANSFORM = _descriptor.Descriptor(
  name='PTransform',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='processed_elements', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.processed_elements', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='active_elements', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.active_elements', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='watermarks', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.watermarks', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='user', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PTransform.user', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_METRICS_PTRANSFORM_MEASURED, _METRICS_PTRANSFORM_PROCESSEDELEMENTS, _METRICS_PTRANSFORM_ACTIVEELEMENTS, _METRICS_PTRANSFORM_WATERMARKSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4119,
  serialized_end=5395,
)

_METRICS_USER_METRICNAME = _descriptor.Descriptor(
  name='MetricName',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.MetricName',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='namespace', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.MetricName.namespace', index=0,
      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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='name', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.MetricName.name', index=1,
      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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5767,
  serialized_end=5812,
)

_METRICS_USER_COUNTERDATA = _descriptor.Descriptor(
  name='CounterData',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.CounterData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.CounterData.value', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5814,
  serialized_end=5842,
)

_METRICS_USER_DISTRIBUTIONDATA = _descriptor.Descriptor(
  name='DistributionData',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='count', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='sum', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData.sum', index=1,
      number=2, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='min', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData.min', index=2,
      number=3, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='max', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData.max', index=3,
      number=4, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5844,
  serialized_end=5916,
)

_METRICS_USER_GAUGEDATA = _descriptor.Descriptor(
  name='GaugeData',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.GaugeData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.GaugeData.value', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='timestamp', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.GaugeData.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5918,
  serialized_end=5991,
)

_METRICS_USER = _descriptor.Descriptor(
  name='User',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.User',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='metric_name', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.metric_name', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='counter_data', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.counter_data', index=1,
      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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='distribution_data', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.distribution_data', index=2,
      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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='gauge_data', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.gauge_data', index=3,
      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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_METRICS_USER_METRICNAME, _METRICS_USER_COUNTERDATA, _METRICS_USER_DISTRIBUTIONDATA, _METRICS_USER_GAUGEDATA, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.v1.Metrics.User.data',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=5398,
  serialized_end=5999,
)

_METRICS_PTRANSFORMSENTRY = _descriptor.Descriptor(
  name='PtransformsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics.PtransformsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PtransformsEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.Metrics.PtransformsEntry.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6001,
  serialized_end=6110,
)

_METRICS = _descriptor.Descriptor(
  name='Metrics',
  full_name='org.apache.beam.model.fn_execution.v1.Metrics',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransforms', full_name='org.apache.beam.model.fn_execution.v1.Metrics.ptransforms', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_METRICS_PTRANSFORM, _METRICS_USER, _METRICS_PTRANSFORMSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4021,
  serialized_end=6110,
)


_PROCESSBUNDLEPROGRESSRESPONSE = _descriptor.Descriptor(
  name='ProcessBundleProgressResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='metrics', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.metrics', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.monitoring_infos', index=1,
      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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='primary_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.primary_roots', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6113,
  serialized_end=6367,
)


_PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY = _descriptor.Descriptor(
  name='BacklogRemainingEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.BacklogRemainingEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.BacklogRemainingEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.BacklogRemainingEntry.value', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6654,
  serialized_end=6709,
)

_PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT = _descriptor.Descriptor(
  name='DesiredSplit',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='fraction_of_remainder', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.fraction_of_remainder', index=0,
      number=1, type=2, cpp_type=6, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='allowed_split_points', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.allowed_split_points', index=1,
      number=3, type=3, cpp_type=2, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='estimated_input_elements', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.estimated_input_elements', index=2,
      number=2, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6711,
  serialized_end=6820,
)

_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY = _descriptor.Descriptor(
  name='DesiredSplitsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6823,
  serialized_end=6954,
)

_PROCESSBUNDLESPLITREQUEST = _descriptor.Descriptor(
  name='ProcessBundleSplitRequest',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='backlog_remaining', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.backlog_remaining', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='desired_splits', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.desired_splits', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY, _PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT, _PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6370,
  serialized_end=6954,
)


_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT = _descriptor.Descriptor(
  name='ChannelSplit',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransform_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.ptransform_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='input_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.input_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='last_primary_element', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.last_primary_element', index=2,
      number=3, type=5, cpp_type=1, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='first_residual_element', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.first_residual_element', index=3,
      number=4, type=5, cpp_type=1, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=7261,
  serialized_end=7378,
)

_PROCESSBUNDLESPLITRESPONSE = _descriptor.Descriptor(
  name='ProcessBundleSplitResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='primary_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.primary_roots', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='residual_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.residual_roots', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='channel_splits', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.channel_splits', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6957,
  serialized_end=7378,
)


_FINALIZEBUNDLEREQUEST = _descriptor.Descriptor(
  name='FinalizeBundleRequest',
  full_name='org.apache.beam.model.fn_execution.v1.FinalizeBundleRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.v1.FinalizeBundleRequest.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=7380,
  serialized_end=7434,
)


_FINALIZEBUNDLERESPONSE = _descriptor.Descriptor(
  name='FinalizeBundleResponse',
  full_name='org.apache.beam.model.fn_execution.v1.FinalizeBundleResponse',
  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=7436,
  serialized_end=7460,
)


_ELEMENTS_DATA = _descriptor.Descriptor(
  name='Data',
  full_name='org.apache.beam.model.fn_execution.v1.Elements.Data',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='target', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=7543,
  serialized_end=7657,
)

_ELEMENTS = _descriptor.Descriptor(
  name='Elements',
  full_name='org.apache.beam.model.fn_execution.v1.Elements',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_ELEMENTS_DATA, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=7463,
  serialized_end=7657,
)


_STATEREQUEST = _descriptor.Descriptor(
  name='StateRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StateRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='state_key', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='get', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='append', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='clear', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='request', full_name='org.apache.beam.model.fn_execution.v1.StateRequest.request',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=7660,
  serialized_end=8022,
)


_STATERESPONSE = _descriptor.Descriptor(
  name='StateResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='cache_token', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.cache_token', index=2,
      number=3, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='get', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.get', index=3,
      number=1000, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='append', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.append', index=4,
      number=1001, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='clear', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.clear', index=5,
      number=1002, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='response', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.response',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=8025,
  serialized_end=8329,
)


_STATEKEY_RUNNER = _descriptor.Descriptor(
  name='Runner',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.Runner',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.Runner.key', index=0,
      number=1, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8604,
  serialized_end=8625,
)

_STATEKEY_MULTIMAPSIDEINPUT = _descriptor.Descriptor(
  name='MultimapSideInput',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput.ptransform_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='side_input_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput.side_input_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput.window', index=2,
      number=3, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput.key', index=3,
      number=4, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8627,
  serialized_end=8721,
)

_STATEKEY_BAGUSERSTATE = _descriptor.Descriptor(
  name='BagUserState',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState.ptransform_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='user_state_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState.user_state_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState.window', index=2,
      number=3, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState.key', index=3,
      number=4, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8723,
  serialized_end=8812,
)

_STATEKEY = _descriptor.Descriptor(
  name='StateKey',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='runner', full_name='org.apache.beam.model.fn_execution.v1.StateKey.runner', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='multimap_side_input', full_name='org.apache.beam.model.fn_execution.v1.StateKey.multimap_side_input', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='bag_user_state', full_name='org.apache.beam.model.fn_execution.v1.StateKey.bag_user_state', index=2,
      number=3, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_STATEKEY_RUNNER, _STATEKEY_MULTIMAPSIDEINPUT, _STATEKEY_BAGUSERSTATE, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='type', full_name='org.apache.beam.model.fn_execution.v1.StateKey.type',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=8332,
  serialized_end=8820,
)


_STATEGETREQUEST = _descriptor.Descriptor(
  name='StateGetRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StateGetRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='continuation_token', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8822,
  serialized_end=8867,
)


_STATEGETRESPONSE = _descriptor.Descriptor(
  name='StateGetResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateGetResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='continuation_token', full_name='org.apache.beam.model.fn_execution.v1.StateGetResponse.continuation_token', index=0,
      number=1, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.v1.StateGetResponse.data', index=1,
      number=2, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=_b(""),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8869,
  serialized_end=8929,
)


_STATEAPPENDREQUEST = _descriptor.Descriptor(
  name='StateAppendRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StateAppendRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8931,
  serialized_end=8965,
)


_STATEAPPENDRESPONSE = _descriptor.Descriptor(
  name='StateAppendResponse',
  full_name='org.apache.beam.model.fn_execution.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=8967,
  serialized_end=8988,
)


_STATECLEARREQUEST = _descriptor.Descriptor(
  name='StateClearRequest',
  full_name='org.apache.beam.model.fn_execution.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=8990,
  serialized_end=9009,
)


_STATECLEARRESPONSE = _descriptor.Descriptor(
  name='StateClearResponse',
  full_name='org.apache.beam.model.fn_execution.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=9011,
  serialized_end=9031,
)


_LOGENTRY_LIST = _descriptor.Descriptor(
  name='List',
  full_name='org.apache.beam.model.fn_execution.v1.LogEntry.List',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='log_entries', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9314,
  serialized_end=9390,
)

_LOGENTRY_SEVERITY = _descriptor.Descriptor(
  name='Severity',
  full_name='org.apache.beam.model.fn_execution.v1.LogEntry.Severity',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
    _LOGENTRY_SEVERITY_ENUM,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9392,
  serialized_end=9506,
)

_LOGENTRY = _descriptor.Descriptor(
  name='LogEntry',
  full_name='org.apache.beam.model.fn_execution.v1.LogEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='severity', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='timestamp', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='trace', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='instruction_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='primitive_transform_reference', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='log_location', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='thread', full_name='org.apache.beam.model.fn_execution.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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_LOGENTRY_LIST, _LOGENTRY_SEVERITY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9034,
  serialized_end=9506,
)


_LOGCONTROL = _descriptor.Descriptor(
  name='LogControl',
  full_name='org.apache.beam.model.fn_execution.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=9508,
  serialized_end=9520,
)


_NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY = _descriptor.Descriptor(
  name='ParamsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.ParamsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.ParamsEntry.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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.ParamsEntry.value', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10006,
  serialized_end=10051,
)

_NOTIFYRUNNERAVAILABLEREQUEST = _descriptor.Descriptor(
  name='NotifyRunnerAvailableRequest',
  full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='worker_id', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.worker_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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='control_endpoint', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.control_endpoint', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='logging_endpoint', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.logging_endpoint', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='artifact_endpoint', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.artifact_endpoint', 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='provision_endpoint', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.provision_endpoint', index=4,
      number=5, 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, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='params', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.params', index=5,
      number=10, 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9523,
  serialized_end=10051,
)


_NOTIFYRUNNERAVAILABLERESPONSE = _descriptor.Descriptor(
  name='NotifyRunnerAvailableResponse',
  full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableResponse.error', 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, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10053,
  serialized_end=10099,
)

_TARGET_LIST.fields_by_name['target'].message_type = _TARGET
_TARGET_LIST.containing_type = _TARGET
_REMOTEGRPCPORT.fields_by_name['api_service_descriptor'].message_type = endpoints__pb2._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.fields_by_name['finalize_bundle'].message_type = _FINALIZEBUNDLEREQUEST
_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']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['finalize_bundle'])
_INSTRUCTIONREQUEST.fields_by_name['finalize_bundle'].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.fields_by_name['finalize_bundle'].message_type = _FINALIZEBUNDLERESPONSE
_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']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['finalize_bundle'])
_INSTRUCTIONRESPONSE.fields_by_name['finalize_bundle'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_REGISTERREQUEST.fields_by_name['process_bundle_descriptor'].message_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PTRANSFORM
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PCOLLECTION
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._WINDOWINGSTRATEGY
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._CODER
_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._ENVIRONMENT
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['transforms'].message_type = _PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['pcollections'].message_type = _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['windowing_strategies'].message_type = _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['coders'].message_type = _PROCESSBUNDLEDESCRIPTOR_CODERSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['environments'].message_type = _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['state_api_service_descriptor'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY.fields_by_name['value'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY.containing_type = _BUNDLEAPPLICATION
_BUNDLEAPPLICATION_BACKLOG.containing_type = _BUNDLEAPPLICATION
_BUNDLEAPPLICATION_BACKLOG.oneofs_by_name['value'].fields.append(
  _BUNDLEAPPLICATION_BACKLOG.fields_by_name['bytes'])
_BUNDLEAPPLICATION_BACKLOG.fields_by_name['bytes'].containing_oneof = _BUNDLEAPPLICATION_BACKLOG.oneofs_by_name['value']
_BUNDLEAPPLICATION_BACKLOG.oneofs_by_name['value'].fields.append(
  _BUNDLEAPPLICATION_BACKLOG.fields_by_name['is_unknown'])
_BUNDLEAPPLICATION_BACKLOG.fields_by_name['is_unknown'].containing_oneof = _BUNDLEAPPLICATION_BACKLOG.oneofs_by_name['value']
_BUNDLEAPPLICATION.fields_by_name['output_watermarks'].message_type = _BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY
_BUNDLEAPPLICATION.fields_by_name['backlog'].message_type = _BUNDLEAPPLICATION_BACKLOG
_BUNDLEAPPLICATION.fields_by_name['is_bounded'].enum_type = beam__runner__api__pb2._ISBOUNDED_ENUM
_BUNDLEAPPLICATION.fields_by_name['monitoring_infos'].message_type = metrics__pb2._MONITORINGINFO
_DELAYEDBUNDLEAPPLICATION.fields_by_name['requested_execution_time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_DELAYEDBUNDLEAPPLICATION.fields_by_name['application'].message_type = _BUNDLEAPPLICATION
_PROCESSBUNDLERESPONSE.fields_by_name['metrics'].message_type = _METRICS
_PROCESSBUNDLERESPONSE.fields_by_name['residual_roots'].message_type = _DELAYEDBUNDLEAPPLICATION
_PROCESSBUNDLERESPONSE.fields_by_name['monitoring_infos'].message_type = metrics__pb2._MONITORINGINFO
_METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY.containing_type = _METRICS_PTRANSFORM_MEASURED
_METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY.containing_type = _METRICS_PTRANSFORM_MEASURED
_METRICS_PTRANSFORM_MEASURED.fields_by_name['input_element_counts'].message_type = _METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY
_METRICS_PTRANSFORM_MEASURED.fields_by_name['output_element_counts'].message_type = _METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY
_METRICS_PTRANSFORM_MEASURED.containing_type = _METRICS_PTRANSFORM
_METRICS_PTRANSFORM_PROCESSEDELEMENTS.fields_by_name['measured'].message_type = _METRICS_PTRANSFORM_MEASURED
_METRICS_PTRANSFORM_PROCESSEDELEMENTS.containing_type = _METRICS_PTRANSFORM
_METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY.containing_type = _METRICS_PTRANSFORM_ACTIVEELEMENTS
_METRICS_PTRANSFORM_ACTIVEELEMENTS.fields_by_name['measured'].message_type = _METRICS_PTRANSFORM_MEASURED
_METRICS_PTRANSFORM_ACTIVEELEMENTS.fields_by_name['output_elements_remaining'].message_type = _METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY
_METRICS_PTRANSFORM_ACTIVEELEMENTS.containing_type = _METRICS_PTRANSFORM
_METRICS_PTRANSFORM_WATERMARKSENTRY.containing_type = _METRICS_PTRANSFORM
_METRICS_PTRANSFORM.fields_by_name['processed_elements'].message_type = _METRICS_PTRANSFORM_PROCESSEDELEMENTS
_METRICS_PTRANSFORM.fields_by_name['active_elements'].message_type = _METRICS_PTRANSFORM_ACTIVEELEMENTS
_METRICS_PTRANSFORM.fields_by_name['watermarks'].message_type = _METRICS_PTRANSFORM_WATERMARKSENTRY
_METRICS_PTRANSFORM.fields_by_name['user'].message_type = _METRICS_USER
_METRICS_PTRANSFORM.containing_type = _METRICS
_METRICS_USER_METRICNAME.containing_type = _METRICS_USER
_METRICS_USER_COUNTERDATA.containing_type = _METRICS_USER
_METRICS_USER_DISTRIBUTIONDATA.containing_type = _METRICS_USER
_METRICS_USER_GAUGEDATA.fields_by_name['timestamp'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_METRICS_USER_GAUGEDATA.containing_type = _METRICS_USER
_METRICS_USER.fields_by_name['metric_name'].message_type = _METRICS_USER_METRICNAME
_METRICS_USER.fields_by_name['counter_data'].message_type = _METRICS_USER_COUNTERDATA
_METRICS_USER.fields_by_name['distribution_data'].message_type = _METRICS_USER_DISTRIBUTIONDATA
_METRICS_USER.fields_by_name['gauge_data'].message_type = _METRICS_USER_GAUGEDATA
_METRICS_USER.containing_type = _METRICS
_METRICS_USER.oneofs_by_name['data'].fields.append(
  _METRICS_USER.fields_by_name['counter_data'])
_METRICS_USER.fields_by_name['counter_data'].containing_oneof = _METRICS_USER.oneofs_by_name['data']
_METRICS_USER.oneofs_by_name['data'].fields.append(
  _METRICS_USER.fields_by_name['distribution_data'])
_METRICS_USER.fields_by_name['distribution_data'].containing_oneof = _METRICS_USER.oneofs_by_name['data']
_METRICS_USER.oneofs_by_name['data'].fields.append(
  _METRICS_USER.fields_by_name['gauge_data'])
_METRICS_USER.fields_by_name['gauge_data'].containing_oneof = _METRICS_USER.oneofs_by_name['data']
_METRICS_PTRANSFORMSENTRY.fields_by_name['value'].message_type = _METRICS_PTRANSFORM
_METRICS_PTRANSFORMSENTRY.containing_type = _METRICS
_METRICS.fields_by_name['ptransforms'].message_type = _METRICS_PTRANSFORMSENTRY
_PROCESSBUNDLEPROGRESSRESPONSE.fields_by_name['metrics'].message_type = _METRICS
_PROCESSBUNDLEPROGRESSRESPONSE.fields_by_name['monitoring_infos'].message_type = metrics__pb2._MONITORINGINFO
_PROCESSBUNDLEPROGRESSRESPONSE.fields_by_name['primary_roots'].message_type = _BUNDLEAPPLICATION
_PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY.containing_type = _PROCESSBUNDLESPLITREQUEST
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT.containing_type = _PROCESSBUNDLESPLITREQUEST
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY.fields_by_name['value'].message_type = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY.containing_type = _PROCESSBUNDLESPLITREQUEST
_PROCESSBUNDLESPLITREQUEST.fields_by_name['backlog_remaining'].message_type = _PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY
_PROCESSBUNDLESPLITREQUEST.fields_by_name['desired_splits'].message_type = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY
_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT.containing_type = _PROCESSBUNDLESPLITRESPONSE
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['primary_roots'].message_type = _BUNDLEAPPLICATION
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['residual_roots'].message_type = _DELAYEDBUNDLEAPPLICATION
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['channel_splits'].message_type = _PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT
_ELEMENTS_DATA.fields_by_name['target'].message_type = _TARGET
_ELEMENTS_DATA.containing_type = _ELEMENTS
_ELEMENTS.fields_by_name['data'].message_type = _ELEMENTS_DATA
_STATEREQUEST.fields_by_name['state_key'].message_type = _STATEKEY
_STATEREQUEST.fields_by_name['get'].message_type = _STATEGETREQUEST
_STATEREQUEST.fields_by_name['append'].message_type = _STATEAPPENDREQUEST
_STATEREQUEST.fields_by_name['clear'].message_type = _STATECLEARREQUEST
_STATEREQUEST.oneofs_by_name['request'].fields.append(
  _STATEREQUEST.fields_by_name['get'])
_STATEREQUEST.fields_by_name['get'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATEREQUEST.oneofs_by_name['request'].fields.append(
  _STATEREQUEST.fields_by_name['append'])
_STATEREQUEST.fields_by_name['append'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATEREQUEST.oneofs_by_name['request'].fields.append(
  _STATEREQUEST.fields_by_name['clear'])
_STATEREQUEST.fields_by_name['clear'].containing_oneof = _STATEREQUEST.oneofs_by_name['request']
_STATERESPONSE.fields_by_name['get'].message_type = _STATEGETRESPONSE
_STATERESPONSE.fields_by_name['append'].message_type = _STATEAPPENDRESPONSE
_STATERESPONSE.fields_by_name['clear'].message_type = _STATECLEARRESPONSE
_STATERESPONSE.oneofs_by_name['response'].fields.append(
  _STATERESPONSE.fields_by_name['get'])
_STATERESPONSE.fields_by_name['get'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATERESPONSE.oneofs_by_name['response'].fields.append(
  _STATERESPONSE.fields_by_name['append'])
_STATERESPONSE.fields_by_name['append'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATERESPONSE.oneofs_by_name['response'].fields.append(
  _STATERESPONSE.fields_by_name['clear'])
_STATERESPONSE.fields_by_name['clear'].containing_oneof = _STATERESPONSE.oneofs_by_name['response']
_STATEKEY_RUNNER.containing_type = _STATEKEY
_STATEKEY_MULTIMAPSIDEINPUT.containing_type = _STATEKEY
_STATEKEY_BAGUSERSTATE.containing_type = _STATEKEY
_STATEKEY.fields_by_name['runner'].message_type = _STATEKEY_RUNNER
_STATEKEY.fields_by_name['multimap_side_input'].message_type = _STATEKEY_MULTIMAPSIDEINPUT
_STATEKEY.fields_by_name['bag_user_state'].message_type = _STATEKEY_BAGUSERSTATE
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['runner'])
_STATEKEY.fields_by_name['runner'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['multimap_side_input'])
_STATEKEY.fields_by_name['multimap_side_input'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['bag_user_state'])
_STATEKEY.fields_by_name['bag_user_state'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_LOGENTRY_LIST.fields_by_name['log_entries'].message_type = _LOGENTRY
_LOGENTRY_LIST.containing_type = _LOGENTRY
_LOGENTRY_SEVERITY.containing_type = _LOGENTRY
_LOGENTRY_SEVERITY_ENUM.containing_type = _LOGENTRY_SEVERITY
_LOGENTRY.fields_by_name['severity'].enum_type = _LOGENTRY_SEVERITY_ENUM
_LOGENTRY.fields_by_name['timestamp'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY.containing_type = _NOTIFYRUNNERAVAILABLEREQUEST
_NOTIFYRUNNERAVAILABLEREQUEST.fields_by_name['control_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_NOTIFYRUNNERAVAILABLEREQUEST.fields_by_name['logging_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_NOTIFYRUNNERAVAILABLEREQUEST.fields_by_name['artifact_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_NOTIFYRUNNERAVAILABLEREQUEST.fields_by_name['provision_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_NOTIFYRUNNERAVAILABLEREQUEST.fields_by_name['params'].message_type = _NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY
DESCRIPTOR.message_types_by_name['Target'] = _TARGET
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['BundleApplication'] = _BUNDLEAPPLICATION
DESCRIPTOR.message_types_by_name['DelayedBundleApplication'] = _DELAYEDBUNDLEAPPLICATION
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['Metrics'] = _METRICS
DESCRIPTOR.message_types_by_name['ProcessBundleProgressResponse'] = _PROCESSBUNDLEPROGRESSRESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleSplitRequest'] = _PROCESSBUNDLESPLITREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleSplitResponse'] = _PROCESSBUNDLESPLITRESPONSE
DESCRIPTOR.message_types_by_name['FinalizeBundleRequest'] = _FINALIZEBUNDLEREQUEST
DESCRIPTOR.message_types_by_name['FinalizeBundleResponse'] = _FINALIZEBUNDLERESPONSE
DESCRIPTOR.message_types_by_name['Elements'] = _ELEMENTS
DESCRIPTOR.message_types_by_name['StateRequest'] = _STATEREQUEST
DESCRIPTOR.message_types_by_name['StateResponse'] = _STATERESPONSE
DESCRIPTOR.message_types_by_name['StateKey'] = _STATEKEY
DESCRIPTOR.message_types_by_name['StateGetRequest'] = _STATEGETREQUEST
DESCRIPTOR.message_types_by_name['StateGetResponse'] = _STATEGETRESPONSE
DESCRIPTOR.message_types_by_name['StateAppendRequest'] = _STATEAPPENDREQUEST
DESCRIPTOR.message_types_by_name['StateAppendResponse'] = _STATEAPPENDRESPONSE
DESCRIPTOR.message_types_by_name['StateClearRequest'] = _STATECLEARREQUEST
DESCRIPTOR.message_types_by_name['StateClearResponse'] = _STATECLEARRESPONSE
DESCRIPTOR.message_types_by_name['LogEntry'] = _LOGENTRY
DESCRIPTOR.message_types_by_name['LogControl'] = _LOGCONTROL
DESCRIPTOR.message_types_by_name['NotifyRunnerAvailableRequest'] = _NOTIFYRUNNERAVAILABLEREQUEST
DESCRIPTOR.message_types_by_name['NotifyRunnerAvailableResponse'] = _NOTIFYRUNNERAVAILABLERESPONSE
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

Target = _reflection.GeneratedProtocolMessageType('Target', (_message.Message,), dict(

  List = _reflection.GeneratedProtocolMessageType('List', (_message.Message,), dict(
    DESCRIPTOR = _TARGET_LIST,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Target.List)
    ))
  ,
  DESCRIPTOR = _TARGET,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Target)
  ))
_sym_db.RegisterMessage(Target)
_sym_db.RegisterMessage(Target.List)

RemoteGrpcPort = _reflection.GeneratedProtocolMessageType('RemoteGrpcPort', (_message.Message,), dict(
  DESCRIPTOR = _REMOTEGRPCPORT,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.v1.RegisterResponse)
  ))
_sym_db.RegisterMessage(RegisterResponse)

ProcessBundleDescriptor = _reflection.GeneratedProtocolMessageType('ProcessBundleDescriptor', (_message.Message,), dict(

  TransformsEntry = _reflection.GeneratedProtocolMessageType('TransformsEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry)
    ))
  ,

  PcollectionsEntry = _reflection.GeneratedProtocolMessageType('PcollectionsEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry)
    ))
  ,

  WindowingStrategiesEntry = _reflection.GeneratedProtocolMessageType('WindowingStrategiesEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry)
    ))
  ,

  CodersEntry = _reflection.GeneratedProtocolMessageType('CodersEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_CODERSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry)
    ))
  ,

  EnvironmentsEntry = _reflection.GeneratedProtocolMessageType('EnvironmentsEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry)
    ))
  ,
  DESCRIPTOR = _PROCESSBUNDLEDESCRIPTOR,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor)
  ))
_sym_db.RegisterMessage(ProcessBundleDescriptor)
_sym_db.RegisterMessage(ProcessBundleDescriptor.TransformsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.PcollectionsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.WindowingStrategiesEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.CodersEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.EnvironmentsEntry)

BundleApplication = _reflection.GeneratedProtocolMessageType('BundleApplication', (_message.Message,), dict(

  OutputWatermarksEntry = _reflection.GeneratedProtocolMessageType('OutputWatermarksEntry', (_message.Message,), dict(
    DESCRIPTOR = _BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry)
    ))
  ,

  Backlog = _reflection.GeneratedProtocolMessageType('Backlog', (_message.Message,), dict(
    DESCRIPTOR = _BUNDLEAPPLICATION_BACKLOG,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.BundleApplication.Backlog)
    ))
  ,
  DESCRIPTOR = _BUNDLEAPPLICATION,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.BundleApplication)
  ))
_sym_db.RegisterMessage(BundleApplication)
_sym_db.RegisterMessage(BundleApplication.OutputWatermarksEntry)
_sym_db.RegisterMessage(BundleApplication.Backlog)

DelayedBundleApplication = _reflection.GeneratedProtocolMessageType('DelayedBundleApplication', (_message.Message,), dict(
  DESCRIPTOR = _DELAYEDBUNDLEAPPLICATION,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.DelayedBundleApplication)
  ))
_sym_db.RegisterMessage(DelayedBundleApplication)

ProcessBundleRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleRequest', (_message.Message,), dict(
  DESCRIPTOR = _PROCESSBUNDLEREQUEST,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.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.model.fn_execution.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.model.fn_execution.v1.ProcessBundleProgressRequest)
  ))
_sym_db.RegisterMessage(ProcessBundleProgressRequest)

Metrics = _reflection.GeneratedProtocolMessageType('Metrics', (_message.Message,), dict(

  PTransform = _reflection.GeneratedProtocolMessageType('PTransform', (_message.Message,), dict(

    Measured = _reflection.GeneratedProtocolMessageType('Measured', (_message.Message,), dict(

      InputElementCountsEntry = _reflection.GeneratedProtocolMessageType('InputElementCountsEntry', (_message.Message,), dict(
        DESCRIPTOR = _METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY,
        __module__ = 'beam_fn_api_pb2'
        # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.InputElementCountsEntry)
        ))
      ,

      OutputElementCountsEntry = _reflection.GeneratedProtocolMessageType('OutputElementCountsEntry', (_message.Message,), dict(
        DESCRIPTOR = _METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY,
        __module__ = 'beam_fn_api_pb2'
        # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured.OutputElementCountsEntry)
        ))
      ,
      DESCRIPTOR = _METRICS_PTRANSFORM_MEASURED,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.Measured)
      ))
    ,

    ProcessedElements = _reflection.GeneratedProtocolMessageType('ProcessedElements', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_PTRANSFORM_PROCESSEDELEMENTS,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ProcessedElements)
      ))
    ,

    ActiveElements = _reflection.GeneratedProtocolMessageType('ActiveElements', (_message.Message,), dict(

      OutputElementsRemainingEntry = _reflection.GeneratedProtocolMessageType('OutputElementsRemainingEntry', (_message.Message,), dict(
        DESCRIPTOR = _METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY,
        __module__ = 'beam_fn_api_pb2'
        # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry)
        ))
      ,
      DESCRIPTOR = _METRICS_PTRANSFORM_ACTIVEELEMENTS,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.ActiveElements)
      ))
    ,

    WatermarksEntry = _reflection.GeneratedProtocolMessageType('WatermarksEntry', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_PTRANSFORM_WATERMARKSENTRY,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform.WatermarksEntry)
      ))
    ,
    DESCRIPTOR = _METRICS_PTRANSFORM,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PTransform)
    ))
  ,

  User = _reflection.GeneratedProtocolMessageType('User', (_message.Message,), dict(

    MetricName = _reflection.GeneratedProtocolMessageType('MetricName', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_USER_METRICNAME,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.User.MetricName)
      ))
    ,

    CounterData = _reflection.GeneratedProtocolMessageType('CounterData', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_USER_COUNTERDATA,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.User.CounterData)
      ))
    ,

    DistributionData = _reflection.GeneratedProtocolMessageType('DistributionData', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_USER_DISTRIBUTIONDATA,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.User.DistributionData)
      ))
    ,

    GaugeData = _reflection.GeneratedProtocolMessageType('GaugeData', (_message.Message,), dict(
      DESCRIPTOR = _METRICS_USER_GAUGEDATA,
      __module__ = 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.User.GaugeData)
      ))
    ,
    DESCRIPTOR = _METRICS_USER,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.User)
    ))
  ,

  PtransformsEntry = _reflection.GeneratedProtocolMessageType('PtransformsEntry', (_message.Message,), dict(
    DESCRIPTOR = _METRICS_PTRANSFORMSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics.PtransformsEntry)
    ))
  ,
  DESCRIPTOR = _METRICS,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Metrics)
  ))
_sym_db.RegisterMessage(Metrics)
_sym_db.RegisterMessage(Metrics.PTransform)
_sym_db.RegisterMessage(Metrics.PTransform.Measured)
_sym_db.RegisterMessage(Metrics.PTransform.Measured.InputElementCountsEntry)
_sym_db.RegisterMessage(Metrics.PTransform.Measured.OutputElementCountsEntry)
_sym_db.RegisterMessage(Metrics.PTransform.ProcessedElements)
_sym_db.RegisterMessage(Metrics.PTransform.ActiveElements)
_sym_db.RegisterMessage(Metrics.PTransform.ActiveElements.OutputElementsRemainingEntry)
_sym_db.RegisterMessage(Metrics.PTransform.WatermarksEntry)
_sym_db.RegisterMessage(Metrics.User)
_sym_db.RegisterMessage(Metrics.User.MetricName)
_sym_db.RegisterMessage(Metrics.User.CounterData)
_sym_db.RegisterMessage(Metrics.User.DistributionData)
_sym_db.RegisterMessage(Metrics.User.GaugeData)
_sym_db.RegisterMessage(Metrics.PtransformsEntry)

ProcessBundleProgressResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleProgressResponse', (_message.Message,), dict(
  DESCRIPTOR = _PROCESSBUNDLEPROGRESSRESPONSE,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse)
  ))
_sym_db.RegisterMessage(ProcessBundleProgressResponse)

ProcessBundleSplitRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleSplitRequest', (_message.Message,), dict(

  BacklogRemainingEntry = _reflection.GeneratedProtocolMessageType('BacklogRemainingEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.BacklogRemainingEntry)
    ))
  ,

  DesiredSplit = _reflection.GeneratedProtocolMessageType('DesiredSplit', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit)
    ))
  ,

  DesiredSplitsEntry = _reflection.GeneratedProtocolMessageType('DesiredSplitsEntry', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry)
    ))
  ,
  DESCRIPTOR = _PROCESSBUNDLESPLITREQUEST,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest)
  ))
_sym_db.RegisterMessage(ProcessBundleSplitRequest)
_sym_db.RegisterMessage(ProcessBundleSplitRequest.BacklogRemainingEntry)
_sym_db.RegisterMessage(ProcessBundleSplitRequest.DesiredSplit)
_sym_db.RegisterMessage(ProcessBundleSplitRequest.DesiredSplitsEntry)

ProcessBundleSplitResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleSplitResponse', (_message.Message,), dict(

  ChannelSplit = _reflection.GeneratedProtocolMessageType('ChannelSplit', (_message.Message,), dict(
    DESCRIPTOR = _PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit)
    ))
  ,
  DESCRIPTOR = _PROCESSBUNDLESPLITRESPONSE,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse)
  ))
_sym_db.RegisterMessage(ProcessBundleSplitResponse)
_sym_db.RegisterMessage(ProcessBundleSplitResponse.ChannelSplit)

FinalizeBundleRequest = _reflection.GeneratedProtocolMessageType('FinalizeBundleRequest', (_message.Message,), dict(
  DESCRIPTOR = _FINALIZEBUNDLEREQUEST,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.FinalizeBundleRequest)
  ))
_sym_db.RegisterMessage(FinalizeBundleRequest)

FinalizeBundleResponse = _reflection.GeneratedProtocolMessageType('FinalizeBundleResponse', (_message.Message,), dict(
  DESCRIPTOR = _FINALIZEBUNDLERESPONSE,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.FinalizeBundleResponse)
  ))
_sym_db.RegisterMessage(FinalizeBundleResponse)

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.model.fn_execution.v1.Elements.Data)
    ))
  ,
  DESCRIPTOR = _ELEMENTS,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.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.model.fn_execution.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.model.fn_execution.v1.StateResponse)
  ))
_sym_db.RegisterMessage(StateResponse)

StateKey = _reflection.GeneratedProtocolMessageType('StateKey', (_message.Message,), dict(

  Runner = _reflection.GeneratedProtocolMessageType('Runner', (_message.Message,), dict(
    DESCRIPTOR = _STATEKEY_RUNNER,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.Runner)
    ))
  ,

  MultimapSideInput = _reflection.GeneratedProtocolMessageType('MultimapSideInput', (_message.Message,), dict(
    DESCRIPTOR = _STATEKEY_MULTIMAPSIDEINPUT,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput)
    ))
  ,

  BagUserState = _reflection.GeneratedProtocolMessageType('BagUserState', (_message.Message,), dict(
    DESCRIPTOR = _STATEKEY_BAGUSERSTATE,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.BagUserState)
    ))
  ,
  DESCRIPTOR = _STATEKEY,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey)
  ))
_sym_db.RegisterMessage(StateKey)
_sym_db.RegisterMessage(StateKey.Runner)
_sym_db.RegisterMessage(StateKey.MultimapSideInput)
_sym_db.RegisterMessage(StateKey.BagUserState)

StateGetRequest = _reflection.GeneratedProtocolMessageType('StateGetRequest', (_message.Message,), dict(
  DESCRIPTOR = _STATEGETREQUEST,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.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.model.fn_execution.v1.LogEntry.List)
    ))
  ,

  Severity = _reflection.GeneratedProtocolMessageType('Severity', (_message.Message,), dict(
    DESCRIPTOR = _LOGENTRY_SEVERITY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.LogEntry.Severity)
    ))
  ,
  DESCRIPTOR = _LOGENTRY,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.LogEntry)
  ))
_sym_db.RegisterMessage(LogEntry)
_sym_db.RegisterMessage(LogEntry.List)
_sym_db.RegisterMessage(LogEntry.Severity)

LogControl = _reflection.GeneratedProtocolMessageType('LogControl', (_message.Message,), dict(
  DESCRIPTOR = _LOGCONTROL,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.LogControl)
  ))
_sym_db.RegisterMessage(LogControl)

NotifyRunnerAvailableRequest = _reflection.GeneratedProtocolMessageType('NotifyRunnerAvailableRequest', (_message.Message,), dict(

  ParamsEntry = _reflection.GeneratedProtocolMessageType('ParamsEntry', (_message.Message,), dict(
    DESCRIPTOR = _NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest.ParamsEntry)
    ))
  ,
  DESCRIPTOR = _NOTIFYRUNNERAVAILABLEREQUEST,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableRequest)
  ))
_sym_db.RegisterMessage(NotifyRunnerAvailableRequest)
_sym_db.RegisterMessage(NotifyRunnerAvailableRequest.ParamsEntry)

NotifyRunnerAvailableResponse = _reflection.GeneratedProtocolMessageType('NotifyRunnerAvailableResponse', (_message.Message,), dict(
  DESCRIPTOR = _NOTIFYRUNNERAVAILABLERESPONSE,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.NotifyRunnerAvailableResponse)
  ))
_sym_db.RegisterMessage(NotifyRunnerAvailableResponse)


DESCRIPTOR.has_options = True
DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n$org.apache.beam.model.fnexecution.v1B\tBeamFnApiZ\016fnexecution_v1'))
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY.has_options = True
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY.has_options = True
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY.has_options = True
_METRICS_PTRANSFORM_MEASURED_INPUTELEMENTCOUNTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY.has_options = True
_METRICS_PTRANSFORM_MEASURED_OUTPUTELEMENTCOUNTSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY.has_options = True
_METRICS_PTRANSFORM_ACTIVEELEMENTS_OUTPUTELEMENTSREMAININGENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_METRICS_PTRANSFORM_WATERMARKSENTRY.has_options = True
_METRICS_PTRANSFORM_WATERMARKSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_METRICS_PTRANSFORMSENTRY.has_options = True
_METRICS_PTRANSFORMSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY.has_options = True
_PROCESSBUNDLESPLITREQUEST_BACKLOGREMAININGENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY.has_options = True
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY.has_options = True
_NOTIFYRUNNERAVAILABLEREQUEST_PARAMSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))

_BEAMFNCONTROL = _descriptor.ServiceDescriptor(
  name='BeamFnControl',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnControl',
  file=DESCRIPTOR,
  index=0,
  options=None,
  serialized_start=10102,
  serialized_end=10254,
  methods=[
  _descriptor.MethodDescriptor(
    name='Control',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnControl.Control',
    index=0,
    containing_service=None,
    input_type=_INSTRUCTIONRESPONSE,
    output_type=_INSTRUCTIONREQUEST,
    options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNCONTROL)

DESCRIPTOR.services_by_name['BeamFnControl'] = _BEAMFNCONTROL


_BEAMFNDATA = _descriptor.ServiceDescriptor(
  name='BeamFnData',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnData',
  file=DESCRIPTOR,
  index=1,
  options=None,
  serialized_start=10256,
  serialized_end=10380,
  methods=[
  _descriptor.MethodDescriptor(
    name='Data',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnData.Data',
    index=0,
    containing_service=None,
    input_type=_ELEMENTS,
    output_type=_ELEMENTS,
    options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNDATA)

DESCRIPTOR.services_by_name['BeamFnData'] = _BEAMFNDATA


_BEAMFNSTATE = _descriptor.ServiceDescriptor(
  name='BeamFnState',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnState',
  file=DESCRIPTOR,
  index=2,
  options=None,
  serialized_start=10383,
  serialized_end=10518,
  methods=[
  _descriptor.MethodDescriptor(
    name='State',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnState.State',
    index=0,
    containing_service=None,
    input_type=_STATEREQUEST,
    output_type=_STATERESPONSE,
    options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNSTATE)

DESCRIPTOR.services_by_name['BeamFnState'] = _BEAMFNSTATE


_BEAMFNLOGGING = _descriptor.ServiceDescriptor(
  name='BeamFnLogging',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnLogging',
  file=DESCRIPTOR,
  index=3,
  options=None,
  serialized_start=10521,
  serialized_end=10658,
  methods=[
  _descriptor.MethodDescriptor(
    name='Logging',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnLogging.Logging',
    index=0,
    containing_service=None,
    input_type=_LOGENTRY_LIST,
    output_type=_LOGCONTROL,
    options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNLOGGING)

DESCRIPTOR.services_by_name['BeamFnLogging'] = _BEAMFNLOGGING


_BEAMFNEXTERNALWORKERPOOL = _descriptor.ServiceDescriptor(
  name='BeamFnExternalWorkerPool',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool',
  file=DESCRIPTOR,
  index=4,
  options=None,
  serialized_start=10661,
  serialized_end=10854,
  methods=[
  _descriptor.MethodDescriptor(
    name='NotifyRunnerAvailable',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool.NotifyRunnerAvailable',
    index=0,
    containing_service=None,
    input_type=_NOTIFYRUNNERAVAILABLEREQUEST,
    output_type=_NOTIFYRUNNERAVAILABLERESPONSE,
    options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNEXTERNALWORKERPOOL)

DESCRIPTOR.services_by_name['BeamFnExternalWorkerPool'] = _BEAMFNEXTERNALWORKERPOOL

# @@protoc_insertion_point(module_scope)
