# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: beam_fn_api.proto
"""Generated protocol buffer code."""
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
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


from . import beam_runner_api_pb2 as beam__runner__api__pb2
from . import endpoints_pb2 as endpoints__pb2
from google.protobuf import descriptor_pb2 as google_dot_protobuf_dot_descriptor__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
from google.protobuf import duration_pb2 as google_dot_protobuf_dot_duration__pb2
from . import metrics_pb2 as metrics__pb2


DESCRIPTOR = _descriptor.FileDescriptor(
  name='beam_fn_api.proto',
  package='org.apache.beam.model.fn_execution.v1',
  syntax='proto3',
  serialized_options=b'\n$org.apache.beam.model.fnexecution.v1B\tBeamFnApiZNgithub.com/apache/beam/sdks/v2/go/pkg/beam/model/fnexecution_v1;fnexecution_v1',
  create_key=_descriptor._internal_create_key,
  serialized_pb=b'\n\x11\x62\x65\x61m_fn_api.proto\x12%org.apache.beam.model.fn_execution.v1\x1a\x15\x62\x65\x61m_runner_api.proto\x1a\x0f\x65ndpoints.proto\x1a google/protobuf/descriptor.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\rmetrics.proto\"{\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\"I\n!GetProcessBundleDescriptorRequest\x12$\n\x1cprocess_bundle_descriptor_id\x18\x01 \x01(\t\"\xd1\x05\n\x12InstructionRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12V\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32;.org.apache.beam.model.fn_execution.v1.ProcessBundleRequestH\x00\x12g\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x43.org.apache.beam.model.fn_execution.v1.ProcessBundleProgressRequestH\x00\x12\x61\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32@.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequestH\x00\x12X\n\x0f\x66inalize_bundle\x18\xec\x07 \x01(\x0b\x32<.org.apache.beam.model.fn_execution.v1.FinalizeBundleRequestH\x00\x12\x62\n\x10monitoring_infos\x18\xed\x07 \x01(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataRequestH\x00\x12i\n\x18harness_monitoring_infos\x18\xee\x07 \x01(\x0b\x32\x44.org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosRequestH\x00\x12K\n\x08register\x18\xe8\x07 \x01(\x0b\x32\x36.org.apache.beam.model.fn_execution.v1.RegisterRequestH\x00\x42\t\n\x07request\"\xe9\x05\n\x13InstructionResponse\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12W\n\x0eprocess_bundle\x18\xe9\x07 \x01(\x0b\x32<.org.apache.beam.model.fn_execution.v1.ProcessBundleResponseH\x00\x12h\n\x17process_bundle_progress\x18\xea\x07 \x01(\x0b\x32\x44.org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponseH\x00\x12\x62\n\x14process_bundle_split\x18\xeb\x07 \x01(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponseH\x00\x12Y\n\x0f\x66inalize_bundle\x18\xec\x07 \x01(\x0b\x32=.org.apache.beam.model.fn_execution.v1.FinalizeBundleResponseH\x00\x12\x63\n\x10monitoring_infos\x18\xed\x07 \x01(\x0b\x32\x46.org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponseH\x00\x12j\n\x18harness_monitoring_infos\x18\xee\x07 \x01(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponseH\x00\x12L\n\x08register\x18\xe8\x07 \x01(\x0b\x32\x37.org.apache.beam.model.fn_execution.v1.RegisterResponseH\x00\x42\n\n\x08response\"\x1f\n\x1dHarnessMonitoringInfosRequest\"\xcb\x01\n\x1eHarnessMonitoringInfosResponse\x12r\n\x0fmonitoring_data\x18\x01 \x03(\x0b\x32Y.org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.MonitoringDataEntry\x1a\x35\n\x13MonitoringDataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"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\"\xe1\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\x12]\n\x1ctimer_api_service_descriptor\x18\x08 \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\"\xd3\x02\n\x11\x42undleApplication\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x10\n\x08input_id\x18\x02 \x01(\t\x12\x0f\n\x07\x65lement\x18\x03 \x01(\x0c\x12i\n\x11output_watermarks\x18\x04 \x03(\x0b\x32N.org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry\x12\x45\n\nis_bounded\x18\x05 \x01(\x0e\x32\x31.org.apache.beam.model.pipeline.v1.IsBounded.Enum\x1aS\n\x15OutputWatermarksEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12)\n\x05value\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp:\x02\x38\x01\"\xa2\x01\n\x18\x44\x65layedBundleApplication\x12M\n\x0b\x61pplication\x18\x01 \x01(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.BundleApplication\x12\x37\n\x14requested_time_delay\x18\x02 \x01(\x0b\x32\x19.google.protobuf.Duration\"\x9a\x04\n\x14ProcessBundleRequest\x12$\n\x1cprocess_bundle_descriptor_id\x18\x01 \x01(\t\x12\\\n\x0c\x63\x61\x63he_tokens\x18\x02 \x03(\x0b\x32\x46.org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken\x12\x41\n\x08\x65lements\x18\x03 \x01(\x0b\x32/.org.apache.beam.model.fn_execution.v1.Elements\x1a\xba\x02\n\nCacheToken\x12\x66\n\nuser_state\x18\x01 \x01(\x0b\x32P.org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.UserStateH\x00\x12\x66\n\nside_input\x18\x02 \x01(\x0b\x32P.org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.SideInputH\x00\x12\r\n\x05token\x18\n \x01(\x0c\x1a\x0b\n\tUserState\x1a\x38\n\tSideInput\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x15\n\rside_input_id\x18\x02 \x01(\tB\x06\n\x04type\"\xc7\x03\n\x15ProcessBundleResponse\x12W\n\x0eresidual_roots\x18\x02 \x03(\x0b\x32?.org.apache.beam.model.fn_execution.v1.DelayedBundleApplication\x12K\n\x10monitoring_infos\x18\x03 \x03(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo\x12\x1d\n\x15requires_finalization\x18\x04 \x01(\x08\x12i\n\x0fmonitoring_data\x18\x05 \x03(\x0b\x32P.org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.MonitoringDataEntry\x12\x41\n\x08\x65lements\x18\x06 \x01(\x0b\x32/.org.apache.beam.model.fn_execution.v1.Elements\x1a\x35\n\x13MonitoringDataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01J\x04\x08\x01\x10\x02\"6\n\x1cProcessBundleProgressRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\"<\n\x1eMonitoringInfosMetadataRequest\x12\x1a\n\x12monitoring_info_id\x18\x01 \x03(\t\"\xa8\x02\n\x1dProcessBundleProgressResponse\x12K\n\x10monitoring_infos\x18\x03 \x03(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo\x12q\n\x0fmonitoring_data\x18\x05 \x03(\x0b\x32X.org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.MonitoringDataEntry\x1a\x35\n\x13MonitoringDataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01J\x04\x08\x01\x10\x02J\x04\x08\x02\x10\x03J\x04\x08\x04\x10\x05\"\x80\x02\n\x1fMonitoringInfosMetadataResponse\x12s\n\x0fmonitoring_info\x18\x01 \x03(\x0b\x32Z.org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.MonitoringInfoEntry\x1ah\n\x13MonitoringInfoEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12@\n\x05value\x18\x02 \x01(\x0b\x32\x31.org.apache.beam.model.pipeline.v1.MonitoringInfo:\x02\x38\x01\"\x95\x03\n\x19ProcessBundleSplitRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12k\n\x0e\x64\x65sired_splits\x18\x03 \x03(\x0b\x32S.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry\x1am\n\x0c\x44\x65siredSplit\x12\x1d\n\x15\x66raction_of_remainder\x18\x01 \x01(\x01\x12\x1c\n\x14\x61llowed_split_points\x18\x03 \x03(\x03\x12 \n\x18\x65stimated_input_elements\x18\x02 \x01(\x03\x1a\x83\x01\n\x12\x44\x65siredSplitsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\\\n\x05value\x18\x02 \x01(\x0b\x32M.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit:\x02\x38\x01\"\x92\x03\n\x1aProcessBundleSplitResponse\x12O\n\rprimary_roots\x18\x01 \x03(\x0b\x32\x38.org.apache.beam.model.fn_execution.v1.BundleApplication\x12W\n\x0eresidual_roots\x18\x02 \x03(\x0b\x32?.org.apache.beam.model.fn_execution.v1.DelayedBundleApplication\x12\x66\n\x0e\x63hannel_splits\x18\x03 \x03(\x0b\x32N.org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit\x1a\x62\n\x0c\x43hannelSplit\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x1c\n\x14last_primary_element\x18\x02 \x01(\x03\x12\x1e\n\x16\x66irst_residual_element\x18\x03 \x01(\x03\"/\n\x15\x46inalizeBundleRequest\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\"\x18\n\x16\x46inalizeBundleResponse\"\xdd\x02\n\x08\x45lements\x12\x42\n\x04\x64\x61ta\x18\x01 \x03(\x0b\x32\x34.org.apache.beam.model.fn_execution.v1.Elements.Data\x12\x46\n\x06timers\x18\x02 \x03(\x0b\x32\x36.org.apache.beam.model.fn_execution.v1.Elements.Timers\x1aS\n\x04\x44\x61ta\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12\x14\n\x0ctransform_id\x18\x02 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\x12\x0f\n\x07is_last\x18\x04 \x01(\x08\x1ap\n\x06Timers\x12\x16\n\x0einstruction_id\x18\x01 \x01(\t\x12\x14\n\x0ctransform_id\x18\x02 \x01(\t\x12\x17\n\x0ftimer_family_id\x18\x03 \x01(\t\x12\x0e\n\x06timers\x18\x04 \x01(\x0c\x12\x0f\n\x07is_last\x18\x05 \x01(\x08\"\xe3\x02\n\x0cStateRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x16\n\x0einstruction_id\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\"\x9b\x02\n\rStateResponse\x12\n\n\x02id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\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\"\xfb\t\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\x12`\n\x13iterable_side_input\x18\x04 \x01(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInputH\x00\x12i\n\x18multimap_keys_side_input\x18\x05 \x01(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInputH\x00\x12i\n\x18multimap_keys_user_state\x18\x06 \x01(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserStateH\x00\x12`\n\x13multimap_user_state\x18\x07 \x01(\x0b\x32\x41.org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserStateH\x00\x1a\x15\n\x06Runner\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x1aP\n\x11IterableSideInput\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x15\n\rside_input_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x1a]\n\x11MultimapSideInput\x12\x14\n\x0ctransform_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\x1aT\n\x15MultimapKeysSideInput\x12\x14\n\x0ctransform_id\x18\x01 \x01(\t\x12\x15\n\rside_input_id\x18\x02 \x01(\t\x12\x0e\n\x06window\x18\x03 \x01(\x0c\x1aX\n\x0c\x42\x61gUserState\x12\x14\n\x0ctransform_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\x1a\x61\n\x15MultimapKeysUserState\x12\x14\n\x0ctransform_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\x1an\n\x11MultimapUserState\x12\x14\n\x0ctransform_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\x12\x0f\n\x07map_key\x18\x05 \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\"\xc0\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\x16\n\x0einstruction_id\x18\x05 \x01(\t\x12\x14\n\x0ctransform_id\x18\x06 \x01(\t\x12\x14\n\x0clog_location\x18\x07 \x01(\t\x12\x0e\n\x06thread\x18\x08 \x01(\t\x1aL\n\x04List\x12\x44\n\x0blog_entries\x18\x01 \x03(\x0b\x32/.org.apache.beam.model.fn_execution.v1.LogEntry\x1ar\n\x08Severity\"f\n\x04\x45num\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\t\n\x05TRACE\x10\x01\x12\t\n\x05\x44\x45\x42UG\x10\x02\x12\x08\n\x04INFO\x10\x03\x12\n\n\x06NOTICE\x10\x04\x12\x08\n\x04WARN\x10\x05\x12\t\n\x05\x45RROR\x10\x06\x12\x0c\n\x08\x43RITICAL\x10\x07\"\x0c\n\nLogControl\"\xfc\x03\n\x12StartWorkerRequest\x12\x11\n\tworker_id\x18\x01 \x01(\t\x12Q\n\x10\x63ontrol_endpoint\x18\x02 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12Q\n\x10logging_endpoint\x18\x03 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12R\n\x11\x61rtifact_endpoint\x18\x04 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12S\n\x12provision_endpoint\x18\x05 \x01(\x0b\x32\x37.org.apache.beam.model.pipeline.v1.ApiServiceDescriptor\x12U\n\x06params\x18\n \x03(\x0b\x32\x45.org.apache.beam.model.fn_execution.v1.StartWorkerRequest.ParamsEntry\x1a-\n\x0bParamsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"$\n\x13StartWorkerResponse\x12\r\n\x05\x65rror\x18\x01 \x01(\t\"&\n\x11StopWorkerRequest\x12\x11\n\tworker_id\x18\x01 \x01(\t\"#\n\x12StopWorkerResponse\x12\r\n\x05\x65rror\x18\x01 \x01(\t\"!\n\x13WorkerStatusRequest\x12\n\n\x02id\x18\x01 \x01(\t\"F\n\x14WorkerStatusResponse\x12\n\n\x02id\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x12\x13\n\x0bstatus_info\x18\x03 \x01(\t2\xc3\x02\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\x12\xa8\x01\n\x1aGetProcessBundleDescriptor\x12H.org.apache.beam.model.fn_execution.v1.GetProcessBundleDescriptorRequest\x1a>.org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor\"\x00\x32|\n\nBeamFnData\x12n\n\x04\x44\x61ta\x12/.org.apache.beam.model.fn_execution.v1.Elements\x1a/.org.apache.beam.model.fn_execution.v1.Elements\"\x00(\x01\x30\x01\x32\x87\x01\n\x0b\x42\x65\x61mFnState\x12x\n\x05State\x12\x33.org.apache.beam.model.fn_execution.v1.StateRequest\x1a\x34.org.apache.beam.model.fn_execution.v1.StateResponse\"\x00(\x01\x30\x01\x32\x89\x01\n\rBeamFnLogging\x12x\n\x07Logging\x12\x34.org.apache.beam.model.fn_execution.v1.LogEntry.List\x1a\x31.org.apache.beam.model.fn_execution.v1.LogControl\"\x00(\x01\x30\x01\x32\xa9\x02\n\x18\x42\x65\x61mFnExternalWorkerPool\x12\x86\x01\n\x0bStartWorker\x12\x39.org.apache.beam.model.fn_execution.v1.StartWorkerRequest\x1a:.org.apache.beam.model.fn_execution.v1.StartWorkerResponse\"\x00\x12\x83\x01\n\nStopWorker\x12\x38.org.apache.beam.model.fn_execution.v1.StopWorkerRequest\x1a\x39.org.apache.beam.model.fn_execution.v1.StopWorkerResponse\"\x00\x32\xa4\x01\n\x12\x42\x65\x61mFnWorkerStatus\x12\x8d\x01\n\x0cWorkerStatus\x12;.org.apache.beam.model.fn_execution.v1.WorkerStatusResponse\x1a:.org.apache.beam.model.fn_execution.v1.WorkerStatusRequest\"\x00(\x01\x30\x01\x42\x81\x01\n$org.apache.beam.model.fnexecution.v1B\tBeamFnApiZNgithub.com/apache/beam/sdks/v2/go/pkg/beam/model/fnexecution_v1;fnexecution_v1b\x06proto3'
  ,
  dependencies=[beam__runner__api__pb2.DESCRIPTOR,endpoints__pb2.DESCRIPTOR,google_dot_protobuf_dot_descriptor__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,google_dot_protobuf_dot_duration__pb2.DESCRIPTOR,metrics__pb2.DESCRIPTOR,])



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


