# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: beam_fn_api.proto

import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
from google.protobuf import descriptor_pb2
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


import beam_runner_api_pb2 as beam__runner__api__pb2
import endpoints_pb2 as endpoints__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


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\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/wrappers.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\"\xa8\x03\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\x42\t\n\x07request\"\xbd\x03\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\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\"\xed\x04\n\x0b\x42undleSplit\x12U\n\rprimary_roots\x18\x01 \x03(\x0b\x32>.org.apache.beam.model.fn_execution.v1.BundleSplit.Application\x12]\n\x0eresidual_roots\x18\x02 \x03(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.BundleSplit.DelayedApplication\x1a\xa9\x02\n\x0b\x41pplication\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\x12o\n\x11output_watermarks\x18\x04 \x03(\x0b\x32T.org.apache.beam.model.fn_execution.v1.BundleSplit.Application.OutputWatermarksEntry\x12\x36\n\x10\x66raction_of_work\x18\x05 \x01(\x0b\x32\x1c.google.protobuf.DoubleValue\x1a\x37\n\x15OutputWatermarksEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\x1a|\n\x12\x44\x65layedApplication\x12\x11\n\tdelay_sec\x18\x01 \x01(\x01\x12S\n\x0b\x61pplication\x18\x02 \x01(\x0b\x32>.org.apache.beam.model.fn_execution.v1.BundleSplit.Application\"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\"\x9b\x01\n\x15ProcessBundleResponse\x12?\n\x07metrics\x18\x01 \x01(\x0b\x32..org.apache.beam.model.fn_execution.v1.Metrics\x12\x41\n\x05split\x18\x02 \x01(\x0b\x32\x32.org.apache.beam.model.fn_execution.v1.BundleSplit\"=\n\x1cProcessBundleProgressRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\"\xbf\x03\n\x0eMonitoringInfo\x12\x0b\n\x03urn\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12[\n\x15monitoring_table_data\x18\x03 \x01(\x0b\x32:.org.apache.beam.model.fn_execution.v1.MonitoringTableDataH\x00\x12?\n\x06metric\x18\x04 \x01(\x0b\x32-.org.apache.beam.model.fn_execution.v1.MetricH\x00\x12Q\n\x06labels\x18\x05 \x03(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.MonitoringInfo.LabelsEntry\x1a-\n\x0bLabelsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"j\n\x14MonitoringInfoLabels\x12\r\n\tTRANSFORM\x10\x00\x12\x0f\n\x0bPCOLLECTION\x10\x01\x12\x16\n\x12WINDOWING_STRATEGY\x10\x02\x12\t\n\x05\x43ODER\x10\x03\x12\x0f\n\x0b\x45NVIRONMENT\x10\x04\x42\x06\n\x04\x64\x61ta\"\xfe\x01\n\x06Metric\x12J\n\x0c\x63ounter_data\x18\x01 \x01(\x0b\x32\x32.org.apache.beam.model.fn_execution.v1.CounterDataH\x00\x12T\n\x11\x64istribution_data\x18\x02 \x01(\x0b\x32\x37.org.apache.beam.model.fn_execution.v1.DistributionDataH\x00\x12J\n\x0c\x65xtrema_data\x18\x03 \x01(\x0b\x32\x32.org.apache.beam.model.fn_execution.v1.ExtremaDataH\x00\x42\x06\n\x04\x64\x61ta\"]\n\x0b\x43ounterData\x12\x15\n\x0bint64_value\x18\x01 \x01(\x03H\x00\x12\x16\n\x0c\x64ouble_value\x18\x02 \x01(\x01H\x00\x12\x16\n\x0cstring_value\x18\x03 \x01(\tH\x00\x42\x07\n\x05value\"\xc4\x01\n\x0b\x45xtremaData\x12Q\n\x10int_extrema_data\x18\x01 \x01(\x0b\x32\x35.org.apache.beam.model.fn_execution.v1.IntExtremaDataH\x00\x12W\n\x13\x64ouble_extrema_data\x18\x02 \x01(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.DoubleExtremaDataH\x00\x42\t\n\x07\x65xtrema\"$\n\x0eIntExtremaData\x12\x12\n\nint_values\x18\x01 \x03(\x03\"*\n\x11\x44oubleExtremaData\x12\x15\n\rdouble_values\x18\x02 \x03(\x01\"\xe2\x01\n\x10\x44istributionData\x12[\n\x15int_distribution_data\x18\x01 \x01(\x0b\x32:.org.apache.beam.model.fn_execution.v1.IntDistributionDataH\x00\x12\x61\n\x18\x64ouble_distribution_data\x18\x02 \x01(\x0b\x32=.org.apache.beam.model.fn_execution.v1.DoubleDistributionDataH\x00\x42\x0e\n\x0c\x64istribution\"K\n\x13IntDistributionData\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\"N\n\x16\x44oubleDistributionData\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x0b\n\x03sum\x18\x02 \x01(\x01\x12\x0b\n\x03min\x18\x03 \x01(\x01\x12\x0b\n\x03max\x18\x04 \x01(\x01\"\x95\x03\n\x13MonitoringTableData\x12\x14\n\x0c\x63olumn_names\x18\x01 \x03(\t\x12Z\n\x08row_data\x18\x02 \x03(\x0b\x32H.org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringRow\x1a\x98\x01\n\x15MonitoringColumnValue\x12\x15\n\x0bint64_value\x18\x01 \x01(\x03H\x00\x12\x16\n\x0c\x64ouble_value\x18\x02 \x01(\x01H\x00\x12\x16\n\x0cstring_value\x18\x03 \x01(\tH\x00\x12/\n\ttimestamp\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x42\x07\n\x05value\x1aq\n\rMonitoringRow\x12`\n\x06values\x18\x01 \x03(\x0b\x32P.org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue\"\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\"\xa3\x01\n\x1dProcessBundleProgressResponse\x12?\n\x07metrics\x18\x01 \x01(\x0b\x32..org.apache.beam.model.fn_execution.v1.Metrics\x12\x41\n\x05split\x18\x02 \x01(\x0b\x32\x32.org.apache.beam.model.fn_execution.v1.BundleSplit\"w\n\x19ProcessBundleSplitRequest\x12\x1d\n\x15instruction_reference\x18\x01 \x01(\t\x12;\n\x15\x66raction_of_remainder\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.DoubleValue\"\x1c\n\x1aProcessBundleSplitResponse\"\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\nLogControl2\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\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_timestamp__pb2.DESCRIPTOR,google_dot_protobuf_dot_wrappers__pb2.DESCRIPTOR,])



_MONITORINGINFO_MONITORINGINFOLABELS = _descriptor.EnumDescriptor(
  name='MonitoringInfoLabels',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.MonitoringInfoLabels',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='TRANSFORM', index=0, number=0,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='PCOLLECTION', index=1, number=1,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='WINDOWING_STRATEGY', index=2, number=2,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='CODER', index=3, number=3,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='ENVIRONMENT', index=4, number=4,
      options=None,
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=3865,
  serialized_end=3971,
)
_sym_db.RegisterEnumDescriptor(_MONITORINGINFO_MONITORINGINFOLABELS)

_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=9759,
  serialized_end=9861,
)
_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=229,
  serialized_end=298,
)

_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=166,
  serialized_end=298,
)


_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=300,
  serialized_end=423,
)


_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),
  ],
  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=426,
  serialized_end=850,
)


_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),
  ],
  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=853,
  serialized_end=1298,
)


_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=1300,
  serialized_end=1416,
)


_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=1418,
  serialized_end=1436,
)


_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=2092,
  serialized_end=2188,
)

_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=2190,
  serialized_end=2289,
)

_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=2291,
  serialized_end=2403,
)

_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=2405,
  serialized_end=2492,
)

_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=2494,
  serialized_end=2593,
)

_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=1439,
  serialized_end=2593,
)


_BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY = _descriptor.Descriptor(
  name='OutputWatermarksEntry',
  full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.Application.OutputWatermarksEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.Application.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.BundleSplit.Application.OutputWatermarksEntry.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=3036,
  serialized_end=3091,
)