_REMOTEGRPCPORT = _descriptor.Descriptor(
  name='RemoteGrpcPort',
  full_name='org.apache.beam.model.fn_execution.v1.RemoteGrpcPort',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=214,
  serialized_end=337,
)


_GETPROCESSBUNDLEDESCRIPTORREQUEST = _descriptor.Descriptor(
  name='GetProcessBundleDescriptorRequest',
  full_name='org.apache.beam.model.fn_execution.v1.GetProcessBundleDescriptorRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='process_bundle_descriptor_id', full_name='org.apache.beam.model.fn_execution.v1.GetProcessBundleDescriptorRequest.process_bundle_descriptor_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=339,
  serialized_end=412,
)


_INSTRUCTIONREQUEST = _descriptor.Descriptor(
  name='InstructionRequest',
  full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.process_bundle', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle_progress', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.process_bundle_progress', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle_split', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.process_bundle_split', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='finalize_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.finalize_bundle', index=4,
      number=1004, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.monitoring_infos', index=5,
      number=1005, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='harness_monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.harness_monitoring_infos', index=6,
      number=1006, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='register', full_name='org.apache.beam.model.fn_execution.v1.InstructionRequest.register', index=7,
      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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_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,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=415,
  serialized_end=1136,
)


_INSTRUCTIONRESPONSE = _descriptor.Descriptor(
  name='InstructionResponse',
  full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle_progress', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='process_bundle_split', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='finalize_bundle', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.finalize_bundle', index=5,
      number=1004, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.monitoring_infos', index=6,
      number=1005, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='harness_monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.harness_monitoring_infos', index=7,
      number=1006, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='register', full_name='org.apache.beam.model.fn_execution.v1.InstructionResponse.register', index=8,
      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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_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,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=1139,
  serialized_end=1884,
)