_BUNDLESPLIT_APPLICATION = _descriptor.Descriptor(
  name='Application',
  full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.Application',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='ptransform_id', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.Application.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.BundleSplit.Application.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.BundleSplit.Application.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.BundleSplit.Application.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='fraction_of_work', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.Application.fraction_of_work', 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),
  ],
  extensions=[
  ],
  nested_types=[_BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2794,
  serialized_end=3091,
)

_BUNDLESPLIT_DELAYEDAPPLICATION = _descriptor.Descriptor(
  name='DelayedApplication',
  full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.DelayedApplication',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='delay_sec', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.DelayedApplication.delay_sec', index=0,
      number=1, type=1, cpp_type=5, label=1,
      has_default_value=False, default_value=float(0),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='application', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.DelayedApplication.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=3093,
  serialized_end=3217,
)

_BUNDLESPLIT = _descriptor.Descriptor(
  name='BundleSplit',
  full_name='org.apache.beam.model.fn_execution.v1.BundleSplit',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='primary_roots', full_name='org.apache.beam.model.fn_execution.v1.BundleSplit.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.BundleSplit.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),
  ],
  extensions=[
  ],
  nested_types=[_BUNDLESPLIT_APPLICATION, _BUNDLESPLIT_DELAYEDAPPLICATION, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2596,
  serialized_end=3217,
)


_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=3219,
  serialized_end=3308,
)


_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='split', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.split', 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=3311,
  serialized_end=3466,
)


_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=3468,
  serialized_end=3529,
)


_MONITORINGINFO_LABELSENTRY = _descriptor.Descriptor(
  name='LabelsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.LabelsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.LabelsEntry.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.MonitoringInfo.LabelsEntry.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=3818,
  serialized_end=3863,
)

_MONITORINGINFO = _descriptor.Descriptor(
  name='MonitoringInfo',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='urn', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.urn', 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='type', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.type', 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='monitoring_table_data', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.monitoring_table_data', 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='metric', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.metric', 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='labels', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.labels', 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),
  ],
  extensions=[
  ],
  nested_types=[_MONITORINGINFO_LABELSENTRY, ],
  enum_types=[
    _MONITORINGINFO_MONITORINGINFOLABELS,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='data', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfo.data',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=3532,
  serialized_end=3979,
)


_METRIC = _descriptor.Descriptor(
  name='Metric',
  full_name='org.apache.beam.model.fn_execution.v1.Metric',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='counter_data', full_name='org.apache.beam.model.fn_execution.v1.Metric.counter_data', 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='distribution_data', full_name='org.apache.beam.model.fn_execution.v1.Metric.distribution_data', 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='extrema_data', full_name='org.apache.beam.model.fn_execution.v1.Metric.extrema_data', 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=[],
  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.Metric.data',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=3982,
  serialized_end=4236,
)


_COUNTERDATA = _descriptor.Descriptor(
  name='CounterData',
  full_name='org.apache.beam.model.fn_execution.v1.CounterData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='int64_value', full_name='org.apache.beam.model.fn_execution.v1.CounterData.int64_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='double_value', full_name='org.apache.beam.model.fn_execution.v1.CounterData.double_value', 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='string_value', full_name='org.apache.beam.model.fn_execution.v1.CounterData.string_value', 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),
  ],
  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.CounterData.value',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=4238,
  serialized_end=4331,
)


_EXTREMADATA = _descriptor.Descriptor(
  name='ExtremaData',
  full_name='org.apache.beam.model.fn_execution.v1.ExtremaData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='int_extrema_data', full_name='org.apache.beam.model.fn_execution.v1.ExtremaData.int_extrema_data', 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='double_extrema_data', full_name='org.apache.beam.model.fn_execution.v1.ExtremaData.double_extrema_data', 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=[
    _descriptor.OneofDescriptor(
      name='extrema', full_name='org.apache.beam.model.fn_execution.v1.ExtremaData.extrema',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=4334,
  serialized_end=4530,
)


_INTEXTREMADATA = _descriptor.Descriptor(
  name='IntExtremaData',
  full_name='org.apache.beam.model.fn_execution.v1.IntExtremaData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='int_values', full_name='org.apache.beam.model.fn_execution.v1.IntExtremaData.int_values', index=0,
      number=1, 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),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4532,
  serialized_end=4568,
)