_HARNESSMONITORINGINFOSREQUEST = _descriptor.Descriptor(
  name='HarnessMonitoringInfosRequest',
  full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1886,
  serialized_end=1917,
)


_HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY = _descriptor.Descriptor(
  name='MonitoringDataEntry',
  full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.MonitoringDataEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.MonitoringDataEntry.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.MonitoringDataEntry.value', index=1,
      number=2, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=b"",
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2070,
  serialized_end=2123,
)

_HARNESSMONITORINGINFOSRESPONSE = _descriptor.Descriptor(
  name='HarnessMonitoringInfosResponse',
  full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='monitoring_data', full_name='org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.monitoring_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1920,
  serialized_end=2123,
)


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


_REGISTERRESPONSE = _descriptor.Descriptor(
  name='RegisterResponse',
  full_name='org.apache.beam.model.fn_execution.v1.RegisterResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2243,
  serialized_end=2261,
)


_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY = _descriptor.Descriptor(
  name='TransformsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.TransformsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3012,
  serialized_end=3108,
)

_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY = _descriptor.Descriptor(
  name='PcollectionsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.PcollectionsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3110,
  serialized_end=3209,
)

_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY = _descriptor.Descriptor(
  name='WindowingStrategiesEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.WindowingStrategiesEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3211,
  serialized_end=3323,
)

_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY = _descriptor.Descriptor(
  name='CodersEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.CodersEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3325,
  serialized_end=3412,
)

_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY = _descriptor.Descriptor(
  name='EnvironmentsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3414,
  serialized_end=3513,
)

_PROCESSBUNDLEDESCRIPTOR = _descriptor.Descriptor(
  name='ProcessBundleDescriptor',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='timer_api_service_descriptor', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.timer_api_service_descriptor', index=7,
      number=8, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY, _PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY, _PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY, _PROCESSBUNDLEDESCRIPTOR_CODERSENTRY, _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2264,
  serialized_end=3513,
)


_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY = _descriptor.Descriptor(
  name='OutputWatermarksEntry',
  full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.OutputWatermarksEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3772,
  serialized_end=3855,
)

_BUNDLEAPPLICATION = _descriptor.Descriptor(
  name='BundleApplication',
  full_name='org.apache.beam.model.fn_execution.v1.BundleApplication',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='input_id', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.input_id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='element', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.element', index=2,
      number=3, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=b"",
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='output_watermarks', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.output_watermarks', index=3,
      number=4, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='is_bounded', full_name='org.apache.beam.model.fn_execution.v1.BundleApplication.is_bounded', index=4,
      number=5, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=3516,
  serialized_end=3855,
)


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


_PROCESSBUNDLEREQUEST_CACHETOKEN_USERSTATE = _descriptor.Descriptor(
  name='UserState',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.UserState',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4484,
  serialized_end=4495,
)

_PROCESSBUNDLEREQUEST_CACHETOKEN_SIDEINPUT = _descriptor.Descriptor(
  name='SideInput',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.SideInput',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.SideInput.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='side_input_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.SideInput.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4497,
  serialized_end=4553,
)

_PROCESSBUNDLEREQUEST_CACHETOKEN = _descriptor.Descriptor(
  name='CacheToken',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='user_state', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.user_state', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='side_input', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='token', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.token', index=2,
      number=10, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLEREQUEST_CACHETOKEN_USERSTATE, _PROCESSBUNDLEREQUEST_CACHETOKEN_SIDEINPUT, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='type', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.type',
      index=0, containing_type=None,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=4247,
  serialized_end=4561,
)

_PROCESSBUNDLEREQUEST = _descriptor.Descriptor(
  name='ProcessBundleRequest',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='process_bundle_descriptor_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.process_bundle_descriptor_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='cache_tokens', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.cache_tokens', index=1,
      number=2, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='elements', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.elements', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLEREQUEST_CACHETOKEN, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4023,
  serialized_end=4561,
)


_PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY = _descriptor.Descriptor(
  name='MonitoringDataEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.MonitoringDataEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.MonitoringDataEntry.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.MonitoringDataEntry.value', index=1,
      number=2, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=b"",
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2070,
  serialized_end=2123,
)

_PROCESSBUNDLERESPONSE = _descriptor.Descriptor(
  name='ProcessBundleResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='residual_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.residual_roots', index=0,
      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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.monitoring_infos', index=1,
      number=3, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='requires_finalization', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.requires_finalization', index=2,
      number=4, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='monitoring_data', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.monitoring_data', index=3,
      number=5, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='elements', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.elements', index=4,
      number=6, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4564,
  serialized_end=5019,
)


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


_MONITORINGINFOSMETADATAREQUEST = _descriptor.Descriptor(
  name='MonitoringInfosMetadataRequest',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='monitoring_info_id', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataRequest.monitoring_info_id', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5077,
  serialized_end=5137,
)


_PROCESSBUNDLEPROGRESSRESPONSE_MONITORINGDATAENTRY = _descriptor.Descriptor(
  name='MonitoringDataEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.MonitoringDataEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.MonitoringDataEntry.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.MonitoringDataEntry.value', index=1,
      number=2, type=12, cpp_type=9, label=1,
      has_default_value=False, default_value=b"",
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=2070,
  serialized_end=2123,
)

_PROCESSBUNDLEPROGRESSRESPONSE = _descriptor.Descriptor(
  name='ProcessBundleProgressResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='monitoring_infos', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.monitoring_infos', index=0,
      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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='monitoring_data', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleProgressResponse.monitoring_data', index=1,
      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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLEPROGRESSRESPONSE_MONITORINGDATAENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5140,
  serialized_end=5436,
)


_MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY = _descriptor.Descriptor(
  name='MonitoringInfoEntry',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.MonitoringInfoEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.MonitoringInfoEntry.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.MonitoringInfoEntry.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5591,
  serialized_end=5695,
)

_MONITORINGINFOSMETADATARESPONSE = _descriptor.Descriptor(
  name='MonitoringInfosMetadataResponse',
  full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='monitoring_info', full_name='org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.monitoring_info', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5439,
  serialized_end=5695,
)


_PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT = _descriptor.Descriptor(
  name='DesiredSplit',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='fraction_of_remainder', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.fraction_of_remainder', index=0,
      number=1, type=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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='allowed_split_points', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.allowed_split_points', index=1,
      number=3, type=3, cpp_type=2, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='estimated_input_elements', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplit.estimated_input_elements', index=2,
      number=2, type=3, cpp_type=2, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5860,
  serialized_end=5969,
)

_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY = _descriptor.Descriptor(
  name='DesiredSplitsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.DesiredSplitsEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5972,
  serialized_end=6103,
)

_PROCESSBUNDLESPLITREQUEST = _descriptor.Descriptor(
  name='ProcessBundleSplitRequest',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='desired_splits', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitRequest.desired_splits', index=1,
      number=3, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT, _PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=5698,
  serialized_end=6103,
)


_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT = _descriptor.Descriptor(
  name='ChannelSplit',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='last_primary_element', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.last_primary_element', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='first_residual_element', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.ChannelSplit.first_residual_element', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6410,
  serialized_end=6508,
)

_PROCESSBUNDLESPLITRESPONSE = _descriptor.Descriptor(
  name='ProcessBundleSplitResponse',
  full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='primary_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.primary_roots', index=0,
      number=1, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='residual_roots', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.residual_roots', index=1,
      number=2, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='channel_splits', full_name='org.apache.beam.model.fn_execution.v1.ProcessBundleSplitResponse.channel_splits', index=2,
      number=3, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6106,
  serialized_end=6508,
)


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


_FINALIZEBUNDLERESPONSE = _descriptor.Descriptor(
  name='FinalizeBundleResponse',
  full_name='org.apache.beam.model.fn_execution.v1.FinalizeBundleResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6559,
  serialized_end=6583,
)


_ELEMENTS_DATA = _descriptor.Descriptor(
  name='Data',
  full_name='org.apache.beam.model.fn_execution.v1.Elements.Data',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.v1.Elements.Data.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.Elements.Data.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='is_last', full_name='org.apache.beam.model.fn_execution.v1.Elements.Data.is_last', index=3,
      number=4, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6738,
  serialized_end=6821,
)

_ELEMENTS_TIMERS = _descriptor.Descriptor(
  name='Timers',
  full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='timer_family_id', full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers.timer_family_id', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='timers', full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers.timers', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='is_last', full_name='org.apache.beam.model.fn_execution.v1.Elements.Timers.is_last', index=4,
      number=5, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6823,
  serialized_end=6935,
)

_ELEMENTS = _descriptor.Descriptor(
  name='Elements',
  full_name='org.apache.beam.model.fn_execution.v1.Elements',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='timers', full_name='org.apache.beam.model.fn_execution.v1.Elements.timers', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_ELEMENTS_DATA, _ELEMENTS_TIMERS, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=6586,
  serialized_end=6935,
)


_STATEREQUEST = _descriptor.Descriptor(
  name='StateRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StateRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.v1.StateRequest.instruction_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_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,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=6938,
  serialized_end=7293,
)


_STATERESPONSE = _descriptor.Descriptor(
  name='StateResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='get', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.get', index=2,
      number=1000, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='append', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.append', index=3,
      number=1001, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='clear', full_name='org.apache.beam.model.fn_execution.v1.StateResponse.clear', index=4,
      number=1002, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_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,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=7296,
  serialized_end=7579,
)


_STATEKEY_RUNNER = _descriptor.Descriptor(
  name='Runner',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.Runner',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8264,
  serialized_end=8285,
)

_STATEKEY_ITERABLESIDEINPUT = _descriptor.Descriptor(
  name='IterableSideInput',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInput',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInput.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='side_input_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInput.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInput.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8287,
  serialized_end=8367,
)

_STATEKEY_MULTIMAPSIDEINPUT = _descriptor.Descriptor(
  name='MultimapSideInput',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapSideInput.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8369,
  serialized_end=8462,
)

_STATEKEY_MULTIMAPKEYSSIDEINPUT = _descriptor.Descriptor(
  name='MultimapKeysSideInput',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInput',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInput.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='side_input_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInput.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInput.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8464,
  serialized_end=8548,
)

_STATEKEY_BAGUSERSTATE = _descriptor.Descriptor(
  name='BagUserState',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.BagUserState.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8550,
  serialized_end=8638,
)

_STATEKEY_MULTIMAPKEYSUSERSTATE = _descriptor.Descriptor(
  name='MultimapKeysUserState',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='user_state_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8640,
  serialized_end=8737,
)

_STATEKEY_MULTIMAPUSERSTATE = _descriptor.Descriptor(
  name='MultimapUserState',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState.transform_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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='user_state_id', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='window', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='map_key', full_name='org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState.map_key', index=4,
      number=5, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8739,
  serialized_end=8849,
)

_STATEKEY = _descriptor.Descriptor(
  name='StateKey',
  full_name='org.apache.beam.model.fn_execution.v1.StateKey',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='iterable_side_input', full_name='org.apache.beam.model.fn_execution.v1.StateKey.iterable_side_input', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='multimap_keys_side_input', full_name='org.apache.beam.model.fn_execution.v1.StateKey.multimap_keys_side_input', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='multimap_keys_user_state', full_name='org.apache.beam.model.fn_execution.v1.StateKey.multimap_keys_user_state', index=5,
      number=6, 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='multimap_user_state', full_name='org.apache.beam.model.fn_execution.v1.StateKey.multimap_user_state', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_STATEKEY_RUNNER, _STATEKEY_ITERABLESIDEINPUT, _STATEKEY_MULTIMAPSIDEINPUT, _STATEKEY_MULTIMAPKEYSSIDEINPUT, _STATEKEY_BAGUSERSTATE, _STATEKEY_MULTIMAPKEYSUSERSTATE, _STATEKEY_MULTIMAPUSERSTATE, ],
  enum_types=[
  ],
  serialized_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,
      create_key=_descriptor._internal_create_key,
    fields=[]),
  ],
  serialized_start=7582,
  serialized_end=8857,
)


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


_STATEGETRESPONSE = _descriptor.Descriptor(
  name='StateGetResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateGetResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=8906,
  serialized_end=8966,
)


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


_STATEAPPENDRESPONSE = _descriptor.Descriptor(
  name='StateAppendResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateAppendResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9004,
  serialized_end=9025,
)


_STATECLEARREQUEST = _descriptor.Descriptor(
  name='StateClearRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StateClearRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9027,
  serialized_end=9046,
)


_STATECLEARRESPONSE = _descriptor.Descriptor(
  name='StateClearResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StateClearResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9048,
  serialized_end=9068,
)


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

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

_LOGENTRY = _descriptor.Descriptor(
  name='LogEntry',
  full_name='org.apache.beam.model.fn_execution.v1.LogEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='instruction_id', full_name='org.apache.beam.model.fn_execution.v1.LogEntry.instruction_id', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='transform_id', full_name='org.apache.beam.model.fn_execution.v1.LogEntry.transform_id', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_LOGENTRY_LIST, _LOGENTRY_SEVERITY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9071,
  serialized_end=9519,
)


_LOGCONTROL = _descriptor.Descriptor(
  name='LogControl',
  full_name='org.apache.beam.model.fn_execution.v1.LogControl',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9521,
  serialized_end=9533,
)


_STARTWORKERREQUEST_PARAMSENTRY = _descriptor.Descriptor(
  name='ParamsEntry',
  full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.ParamsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.ParamsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.ParamsEntry.value', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=b'8\001',
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9999,
  serialized_end=10044,
)