_DOUBLEEXTREMADATA = _descriptor.Descriptor(
  name='DoubleExtremaData',
  full_name='org.apache.beam.model.fn_execution.v1.DoubleExtremaData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='double_values', full_name='org.apache.beam.model.fn_execution.v1.DoubleExtremaData.double_values', index=0,
      number=2, type=1, cpp_type=5, 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=4570,
  serialized_end=4612,
)


_DISTRIBUTIONDATA = _descriptor.Descriptor(
  name='DistributionData',
  full_name='org.apache.beam.model.fn_execution.v1.DistributionData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='int_distribution_data', full_name='org.apache.beam.model.fn_execution.v1.DistributionData.int_distribution_data', 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='double_distribution_data', full_name='org.apache.beam.model.fn_execution.v1.DistributionData.double_distribution_data', 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=[
    _descriptor.OneofDescriptor(
      name='distribution', full_name='org.apache.beam.model.fn_execution.v1.DistributionData.distribution',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=4615,
  serialized_end=4841,
)


_INTDISTRIBUTIONDATA = _descriptor.Descriptor(
  name='IntDistributionData',
  full_name='org.apache.beam.model.fn_execution.v1.IntDistributionData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='count', full_name='org.apache.beam.model.fn_execution.v1.IntDistributionData.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.IntDistributionData.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.IntDistributionData.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.IntDistributionData.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=4843,
  serialized_end=4918,
)


_DOUBLEDISTRIBUTIONDATA = _descriptor.Descriptor(
  name='DoubleDistributionData',
  full_name='org.apache.beam.model.fn_execution.v1.DoubleDistributionData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='count', full_name='org.apache.beam.model.fn_execution.v1.DoubleDistributionData.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.DoubleDistributionData.sum', 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='min', full_name='org.apache.beam.model.fn_execution.v1.DoubleDistributionData.min', 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),
    _descriptor.FieldDescriptor(
      name='max', full_name='org.apache.beam.model.fn_execution.v1.DoubleDistributionData.max', index=3,
      number=4, 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=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4920,
  serialized_end=4998,
)


_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE = _descriptor.Descriptor(
  name='MonitoringColumnValue',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='int64_value', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue.int64_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='double_value', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue.double_value', 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='string_value', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue.string_value', 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='timestamp', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringColumnValue.timestamp', 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),
  ],
  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.MonitoringTableData.MonitoringColumnValue.value',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=5139,
  serialized_end=5291,
)

_MONITORINGTABLEDATA_MONITORINGROW = _descriptor.Descriptor(
  name='MonitoringRow',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringRow',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='values', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringRow.values', 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=5293,
  serialized_end=5406,
)

_MONITORINGTABLEDATA = _descriptor.Descriptor(
  name='MonitoringTableData',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='column_names', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.column_names', index=0,
      number=1, type=9, cpp_type=9, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='row_data', full_name='org.apache.beam.model.fn_execution.v1.MonitoringTableData.row_data', 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),
  ],
  extensions=[
  ],
  nested_types=[_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE, _MONITORINGTABLEDATA_MONITORINGROW, ],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5001,
  serialized_end=5406,
)


_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=6172,
  serialized_end=6229,
)

_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=6231,
  serialized_end=6289,
)

_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=5888,
  serialized_end=6289,
)

_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=6291,
  serialized_end=6396,
)

_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=6670,
  serialized_end=6732,
)

_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=6399,
  serialized_end=6732,
)

_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=6734,
  serialized_end=6783,
)

_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=5507,
  serialized_end=6783,
)

_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=7155,
  serialized_end=7200,
)

_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=7202,
  serialized_end=7230,
)

_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=7232,
  serialized_end=7304,
)

_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=7306,
  serialized_end=7379,
)

_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=6786,
  serialized_end=7387,
)

_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=7389,
  serialized_end=7498,
)

_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=5409,
  serialized_end=7498,
)


_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='split', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.split', 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=7501,
  serialized_end=7664,
)