_STARTWORKERREQUEST = _descriptor.Descriptor(
  name='StartWorkerRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='worker_id', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.worker_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='control_endpoint', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.control_endpoint', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='logging_endpoint', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.logging_endpoint', index=2,
      number=3, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='artifact_endpoint', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.artifact_endpoint', index=3,
      number=4, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='provision_endpoint', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.provision_endpoint', index=4,
      number=5, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='params', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerRequest.params', index=5,
      number=10, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[_STARTWORKERREQUEST_PARAMSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=9536,
  serialized_end=10044,
)


_STARTWORKERRESPONSE = _descriptor.Descriptor(
  name='StartWorkerResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StartWorkerResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.v1.StartWorkerResponse.error', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10046,
  serialized_end=10082,
)


_STOPWORKERREQUEST = _descriptor.Descriptor(
  name='StopWorkerRequest',
  full_name='org.apache.beam.model.fn_execution.v1.StopWorkerRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='worker_id', full_name='org.apache.beam.model.fn_execution.v1.StopWorkerRequest.worker_id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10084,
  serialized_end=10122,
)


_STOPWORKERRESPONSE = _descriptor.Descriptor(
  name='StopWorkerResponse',
  full_name='org.apache.beam.model.fn_execution.v1.StopWorkerResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.v1.StopWorkerResponse.error', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10124,
  serialized_end=10159,
)


_WORKERSTATUSREQUEST = _descriptor.Descriptor(
  name='WorkerStatusRequest',
  full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusRequest.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10161,
  serialized_end=10194,
)


_WORKERSTATUSRESPONSE = _descriptor.Descriptor(
  name='WorkerStatusResponse',
  full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusResponse.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='error', full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusResponse.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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='status_info', full_name='org.apache.beam.model.fn_execution.v1.WorkerStatusResponse.status_info', 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,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=10196,
  serialized_end=10266,
)

_REMOTEGRPCPORT.fields_by_name['api_service_descriptor'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'].message_type = _PROCESSBUNDLEREQUEST
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'].message_type = _PROCESSBUNDLEPROGRESSREQUEST
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'].message_type = _PROCESSBUNDLESPLITREQUEST
_INSTRUCTIONREQUEST.fields_by_name['finalize_bundle'].message_type = _FINALIZEBUNDLEREQUEST
_INSTRUCTIONREQUEST.fields_by_name['monitoring_infos'].message_type = _MONITORINGINFOSMETADATAREQUEST
_INSTRUCTIONREQUEST.fields_by_name['harness_monitoring_infos'].message_type = _HARNESSMONITORINGINFOSREQUEST
_INSTRUCTIONREQUEST.fields_by_name['register'].message_type = _REGISTERREQUEST
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'])
_INSTRUCTIONREQUEST.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['finalize_bundle'])
_INSTRUCTIONREQUEST.fields_by_name['finalize_bundle'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['monitoring_infos'])
_INSTRUCTIONREQUEST.fields_by_name['monitoring_infos'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['harness_monitoring_infos'])
_INSTRUCTIONREQUEST.fields_by_name['harness_monitoring_infos'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONREQUEST.oneofs_by_name['request'].fields.append(
  _INSTRUCTIONREQUEST.fields_by_name['register'])
_INSTRUCTIONREQUEST.fields_by_name['register'].containing_oneof = _INSTRUCTIONREQUEST.oneofs_by_name['request']
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].message_type = _PROCESSBUNDLERESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].message_type = _PROCESSBUNDLEPROGRESSRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].message_type = _PROCESSBUNDLESPLITRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['finalize_bundle'].message_type = _FINALIZEBUNDLERESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['monitoring_infos'].message_type = _MONITORINGINFOSMETADATARESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['harness_monitoring_infos'].message_type = _HARNESSMONITORINGINFOSRESPONSE
_INSTRUCTIONRESPONSE.fields_by_name['register'].message_type = _REGISTERRESPONSE
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_progress'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'])
_INSTRUCTIONRESPONSE.fields_by_name['process_bundle_split'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['finalize_bundle'])
_INSTRUCTIONRESPONSE.fields_by_name['finalize_bundle'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['monitoring_infos'])
_INSTRUCTIONRESPONSE.fields_by_name['monitoring_infos'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['harness_monitoring_infos'])
_INSTRUCTIONRESPONSE.fields_by_name['harness_monitoring_infos'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_INSTRUCTIONRESPONSE.oneofs_by_name['response'].fields.append(
  _INSTRUCTIONRESPONSE.fields_by_name['register'])
_INSTRUCTIONRESPONSE.fields_by_name['register'].containing_oneof = _INSTRUCTIONRESPONSE.oneofs_by_name['response']
_HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY.containing_type = _HARNESSMONITORINGINFOSRESPONSE
_HARNESSMONITORINGINFOSRESPONSE.fields_by_name['monitoring_data'].message_type = _HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY
_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
_PROCESSBUNDLEDESCRIPTOR.fields_by_name['timer_api_service_descriptor'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY.fields_by_name['value'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY.containing_type = _BUNDLEAPPLICATION
_BUNDLEAPPLICATION.fields_by_name['output_watermarks'].message_type = _BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY
_BUNDLEAPPLICATION.fields_by_name['is_bounded'].enum_type = beam__runner__api__pb2._ISBOUNDED_ENUM
_DELAYEDBUNDLEAPPLICATION.fields_by_name['application'].message_type = _BUNDLEAPPLICATION
_DELAYEDBUNDLEAPPLICATION.fields_by_name['requested_time_delay'].message_type = google_dot_protobuf_dot_duration__pb2._DURATION
_PROCESSBUNDLEREQUEST_CACHETOKEN_USERSTATE.containing_type = _PROCESSBUNDLEREQUEST_CACHETOKEN
_PROCESSBUNDLEREQUEST_CACHETOKEN_SIDEINPUT.containing_type = _PROCESSBUNDLEREQUEST_CACHETOKEN
_PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['user_state'].message_type = _PROCESSBUNDLEREQUEST_CACHETOKEN_USERSTATE
_PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['side_input'].message_type = _PROCESSBUNDLEREQUEST_CACHETOKEN_SIDEINPUT
_PROCESSBUNDLEREQUEST_CACHETOKEN.containing_type = _PROCESSBUNDLEREQUEST
_PROCESSBUNDLEREQUEST_CACHETOKEN.oneofs_by_name['type'].fields.append(
  _PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['user_state'])
_PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['user_state'].containing_oneof = _PROCESSBUNDLEREQUEST_CACHETOKEN.oneofs_by_name['type']
_PROCESSBUNDLEREQUEST_CACHETOKEN.oneofs_by_name['type'].fields.append(
  _PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['side_input'])
_PROCESSBUNDLEREQUEST_CACHETOKEN.fields_by_name['side_input'].containing_oneof = _PROCESSBUNDLEREQUEST_CACHETOKEN.oneofs_by_name['type']
_PROCESSBUNDLEREQUEST.fields_by_name['cache_tokens'].message_type = _PROCESSBUNDLEREQUEST_CACHETOKEN
_PROCESSBUNDLEREQUEST.fields_by_name['elements'].message_type = _ELEMENTS
_PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY.containing_type = _PROCESSBUNDLERESPONSE
_PROCESSBUNDLERESPONSE.fields_by_name['residual_roots'].message_type = _DELAYEDBUNDLEAPPLICATION
_PROCESSBUNDLERESPONSE.fields_by_name['monitoring_infos'].message_type = metrics__pb2._MONITORINGINFO
_PROCESSBUNDLERESPONSE.fields_by_name['monitoring_data'].message_type = _PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY
_PROCESSBUNDLERESPONSE.fields_by_name['elements'].message_type = _ELEMENTS
_PROCESSBUNDLEPROGRESSRESPONSE_MONITORINGDATAENTRY.containing_type = _PROCESSBUNDLEPROGRESSRESPONSE
_PROCESSBUNDLEPROGRESSRESPONSE.fields_by_name['monitoring_infos'].message_type = metrics__pb2._MONITORINGINFO
_PROCESSBUNDLEPROGRESSRESPONSE.fields_by_name['monitoring_data'].message_type = _PROCESSBUNDLEPROGRESSRESPONSE_MONITORINGDATAENTRY
_MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY.fields_by_name['value'].message_type = metrics__pb2._MONITORINGINFO
_MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY.containing_type = _MONITORINGINFOSMETADATARESPONSE
_MONITORINGINFOSMETADATARESPONSE.fields_by_name['monitoring_info'].message_type = _MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT.containing_type = _PROCESSBUNDLESPLITREQUEST
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY.fields_by_name['value'].message_type = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLIT
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY.containing_type = _PROCESSBUNDLESPLITREQUEST
_PROCESSBUNDLESPLITREQUEST.fields_by_name['desired_splits'].message_type = _PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY
_PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT.containing_type = _PROCESSBUNDLESPLITRESPONSE
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['primary_roots'].message_type = _BUNDLEAPPLICATION
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['residual_roots'].message_type = _DELAYEDBUNDLEAPPLICATION
_PROCESSBUNDLESPLITRESPONSE.fields_by_name['channel_splits'].message_type = _PROCESSBUNDLESPLITRESPONSE_CHANNELSPLIT
_ELEMENTS_DATA.containing_type = _ELEMENTS
_ELEMENTS_TIMERS.containing_type = _ELEMENTS
_ELEMENTS.fields_by_name['data'].message_type = _ELEMENTS_DATA
_ELEMENTS.fields_by_name['timers'].message_type = _ELEMENTS_TIMERS
_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_ITERABLESIDEINPUT.containing_type = _STATEKEY
_STATEKEY_MULTIMAPSIDEINPUT.containing_type = _STATEKEY
_STATEKEY_MULTIMAPKEYSSIDEINPUT.containing_type = _STATEKEY
_STATEKEY_BAGUSERSTATE.containing_type = _STATEKEY
_STATEKEY_MULTIMAPKEYSUSERSTATE.containing_type = _STATEKEY
_STATEKEY_MULTIMAPUSERSTATE.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.fields_by_name['iterable_side_input'].message_type = _STATEKEY_ITERABLESIDEINPUT
_STATEKEY.fields_by_name['multimap_keys_side_input'].message_type = _STATEKEY_MULTIMAPKEYSSIDEINPUT
_STATEKEY.fields_by_name['multimap_keys_user_state'].message_type = _STATEKEY_MULTIMAPKEYSUSERSTATE
_STATEKEY.fields_by_name['multimap_user_state'].message_type = _STATEKEY_MULTIMAPUSERSTATE
_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']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['iterable_side_input'])
_STATEKEY.fields_by_name['iterable_side_input'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['multimap_keys_side_input'])
_STATEKEY.fields_by_name['multimap_keys_side_input'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['multimap_keys_user_state'])
_STATEKEY.fields_by_name['multimap_keys_user_state'].containing_oneof = _STATEKEY.oneofs_by_name['type']
_STATEKEY.oneofs_by_name['type'].fields.append(
  _STATEKEY.fields_by_name['multimap_user_state'])
_STATEKEY.fields_by_name['multimap_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
_STARTWORKERREQUEST_PARAMSENTRY.containing_type = _STARTWORKERREQUEST
_STARTWORKERREQUEST.fields_by_name['control_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_STARTWORKERREQUEST.fields_by_name['logging_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_STARTWORKERREQUEST.fields_by_name['artifact_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_STARTWORKERREQUEST.fields_by_name['provision_endpoint'].message_type = endpoints__pb2._APISERVICEDESCRIPTOR
_STARTWORKERREQUEST.fields_by_name['params'].message_type = _STARTWORKERREQUEST_PARAMSENTRY
DESCRIPTOR.message_types_by_name['RemoteGrpcPort'] = _REMOTEGRPCPORT
DESCRIPTOR.message_types_by_name['GetProcessBundleDescriptorRequest'] = _GETPROCESSBUNDLEDESCRIPTORREQUEST
DESCRIPTOR.message_types_by_name['InstructionRequest'] = _INSTRUCTIONREQUEST
DESCRIPTOR.message_types_by_name['InstructionResponse'] = _INSTRUCTIONRESPONSE
DESCRIPTOR.message_types_by_name['HarnessMonitoringInfosRequest'] = _HARNESSMONITORINGINFOSREQUEST
DESCRIPTOR.message_types_by_name['HarnessMonitoringInfosResponse'] = _HARNESSMONITORINGINFOSRESPONSE
DESCRIPTOR.message_types_by_name['RegisterRequest'] = _REGISTERREQUEST
DESCRIPTOR.message_types_by_name['RegisterResponse'] = _REGISTERRESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleDescriptor'] = _PROCESSBUNDLEDESCRIPTOR
DESCRIPTOR.message_types_by_name['BundleApplication'] = _BUNDLEAPPLICATION
DESCRIPTOR.message_types_by_name['DelayedBundleApplication'] = _DELAYEDBUNDLEAPPLICATION
DESCRIPTOR.message_types_by_name['ProcessBundleRequest'] = _PROCESSBUNDLEREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleResponse'] = _PROCESSBUNDLERESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleProgressRequest'] = _PROCESSBUNDLEPROGRESSREQUEST
DESCRIPTOR.message_types_by_name['MonitoringInfosMetadataRequest'] = _MONITORINGINFOSMETADATAREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleProgressResponse'] = _PROCESSBUNDLEPROGRESSRESPONSE
DESCRIPTOR.message_types_by_name['MonitoringInfosMetadataResponse'] = _MONITORINGINFOSMETADATARESPONSE
DESCRIPTOR.message_types_by_name['ProcessBundleSplitRequest'] = _PROCESSBUNDLESPLITREQUEST
DESCRIPTOR.message_types_by_name['ProcessBundleSplitResponse'] = _PROCESSBUNDLESPLITRESPONSE
DESCRIPTOR.message_types_by_name['FinalizeBundleRequest'] = _FINALIZEBUNDLEREQUEST
DESCRIPTOR.message_types_by_name['FinalizeBundleResponse'] = _FINALIZEBUNDLERESPONSE
DESCRIPTOR.message_types_by_name['Elements'] = _ELEMENTS
DESCRIPTOR.message_types_by_name['StateRequest'] = _STATEREQUEST
DESCRIPTOR.message_types_by_name['StateResponse'] = _STATERESPONSE
DESCRIPTOR.message_types_by_name['StateKey'] = _STATEKEY
DESCRIPTOR.message_types_by_name['StateGetRequest'] = _STATEGETREQUEST
DESCRIPTOR.message_types_by_name['StateGetResponse'] = _STATEGETRESPONSE
DESCRIPTOR.message_types_by_name['StateAppendRequest'] = _STATEAPPENDREQUEST
DESCRIPTOR.message_types_by_name['StateAppendResponse'] = _STATEAPPENDRESPONSE
DESCRIPTOR.message_types_by_name['StateClearRequest'] = _STATECLEARREQUEST
DESCRIPTOR.message_types_by_name['StateClearResponse'] = _STATECLEARRESPONSE
DESCRIPTOR.message_types_by_name['LogEntry'] = _LOGENTRY
DESCRIPTOR.message_types_by_name['LogControl'] = _LOGCONTROL
DESCRIPTOR.message_types_by_name['StartWorkerRequest'] = _STARTWORKERREQUEST
DESCRIPTOR.message_types_by_name['StartWorkerResponse'] = _STARTWORKERRESPONSE
DESCRIPTOR.message_types_by_name['StopWorkerRequest'] = _STOPWORKERREQUEST
DESCRIPTOR.message_types_by_name['StopWorkerResponse'] = _STOPWORKERRESPONSE
DESCRIPTOR.message_types_by_name['WorkerStatusRequest'] = _WORKERSTATUSREQUEST
DESCRIPTOR.message_types_by_name['WorkerStatusResponse'] = _WORKERSTATUSRESPONSE
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

RemoteGrpcPort = _reflection.GeneratedProtocolMessageType('RemoteGrpcPort', (_message.Message,), {
  'DESCRIPTOR' : _REMOTEGRPCPORT,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.RemoteGrpcPort)
  })
_sym_db.RegisterMessage(RemoteGrpcPort)

GetProcessBundleDescriptorRequest = _reflection.GeneratedProtocolMessageType('GetProcessBundleDescriptorRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETPROCESSBUNDLEDESCRIPTORREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.GetProcessBundleDescriptorRequest)
  })
_sym_db.RegisterMessage(GetProcessBundleDescriptorRequest)

InstructionRequest = _reflection.GeneratedProtocolMessageType('InstructionRequest', (_message.Message,), {
  '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,), {
  'DESCRIPTOR' : _INSTRUCTIONRESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.InstructionResponse)
  })
_sym_db.RegisterMessage(InstructionResponse)

HarnessMonitoringInfosRequest = _reflection.GeneratedProtocolMessageType('HarnessMonitoringInfosRequest', (_message.Message,), {
  'DESCRIPTOR' : _HARNESSMONITORINGINFOSREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosRequest)
  })
_sym_db.RegisterMessage(HarnessMonitoringInfosRequest)

HarnessMonitoringInfosResponse = _reflection.GeneratedProtocolMessageType('HarnessMonitoringInfosResponse', (_message.Message,), {

  'MonitoringDataEntry' : _reflection.GeneratedProtocolMessageType('MonitoringDataEntry', (_message.Message,), {
    'DESCRIPTOR' : _HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse.MonitoringDataEntry)
    })
  ,
  'DESCRIPTOR' : _HARNESSMONITORINGINFOSRESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.HarnessMonitoringInfosResponse)
  })
_sym_db.RegisterMessage(HarnessMonitoringInfosResponse)
_sym_db.RegisterMessage(HarnessMonitoringInfosResponse.MonitoringDataEntry)

RegisterRequest = _reflection.GeneratedProtocolMessageType('RegisterRequest', (_message.Message,), {
  '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,), {
  '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,), {

  'TransformsEntry' : _reflection.GeneratedProtocolMessageType('TransformsEntry', (_message.Message,), {
    '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,), {
    '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,), {
    '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,), {
    '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,), {
    'DESCRIPTOR' : _PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor.EnvironmentsEntry)
    })
  ,
  'DESCRIPTOR' : _PROCESSBUNDLEDESCRIPTOR,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleDescriptor)
  })
_sym_db.RegisterMessage(ProcessBundleDescriptor)
_sym_db.RegisterMessage(ProcessBundleDescriptor.TransformsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.PcollectionsEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.WindowingStrategiesEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.CodersEntry)
_sym_db.RegisterMessage(ProcessBundleDescriptor.EnvironmentsEntry)

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

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

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

ProcessBundleRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleRequest', (_message.Message,), {

  'CacheToken' : _reflection.GeneratedProtocolMessageType('CacheToken', (_message.Message,), {

    'UserState' : _reflection.GeneratedProtocolMessageType('UserState', (_message.Message,), {
      'DESCRIPTOR' : _PROCESSBUNDLEREQUEST_CACHETOKEN_USERSTATE,
      '__module__' : 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.UserState)
      })
    ,

    'SideInput' : _reflection.GeneratedProtocolMessageType('SideInput', (_message.Message,), {
      'DESCRIPTOR' : _PROCESSBUNDLEREQUEST_CACHETOKEN_SIDEINPUT,
      '__module__' : 'beam_fn_api_pb2'
      # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken.SideInput)
      })
    ,
    'DESCRIPTOR' : _PROCESSBUNDLEREQUEST_CACHETOKEN,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleRequest.CacheToken)
    })
  ,
  'DESCRIPTOR' : _PROCESSBUNDLEREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleRequest)
  })