_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='fraction_of_remainder', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.fraction_of_remainder', 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=7666,
  serialized_end=7785,
)


_PROCESSBUNDLESPLITRESPONSE = _descriptor.Descriptor(
  name='ProcessBundleSplitResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse',
  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=7787,
  serialized_end=7815,
)


_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=7898,
  serialized_end=8012,
)

_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=7818,
  serialized_end=8012,
)


_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=8015,
  serialized_end=8377,
)


_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=8380,
  serialized_end=8684,
)


_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=8959,
  serialized_end=8980,
)

_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=8982,
  serialized_end=9076,
)

_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=9078,
  serialized_end=9167,
)

_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=8687,
  serialized_end=9175,
)


_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=9177,
  serialized_end=9222,
)


_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=9224,
  serialized_end=9284,
)


_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=9286,
  serialized_end=9320,
)


_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=9322,
  serialized_end=9343,
)


_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=9345,
  serialized_end=9364,
)


_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=9366,
  serialized_end=9386,
)


_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=9669,
  serialized_end=9745,
)

_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=9747,
  serialized_end=9861,
)

_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=9389,
  serialized_end=9861,
)


_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=9863,
  serialized_end=9875,
)

_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.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['register'])
_INSTRUCTIONREQUEST.fields_by_name['register'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONRESPONSE.fields_by_name['register'].message_type = _REGISTERRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].message_type = _PROCESSBUNDLERESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].message_type = _PROCESSBUNDLEPROGRESSRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].message_type = _PROCESSBUNDLESPLITRESPONSE
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['register'])
_INSTRUCTIONRESPONSE.fields_by_name['register'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_REGISTERREQUEST.fields_by_name['process_bundle_descriptor'].message_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PTRANSFORM
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._PCOLLECTION
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.fields_by_name['value'].message_type = beam__runner__api__pb2._WINDOWINGSTRATEGY
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY.containing_type = _PROCESSBUNDLEDESCRIPTOR
_PROCESSBUNDLEDESCRIPTOR_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
_BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY.containing_type = _BUNDLESPLIT_APPLICATION
_BUNDLESPLIT_APPLICATION.fields_by_name['output_watermarks'].message_type = _BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY
_BUNDLESPLIT_APPLICATION.fields_by_name['fraction_of_work'].message_type = google_dot_protobuf_dot_wrappers__pb2._DOUBLEVALUE
_BUNDLESPLIT_APPLICATION.containing_type = _BUNDLESPLIT
_BUNDLESPLIT_DELAYEDAPPLICATION.fields_by_name['application'].message_type = _BUNDLESPLIT_APPLICATION
_BUNDLESPLIT_DELAYEDAPPLICATION.containing_type = _BUNDLESPLIT
_BUNDLESPLIT.fields_by_name['primary_roots'].message_type = _BUNDLESPLIT_APPLICATION
_BUNDLESPLIT.fields_by_name['residual_roots'].message_type = _BUNDLESPLIT_DELAYEDAPPLICATION
_PROCESSBUNDLERESPONSE.fields_by_name['metrics'].message_type = _METRICS
_PROCESSBUNDLERESPONSE.fields_by_name['split'].message_type = _BUNDLESPLIT
_MONITORINGINFO_LABELSENTRY.containing_type = _MONITORINGINFO
_MONITORINGINFO.fields_by_name['monitoring_table_data'].message_type = _MONITORINGTABLEDATA
_MONITORINGINFO.fields_by_name['metric'].message_type = _METRIC
_MONITORINGINFO.fields_by_name['labels'].message_type = _MONITORINGINFO_LABELSENTRY
_MONITORINGINFO_MONITORINGINFOLABELS.containing_type = _MONITORINGINFO
_MONITORINGINFO.oneofs_by_name['data'].fields.append(
  _MONITORINGINFO.fields_by_name['monitoring_table_data'])
_MONITORINGINFO.fields_by_name['monitoring_table_data'].containing_oneof = _MONITORINGINFO.oneofs_by_name['data']
_MONITORINGINFO.oneofs_by_name['data'].fields.append(
  _MONITORINGINFO.fields_by_name['metric'])
_MONITORINGINFO.fields_by_name['metric'].containing_oneof = _MONITORINGINFO.oneofs_by_name['data']
_METRIC.fields_by_name['counter_data'].message_type = _COUNTERDATA
_METRIC.fields_by_name['distribution_data'].message_type = _DISTRIBUTIONDATA
_METRIC.fields_by_name['extrema_data'].message_type = _EXTREMADATA
_METRIC.oneofs_by_name['data'].fields.append(
  _METRIC.fields_by_name['counter_data'])
_METRIC.fields_by_name['counter_data'].containing_oneof = _METRIC.oneofs_by_name['data']
_METRIC.oneofs_by_name['data'].fields.append(
  _METRIC.fields_by_name['distribution_data'])
_METRIC.fields_by_name['distribution_data'].containing_oneof = _METRIC.oneofs_by_name['data']
_METRIC.oneofs_by_name['data'].fields.append(
  _METRIC.fields_by_name['extrema_data'])
_METRIC.fields_by_name['extrema_data'].containing_oneof = _METRIC.oneofs_by_name['data']
_COUNTERDATA.oneofs_by_name['value'].fields.append(
  _COUNTERDATA.fields_by_name['int64_value'])
_COUNTERDATA.fields_by_name['int64_value'].containing_oneof = _COUNTERDATA.oneofs_by_name['value']
_COUNTERDATA.oneofs_by_name['value'].fields.append(
  _COUNTERDATA.fields_by_name['double_value'])
_COUNTERDATA.fields_by_name['double_value'].containing_oneof = _COUNTERDATA.oneofs_by_name['value']
_COUNTERDATA.oneofs_by_name['value'].fields.append(
  _COUNTERDATA.fields_by_name['string_value'])
_COUNTERDATA.fields_by_name['string_value'].containing_oneof = _COUNTERDATA.oneofs_by_name['value']
_EXTREMADATA.fields_by_name['int_extrema_data'].message_type = _INTEXTREMADATA
_EXTREMADATA.fields_by_name['double_extrema_data'].message_type = _DOUBLEEXTREMADATA
_EXTREMADATA.oneofs_by_name['extrema'].fields.append(
  _EXTREMADATA.fields_by_name['int_extrema_data'])
_EXTREMADATA.fields_by_name['int_extrema_data'].containing_oneof = _EXTREMADATA.oneofs_by_name['extrema']
_EXTREMADATA.oneofs_by_name['extrema'].fields.append(
  _EXTREMADATA.fields_by_name['double_extrema_data'])
_EXTREMADATA.fields_by_name['double_extrema_data'].containing_oneof = _EXTREMADATA.oneofs_by_name['extrema']
_DISTRIBUTIONDATA.fields_by_name['int_distribution_data'].message_type = _INTDISTRIBUTIONDATA
_DISTRIBUTIONDATA.fields_by_name['double_distribution_data'].message_type = _DOUBLEDISTRIBUTIONDATA
_DISTRIBUTIONDATA.oneofs_by_name['distribution'].fields.append(
  _DISTRIBUTIONDATA.fields_by_name['int_distribution_data'])
_DISTRIBUTIONDATA.fields_by_name['int_distribution_data'].containing_oneof = _DISTRIBUTIONDATA.oneofs_by_name['distribution']
_DISTRIBUTIONDATA.oneofs_by_name['distribution'].fields.append(
  _DISTRIBUTIONDATA.fields_by_name['double_distribution_data'])
_DISTRIBUTIONDATA.fields_by_name['double_distribution_data'].containing_oneof = _DISTRIBUTIONDATA.oneofs_by_name['distribution']
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['timestamp'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.containing_type = _MONITORINGTABLEDATA
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value'].fields.append(
  _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['int64_value'])
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['int64_value'].containing_oneof = _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value']
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value'].fields.append(
  _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['double_value'])
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['double_value'].containing_oneof = _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value']
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value'].fields.append(
  _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['string_value'])
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['string_value'].containing_oneof = _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value']
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value'].fields.append(
  _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['timestamp'])
_MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.fields_by_name['timestamp'].containing_oneof = _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE.oneofs_by_name['value']
_MONITORINGTABLEDATA_MONITORINGROW.fields_by_name['values'].message_type = _MONITORINGTABLEDATA_MONITORINGCOLUMNVALUE
_MONITORINGTABLEDATA_MONITORINGROW.containing_type = _MONITORINGTABLEDATA
_MONITORINGTABLEDATA.fields_by_name['row_data'].message_type = _MONITORINGTABLEDATA_MONITORINGROW
_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['split'].message_type = _BUNDLESPLIT
_PROCESSBUNDLESPLITREQUEST.fields_by_name['fraction_of_remainder'].message_type = google_dot_protobuf_dot_wrappers__pb2._DOUBLEVALUE
_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
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['BundleSplit'] = _BUNDLESPLIT
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['MonitoringInfo'] = _MONITORINGINFO
DESCRIPTOR.message_types_by_name['Metric'] = _METRIC
DESCRIPTOR.message_types_by_name['CounterData'] = _COUNTERDATA
DESCRIPTOR.message_types_by_name['ExtremaData'] = _EXTREMADATA
DESCRIPTOR.message_types_by_name['IntExtremaData'] = _INTEXTREMADATA
DESCRIPTOR.message_types_by_name['DoubleExtremaData'] = _DOUBLEEXTREMADATA
DESCRIPTOR.message_types_by_name['DistributionData'] = _DISTRIBUTIONDATA
DESCRIPTOR.message_types_by_name['IntDistributionData'] = _INTDISTRIBUTIONDATA
DESCRIPTOR.message_types_by_name['DoubleDistributionData'] = _DOUBLEDISTRIBUTIONDATA
DESCRIPTOR.message_types_by_name['MonitoringTableData'] = _MONITORINGTABLEDATA
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['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
_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)

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

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

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

  DelayedApplication = _reflection.GeneratedProtocolMessageType('DelayedApplication', (_message.Message,), dict(
    DESCRIPTOR = _BUNDLESPLIT_DELAYEDAPPLICATION,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.BundleSplit.DelayedApplication)
    ))
  ,
  DESCRIPTOR = _BUNDLESPLIT,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.BundleSplit)
  ))