_sym_db.RegisterMessage(ProcessBundleRequest)
_sym_db.RegisterMessage(ProcessBundleRequest.CacheToken)
_sym_db.RegisterMessage(ProcessBundleRequest.CacheToken.UserState)
_sym_db.RegisterMessage(ProcessBundleRequest.CacheToken.SideInput)

ProcessBundleResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleResponse', (_message.Message,), {

  'MonitoringDataEntry' : _reflection.GeneratedProtocolMessageType('MonitoringDataEntry', (_message.Message,), {
    'DESCRIPTOR' : _PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleResponse.MonitoringDataEntry)
    })
  ,
  'DESCRIPTOR' : _PROCESSBUNDLERESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleResponse)
  })
_sym_db.RegisterMessage(ProcessBundleResponse)
_sym_db.RegisterMessage(ProcessBundleResponse.MonitoringDataEntry)

ProcessBundleProgressRequest = _reflection.GeneratedProtocolMessageType('ProcessBundleProgressRequest', (_message.Message,), {
  'DESCRIPTOR' : _PROCESSBUNDLEPROGRESSREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.ProcessBundleProgressRequest)
  })
_sym_db.RegisterMessage(ProcessBundleProgressRequest)

MonitoringInfosMetadataRequest = _reflection.GeneratedProtocolMessageType('MonitoringInfosMetadataRequest', (_message.Message,), {
  'DESCRIPTOR' : _MONITORINGINFOSMETADATAREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataRequest)
  })
_sym_db.RegisterMessage(MonitoringInfosMetadataRequest)

ProcessBundleProgressResponse = _reflection.GeneratedProtocolMessageType('ProcessBundleProgressResponse', (_message.Message,), {

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

MonitoringInfosMetadataResponse = _reflection.GeneratedProtocolMessageType('MonitoringInfosMetadataResponse', (_message.Message,), {

  'MonitoringInfoEntry' : _reflection.GeneratedProtocolMessageType('MonitoringInfoEntry', (_message.Message,), {
    'DESCRIPTOR' : _MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse.MonitoringInfoEntry)
    })
  ,
  'DESCRIPTOR' : _MONITORINGINFOSMETADATARESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.MonitoringInfosMetadataResponse)
  })
_sym_db.RegisterMessage(MonitoringInfosMetadataResponse)
_sym_db.RegisterMessage(MonitoringInfosMetadataResponse.MonitoringInfoEntry)

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

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

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

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

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

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

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

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

  'Data' : _reflection.GeneratedProtocolMessageType('Data', (_message.Message,), {
    'DESCRIPTOR' : _ELEMENTS_DATA,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Elements.Data)
    })
  ,

  'Timers' : _reflection.GeneratedProtocolMessageType('Timers', (_message.Message,), {
    'DESCRIPTOR' : _ELEMENTS_TIMERS,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.Elements.Timers)
    })
  ,
  '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)
_sym_db.RegisterMessage(Elements.Timers)

StateRequest = _reflection.GeneratedProtocolMessageType('StateRequest', (_message.Message,), {
  '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,), {
  '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,), {

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

  'IterableSideInput' : _reflection.GeneratedProtocolMessageType('IterableSideInput', (_message.Message,), {
    'DESCRIPTOR' : _STATEKEY_ITERABLESIDEINPUT,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.IterableSideInput)
    })
  ,

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

  'MultimapKeysSideInput' : _reflection.GeneratedProtocolMessageType('MultimapKeysSideInput', (_message.Message,), {
    'DESCRIPTOR' : _STATEKEY_MULTIMAPKEYSSIDEINPUT,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysSideInput)
    })
  ,

  'BagUserState' : _reflection.GeneratedProtocolMessageType('BagUserState', (_message.Message,), {
    'DESCRIPTOR' : _STATEKEY_BAGUSERSTATE,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.BagUserState)
    })
  ,

  'MultimapKeysUserState' : _reflection.GeneratedProtocolMessageType('MultimapKeysUserState', (_message.Message,), {
    'DESCRIPTOR' : _STATEKEY_MULTIMAPKEYSUSERSTATE,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.MultimapKeysUserState)
    })
  ,

  'MultimapUserState' : _reflection.GeneratedProtocolMessageType('MultimapUserState', (_message.Message,), {
    'DESCRIPTOR' : _STATEKEY_MULTIMAPUSERSTATE,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StateKey.MultimapUserState)
    })
  ,
  '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.IterableSideInput)
_sym_db.RegisterMessage(StateKey.MultimapSideInput)
_sym_db.RegisterMessage(StateKey.MultimapKeysSideInput)
_sym_db.RegisterMessage(StateKey.BagUserState)
_sym_db.RegisterMessage(StateKey.MultimapKeysUserState)
_sym_db.RegisterMessage(StateKey.MultimapUserState)

StateGetRequest = _reflection.GeneratedProtocolMessageType('StateGetRequest', (_message.Message,), {
  '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,), {
  '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,), {
  '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,), {
  '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,), {
  '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,), {
  '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,), {

  'List' : _reflection.GeneratedProtocolMessageType('List', (_message.Message,), {
    '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,), {
    '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,), {
  'DESCRIPTOR' : _LOGCONTROL,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.LogControl)
  })
_sym_db.RegisterMessage(LogControl)

StartWorkerRequest = _reflection.GeneratedProtocolMessageType('StartWorkerRequest', (_message.Message,), {

  'ParamsEntry' : _reflection.GeneratedProtocolMessageType('ParamsEntry', (_message.Message,), {
    'DESCRIPTOR' : _STARTWORKERREQUEST_PARAMSENTRY,
    '__module__' : 'beam_fn_api_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StartWorkerRequest.ParamsEntry)
    })
  ,
  'DESCRIPTOR' : _STARTWORKERREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StartWorkerRequest)
  })
_sym_db.RegisterMessage(StartWorkerRequest)
_sym_db.RegisterMessage(StartWorkerRequest.ParamsEntry)

StartWorkerResponse = _reflection.GeneratedProtocolMessageType('StartWorkerResponse', (_message.Message,), {
  'DESCRIPTOR' : _STARTWORKERRESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StartWorkerResponse)
  })
_sym_db.RegisterMessage(StartWorkerResponse)

StopWorkerRequest = _reflection.GeneratedProtocolMessageType('StopWorkerRequest', (_message.Message,), {
  'DESCRIPTOR' : _STOPWORKERREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StopWorkerRequest)
  })
_sym_db.RegisterMessage(StopWorkerRequest)

StopWorkerResponse = _reflection.GeneratedProtocolMessageType('StopWorkerResponse', (_message.Message,), {
  'DESCRIPTOR' : _STOPWORKERRESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.StopWorkerResponse)
  })
_sym_db.RegisterMessage(StopWorkerResponse)

WorkerStatusRequest = _reflection.GeneratedProtocolMessageType('WorkerStatusRequest', (_message.Message,), {
  'DESCRIPTOR' : _WORKERSTATUSREQUEST,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.WorkerStatusRequest)
  })
_sym_db.RegisterMessage(WorkerStatusRequest)

WorkerStatusResponse = _reflection.GeneratedProtocolMessageType('WorkerStatusResponse', (_message.Message,), {
  'DESCRIPTOR' : _WORKERSTATUSRESPONSE,
  '__module__' : 'beam_fn_api_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.fn_execution.v1.WorkerStatusResponse)
  })
_sym_db.RegisterMessage(WorkerStatusResponse)


DESCRIPTOR._options = None
_HARNESSMONITORINGINFOSRESPONSE_MONITORINGDATAENTRY._options = None
_PROCESSBUNDLEDESCRIPTOR_TRANSFORMSENTRY._options = None
_PROCESSBUNDLEDESCRIPTOR_PCOLLECTIONSENTRY._options = None
_PROCESSBUNDLEDESCRIPTOR_WINDOWINGSTRATEGIESENTRY._options = None
_PROCESSBUNDLEDESCRIPTOR_CODERSENTRY._options = None
_PROCESSBUNDLEDESCRIPTOR_ENVIRONMENTSENTRY._options = None
_BUNDLEAPPLICATION_OUTPUTWATERMARKSENTRY._options = None
_PROCESSBUNDLERESPONSE_MONITORINGDATAENTRY._options = None
_PROCESSBUNDLEPROGRESSRESPONSE_MONITORINGDATAENTRY._options = None
_MONITORINGINFOSMETADATARESPONSE_MONITORINGINFOENTRY._options = None
_PROCESSBUNDLESPLITREQUEST_DESIREDSPLITSENTRY._options = None
_STARTWORKERREQUEST_PARAMSENTRY._options = None

_BEAMFNCONTROL = _descriptor.ServiceDescriptor(
  name='BeamFnControl',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnControl',
  file=DESCRIPTOR,
  index=0,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=10269,
  serialized_end=10592,
  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,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
  _descriptor.MethodDescriptor(
    name='GetProcessBundleDescriptor',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnControl.GetProcessBundleDescriptor',
    index=1,
    containing_service=None,
    input_type=_GETPROCESSBUNDLEDESCRIPTORREQUEST,
    output_type=_PROCESSBUNDLEDESCRIPTOR,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_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,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=10594,
  serialized_end=10718,
  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,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_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,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=10721,
  serialized_end=10856,
  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,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_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,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=10859,
  serialized_end=10996,
  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,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNLOGGING)

DESCRIPTOR.services_by_name['BeamFnLogging'] = _BEAMFNLOGGING


_BEAMFNEXTERNALWORKERPOOL = _descriptor.ServiceDescriptor(
  name='BeamFnExternalWorkerPool',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool',
  file=DESCRIPTOR,
  index=4,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=10999,
  serialized_end=11296,
  methods=[
  _descriptor.MethodDescriptor(
    name='StartWorker',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool.StartWorker',
    index=0,
    containing_service=None,
    input_type=_STARTWORKERREQUEST,
    output_type=_STARTWORKERRESPONSE,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
  _descriptor.MethodDescriptor(
    name='StopWorker',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool.StopWorker',
    index=1,
    containing_service=None,
    input_type=_STOPWORKERREQUEST,
    output_type=_STOPWORKERRESPONSE,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNEXTERNALWORKERPOOL)

DESCRIPTOR.services_by_name['BeamFnExternalWorkerPool'] = _BEAMFNEXTERNALWORKERPOOL


_BEAMFNWORKERSTATUS = _descriptor.ServiceDescriptor(
  name='BeamFnWorkerStatus',
  full_name='org.apache.beam.model.fn_execution.v1.BeamFnWorkerStatus',
  file=DESCRIPTOR,
  index=5,
  serialized_options=None,
  create_key=_descriptor._internal_create_key,
  serialized_start=11299,
  serialized_end=11463,
  methods=[
  _descriptor.MethodDescriptor(
    name='WorkerStatus',
    full_name='org.apache.beam.model.fn_execution.v1.BeamFnWorkerStatus.WorkerStatus',
    index=0,
    containing_service=None,
    input_type=_WORKERSTATUSRESPONSE,
    output_type=_WORKERSTATUSREQUEST,
    serialized_options=None,
    create_key=_descriptor._internal_create_key,
  ),
])
_sym_db.RegisterServiceDescriptor(_BEAMFNWORKERSTATUS)

DESCRIPTOR.services_by_name['BeamFnWorkerStatus'] = _BEAMFNWORKERSTATUS

# @@protoc_insertion_point(module_scope)