_sym_db.RegisterMessage(BundleSplit)
_sym_db.RegisterMessage(BundleSplit.Application)
_sym_db.RegisterMessage(BundleSplit.Application.OutputWatermarksEntry)
_sym_db.RegisterMessage(BundleSplit.DelayedApplication)

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)

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

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

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

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

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

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

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

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

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

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

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

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

  MonitoringRow = _reflection.GeneratedProtocolMessageType('MonitoringRow', (_message.Message,), dict(
    DESCRIPTOR = _MONITORINGTABLEDATA_MONITORINGROW,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.MonitoringTableData.MonitoringRow)
    ))
  ,
  DESCRIPTOR = _MONITORINGTABLEDATA,
  __module__ = 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.MonitoringTableData)
  ))
_sym_db.RegisterMessage(MonitoringTableData)
_sym_db.RegisterMessage(MonitoringTableData.MonitoringColumnValue)
_sym_db.RegisterMessage(MonitoringTableData.MonitoringRow)

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

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

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

  Data = _reflection.GeneratedProtocolMessageType('Data', (_message.Message,), dict(
    DESCRIPTOR = _ELEMENTS_DATA,
    __module__ = 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.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)


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'))
_BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY.has_options = True
_BUNDLESPLIT_APPLICATION_OUTPUTWATERMARKSENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
_MONITORINGINFO_LABELSENTRY.has_options = True
_MONITORINGINFO_LABELSENTRY._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'))

_BEAMFNCONTROL = _descriptor.ServiceDescriptor(
  name='BeamFnControl',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnControl',
  file=DESCRIPTOR,
  index=0,
  options=None,
  serialized_start=9878,
  serialized_end=10030,
  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=10032,
  serialized_end=10156,
  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=10159,
  serialized_end=10294,
  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=10297,
  serialized_end=10434,
  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

# @@protoc_insertion_point(module_scope)
