# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: metrics.proto
"""Generated protocol buffer code."""
from __future__ import absolute_import
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 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


DESCRIPTOR = _descriptor.FileDescriptor(
  name='metrics.proto',
  package='org.apache.beam.model.pipeline.v1',
  syntax='proto3',
  serialized_options=b'\n!org.apache.beam.model.pipeline.v1B\nMetricsApiZEgithub.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1;pipeline_v1',
  create_key=_descriptor._internal_create_key,
  serialized_pb=b'\n\rmetrics.proto\x12!org.apache.beam.model.pipeline.v1\x1a\x15\x62\x65\x61m_runner_api.proto\x1a google/protobuf/descriptor.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\x8c\x01\n\x12MonitoringInfoSpec\x12\x0b\n\x03urn\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x17\n\x0frequired_labels\x18\x03 \x03(\t\x12\x42\n\x0b\x61nnotations\x18\x04 \x03(\x0b\x32-.org.apache.beam.model.pipeline.v1.Annotation\"(\n\nAnnotation\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\xd1#\n\x13MonitoringInfoSpecs\"\xb9#\n\x04\x45num\x12\xa7\x01\n\x0eUSER_SUM_INT64\x10\x00\x1a\x92\x01\xd2\xa7\xa7\x96\x06\x8b\x01\n\x1d\x62\x65\x61m:metric:user:sum_int64:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xaa\x01\n\x0fUSER_SUM_DOUBLE\x10\x01\x1a\x94\x01\xd2\xa7\xa7\x96\x06\x8d\x01\n\x1e\x62\x65\x61m:metric:user:sum_double:v1\x12\x1a\x62\x65\x61m:metrics:sum_double:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xc2\x01\n\x17USER_DISTRIBUTION_INT64\x10\x02\x1a\xa4\x01\xd2\xa7\xa7\x96\x06\x9d\x01\n&beam:metric:user:distribution_int64:v1\x12\"beam:metrics:distribution_int64:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xc5\x01\n\x18USER_DISTRIBUTION_DOUBLE\x10\x03\x1a\xa6\x01\xd2\xa7\xa7\x96\x06\x9f\x01\n\'beam:metric:user:distribution_double:v1\x12#beam:metrics:distribution_double:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xb0\x01\n\x11USER_LATEST_INT64\x10\x04\x1a\x98\x01\xd2\xa7\xa7\x96\x06\x91\x01\n beam:metric:user:latest_int64:v1\x12\x1c\x62\x65\x61m:metrics:latest_int64:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xb3\x01\n\x12USER_LATEST_DOUBLE\x10\x05\x1a\x9a\x01\xd2\xa7\xa7\x96\x06\x93\x01\n!beam:metric:user:latest_double:v1\x12\x1d\x62\x65\x61m:metrics:latest_double:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xad\x01\n\x10USER_TOP_N_INT64\x10\x06\x1a\x96\x01\xd2\xa7\xa7\x96\x06\x8f\x01\n\x1f\x62\x65\x61m:metric:user:top_n_int64:v1\x12\x1b\x62\x65\x61m:metrics:top_n_int64:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xb0\x01\n\x11USER_TOP_N_DOUBLE\x10\x07\x1a\x98\x01\xd2\xa7\xa7\x96\x06\x91\x01\n beam:metric:user:top_n_double:v1\x12\x1c\x62\x65\x61m:metrics:top_n_double:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xb6\x01\n\x13USER_BOTTOM_N_INT64\x10\x08\x1a\x9c\x01\xd2\xa7\xa7\x96\x06\x95\x01\n\"beam:metric:user:bottom_n_int64:v1\x12\x1e\x62\x65\x61m:metrics:bottom_n_int64:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xb9\x01\n\x14USER_BOTTOM_N_DOUBLE\x10\t\x1a\x9e\x01\xd2\xa7\xa7\x96\x06\x97\x01\n#beam:metric:user:bottom_n_double:v1\x12\x1f\x62\x65\x61m:metrics:bottom_n_double:v1\x1a\nPTRANSFORM\x1a\tNAMESPACE\x1a\x04NAME\"2\n\x0b\x64\x65scription\x12#URN utilized to report user metric.\x12\xad\x01\n\rELEMENT_COUNT\x10\n\x1a\x99\x01\xd2\xa7\xa7\x96\x06\x92\x01\n\x1c\x62\x65\x61m:metric:element_count:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\x0bPCOLLECTION\"J\n\x0b\x64\x65scription\x12;The total elements output to a Pcollection by a PTransform.\x12\xcd\x02\n\x11SAMPLED_BYTE_SIZE\x10\x0b\x1a\xb5\x02\xd2\xa7\xa7\x96\x06\xae\x02\n beam:metric:sampled_byte_size:v1\x12\"beam:metrics:distribution_int64:v1\x1a\x0bPCOLLECTION\"\xd8\x01\n\x0b\x64\x65scription\x12\xc8\x01The total byte size and count of a sampled  set (or all) of elements in the pcollection. Sampling is used  because calculating the byte count involves serializing the  elements which is CPU intensive.\x12\xd9\x01\n\x12START_BUNDLE_MSECS\x10\x0c\x1a\xc0\x01\xd2\xa7\xa7\x96\x06\xb9\x01\n6beam:metric:pardo_execution_time:start_bundle_msecs:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\"X\n\x0b\x64\x65scription\x12IThe total estimated execution time of the start bundlefunction in a pardo\x12\xdf\x01\n\x14PROCESS_BUNDLE_MSECS\x10\r\x1a\xc4\x01\xd2\xa7\xa7\x96\x06\xbd\x01\n8beam:metric:pardo_execution_time:process_bundle_msecs:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\"Z\n\x0b\x64\x65scription\x12KThe total estimated execution time of the process bundlefunction in a pardo\x12\xdd\x01\n\x13\x46INISH_BUNDLE_MSECS\x10\x0e\x1a\xc3\x01\xd2\xa7\xa7\x96\x06\xbc\x01\n7beam:metric:pardo_execution_time:finish_bundle_msecs:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\"Z\n\x0b\x64\x65scription\x12KThe total estimated execution time of the finish bundle function in a pardo\x12\xbb\x01\n\x0bTOTAL_MSECS\x10\x0f\x1a\xa9\x01\xd2\xa7\xa7\x96\x06\xa2\x01\n4beam:metric:ptransform_execution_time:total_msecs:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\"C\n\x0b\x64\x65scription\x12\x34The total estimated execution time of the ptransform\x12\x9f\x02\n\x0eWORK_REMAINING\x10\x10\x1a\x8a\x02\xd2\xa7\xa7\x96\x06\x83\x02\n,beam:metric:ptransform_progress:remaining:v1\x12\x18\x62\x65\x61m:metrics:progress:v1\x1a\nPTRANSFORM\"\xac\x01\n\x0b\x64\x65scription\x12\x9c\x01The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element.\x12\x9f\x02\n\x0eWORK_COMPLETED\x10\x11\x1a\x8a\x02\xd2\xa7\xa7\x96\x06\x83\x02\n,beam:metric:ptransform_progress:completed:v1\x12\x18\x62\x65\x61m:metrics:progress:v1\x1a\nPTRANSFORM\"\xac\x01\n\x0b\x64\x65scription\x12\x9c\x01The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element.\x12\xa8\x01\n\x17\x44\x41TA_CHANNEL_READ_INDEX\x10\x12\x1a\x8a\x01\xd2\xa7\xa7\x96\x06\x83\x01\n&beam:metric:data_channel:read_index:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\nPTRANSFORM\"2\n\x0b\x64\x65scription\x12#The read index of the data channel.\x12\x8a\x02\n\x11\x41PI_REQUEST_COUNT\x10\x13\x1a\xf2\x01\xd2\xa7\xa7\x96\x06\xeb\x01\n#beam:metric:io:api_request_count:v1\x12\x19\x62\x65\x61m:metrics:sum_int64:v1\x1a\x07SERVICE\x1a\x06METHOD\x1a\x08RESOURCE\x1a\nPTRANSFORM\x1a\x06STATUS\"b\n\x0b\x64\x65scription\x12SRequest counts with status made to IO service APIs to batch read or write elements.\"\x16\n\x0eprocess_metric\x12\x04true\x12\xb3\x02\n\x15\x41PI_REQUEST_LATENCIES\x10\x14\x1a\x97\x02\xd2\xa7\xa7\x96\x06\x90\x02\n\'beam:metric:io:api_request_latencies:v1\x12\x1f\x62\x65\x61m:metrics:histogram_int64:v1\x1a\x07SERVICE\x1a\x06METHOD\x1a\x08RESOURCE\x1a\nPTRANSFORM\"n\n\x0b\x64\x65scription\x12_Histogram counts for request latencies made to IO service APIs to batch read or write elements.\"\x15\n\x05units\x12\x0cMilliseconds\"\x16\n\x0eprocess_metric\x12\x04true\"(\n\x18MonitoringInfoLabelProps\x12\x0c\n\x04name\x18\x01 \x01(\t\"\xb2\x07\n\x0eMonitoringInfo\x12\x0b\n\x03urn\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x0f\n\x07payload\x18\x03 \x01(\x0c\x12M\n\x06labels\x18\x04 \x03(\x0b\x32=.org.apache.beam.model.pipeline.v1.MonitoringInfo.LabelsEntry\x12.\n\nstart_time\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a-\n\x0bLabelsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xc5\x05\n\x14MonitoringInfoLabels\x12!\n\tTRANSFORM\x10\x00\x1a\x12\xa2\xd4\xe0\xe5\x03\x0c\n\nPTRANSFORM\x12$\n\x0bPCOLLECTION\x10\x01\x1a\x13\xa2\xd4\xe0\xe5\x03\r\n\x0bPCOLLECTION\x12\x32\n\x12WINDOWING_STRATEGY\x10\x02\x1a\x1a\xa2\xd4\xe0\xe5\x03\x14\n\x12WINDOWING_STRATEGY\x12\x18\n\x05\x43ODER\x10\x03\x1a\r\xa2\xd4\xe0\xe5\x03\x07\n\x05\x43ODER\x12$\n\x0b\x45NVIRONMENT\x10\x04\x1a\x13\xa2\xd4\xe0\xe5\x03\r\n\x0b\x45NVIRONMENT\x12 \n\tNAMESPACE\x10\x05\x1a\x11\xa2\xd4\xe0\xe5\x03\x0b\n\tNAMESPACE\x12\x16\n\x04NAME\x10\x06\x1a\x0c\xa2\xd4\xe0\xe5\x03\x06\n\x04NAME\x12\x1c\n\x07SERVICE\x10\x07\x1a\x0f\xa2\xd4\xe0\xe5\x03\t\n\x07SERVICE\x12\x1a\n\x06METHOD\x10\x08\x1a\x0e\xa2\xd4\xe0\xe5\x03\x08\n\x06METHOD\x12\x1e\n\x08RESOURCE\x10\t\x1a\x10\xa2\xd4\xe0\xe5\x03\n\n\x08RESOURCE\x12\x1a\n\x06STATUS\x10\n\x1a\x0e\xa2\xd4\xe0\xe5\x03\x08\n\x06STATUS\x12\x34\n\x13\x42IGQUERY_PROJECT_ID\x10\x0b\x1a\x1b\xa2\xd4\xe0\xe5\x03\x15\n\x13\x42IGQUERY_PROJECT_ID\x12.\n\x10\x42IGQUERY_DATASET\x10\x0c\x1a\x18\xa2\xd4\xe0\xe5\x03\x12\n\x10\x42IGQUERY_DATASET\x12*\n\x0e\x42IGQUERY_TABLE\x10\r\x1a\x16\xa2\xd4\xe0\xe5\x03\x10\n\x0e\x42IGQUERY_TABLE\x12(\n\rBIGQUERY_VIEW\x10\x0e\x1a\x15\xa2\xd4\xe0\xe5\x03\x0f\n\rBIGQUERY_VIEW\x12\x34\n\x13\x42IGQUERY_QUERY_NAME\x10\x0f\x1a\x1b\xa2\xd4\xe0\xe5\x03\x15\n\x13\x42IGQUERY_QUERY_NAME\x12\"\n\nGCS_BUCKET\x10\x10\x1a\x12\xa2\xd4\xe0\xe5\x03\x0c\n\nGCS_BUCKET\x12*\n\x0eGCS_PROJECT_ID\x10\x11\x1a\x16\xa2\xd4\xe0\xe5\x03\x10\n\x0eGCS_PROJECT_ID\"\xbc\x05\n\x16MonitoringInfoTypeUrns\"\xa1\x05\n\x04\x45num\x12\x33\n\x0eSUM_INT64_TYPE\x10\x00\x1a\x1f\xa2\xb4\xfa\xc2\x05\x19\x62\x65\x61m:metrics:sum_int64:v1\x12\x35\n\x0fSUM_DOUBLE_TYPE\x10\x01\x1a \xa2\xb4\xfa\xc2\x05\x1a\x62\x65\x61m:metrics:sum_double:v1\x12\x45\n\x17\x44ISTRIBUTION_INT64_TYPE\x10\x02\x1a(\xa2\xb4\xfa\xc2\x05\"beam:metrics:distribution_int64:v1\x12G\n\x18\x44ISTRIBUTION_DOUBLE_TYPE\x10\x03\x1a)\xa2\xb4\xfa\xc2\x05#beam:metrics:distribution_double:v1\x12\x39\n\x11LATEST_INT64_TYPE\x10\x04\x1a\"\xa2\xb4\xfa\xc2\x05\x1c\x62\x65\x61m:metrics:latest_int64:v1\x12;\n\x12LATEST_DOUBLE_TYPE\x10\x05\x1a#\xa2\xb4\xfa\xc2\x05\x1d\x62\x65\x61m:metrics:latest_double:v1\x12\x37\n\x10TOP_N_INT64_TYPE\x10\x06\x1a!\xa2\xb4\xfa\xc2\x05\x1b\x62\x65\x61m:metrics:top_n_int64:v1\x12\x39\n\x11TOP_N_DOUBLE_TYPE\x10\x07\x1a\"\xa2\xb4\xfa\xc2\x05\x1c\x62\x65\x61m:metrics:top_n_double:v1\x12=\n\x13\x42OTTOM_N_INT64_TYPE\x10\x08\x1a$\xa2\xb4\xfa\xc2\x05\x1e\x62\x65\x61m:metrics:bottom_n_int64:v1\x12?\n\x14\x42OTTOM_N_DOUBLE_TYPE\x10\t\x1a%\xa2\xb4\xfa\xc2\x05\x1f\x62\x65\x61m:metrics:bottom_n_double:v1\x12\x31\n\rPROGRESS_TYPE\x10\n\x1a\x1e\xa2\xb4\xfa\xc2\x05\x18\x62\x65\x61m:metrics:progress:v1:v\n\x0blabel_props\x12!.google.protobuf.EnumValueOptions\x18\xc4\x8a\xdc< \x01(\x0b\x32;.org.apache.beam.model.pipeline.v1.MonitoringInfoLabelProps:y\n\x14monitoring_info_spec\x12!.google.protobuf.EnumValueOptions\x18\xfa\xf4\xe4\x62 \x01(\x0b\x32\x35.org.apache.beam.model.pipeline.v1.MonitoringInfoSpecBv\n!org.apache.beam.model.pipeline.v1B\nMetricsApiZEgithub.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1;pipeline_v1b\x06proto3'
  ,
  dependencies=[beam__runner__api__pb2.DESCRIPTOR,google_dot_protobuf_dot_descriptor__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,])


LABEL_PROPS_FIELD_NUMBER = 127337796
label_props = _descriptor.FieldDescriptor(
  name='label_props', full_name='org.apache.beam.model.pipeline.v1.label_props', index=0,
  number=127337796, 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=True, extension_scope=None,
  serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key)
MONITORING_INFO_SPEC_FIELD_NUMBER = 207174266
monitoring_info_spec = _descriptor.FieldDescriptor(
  name='monitoring_info_spec', full_name='org.apache.beam.model.pipeline.v1.monitoring_info_spec', index=1,
  number=207174266, 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=True, extension_scope=None,
  serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key)

_MONITORINGINFOSPECS_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpecs.Enum',
  filename=None,
  file=DESCRIPTOR,
  create_key=_descriptor._internal_create_key,
  values=[
    _descriptor.EnumValueDescriptor(
      name='USER_SUM_INT64', index=0, number=0,
      serialized_options=b'\322\247\247\226\006\213\001\n\035beam:metric:user:sum_int64:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_SUM_DOUBLE', index=1, number=1,
      serialized_options=b'\322\247\247\226\006\215\001\n\036beam:metric:user:sum_double:v1\022\032beam:metrics:sum_double:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_DISTRIBUTION_INT64', index=2, number=2,
      serialized_options=b'\322\247\247\226\006\235\001\n&beam:metric:user:distribution_int64:v1\022\"beam:metrics:distribution_int64:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_DISTRIBUTION_DOUBLE', index=3, number=3,
      serialized_options=b'\322\247\247\226\006\237\001\n\'beam:metric:user:distribution_double:v1\022#beam:metrics:distribution_double:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_LATEST_INT64', index=4, number=4,
      serialized_options=b'\322\247\247\226\006\221\001\n beam:metric:user:latest_int64:v1\022\034beam:metrics:latest_int64:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_LATEST_DOUBLE', index=5, number=5,
      serialized_options=b'\322\247\247\226\006\223\001\n!beam:metric:user:latest_double:v1\022\035beam:metrics:latest_double:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_TOP_N_INT64', index=6, number=6,
      serialized_options=b'\322\247\247\226\006\217\001\n\037beam:metric:user:top_n_int64:v1\022\033beam:metrics:top_n_int64:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_TOP_N_DOUBLE', index=7, number=7,
      serialized_options=b'\322\247\247\226\006\221\001\n beam:metric:user:top_n_double:v1\022\034beam:metrics:top_n_double:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_BOTTOM_N_INT64', index=8, number=8,
      serialized_options=b'\322\247\247\226\006\225\001\n\"beam:metric:user:bottom_n_int64:v1\022\036beam:metrics:bottom_n_int64:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='USER_BOTTOM_N_DOUBLE', index=9, number=9,
      serialized_options=b'\322\247\247\226\006\227\001\n#beam:metric:user:bottom_n_double:v1\022\037beam:metrics:bottom_n_double:v1\032\nPTRANSFORM\032\tNAMESPACE\032\004NAME\"2\n\013description\022#URN utilized to report user metric.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='ELEMENT_COUNT', index=10, number=10,
      serialized_options=b'\322\247\247\226\006\222\001\n\034beam:metric:element_count:v1\022\031beam:metrics:sum_int64:v1\032\013PCOLLECTION\"J\n\013description\022;The total elements output to a Pcollection by a PTransform.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='SAMPLED_BYTE_SIZE', index=11, number=11,
      serialized_options=b'\322\247\247\226\006\256\002\n beam:metric:sampled_byte_size:v1\022\"beam:metrics:distribution_int64:v1\032\013PCOLLECTION\"\330\001\n\013description\022\310\001The total byte size and count of a sampled  set (or all) of elements in the pcollection. Sampling is used  because calculating the byte count involves serializing the  elements which is CPU intensive.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='START_BUNDLE_MSECS', index=12, number=12,
      serialized_options=b'\322\247\247\226\006\271\001\n6beam:metric:pardo_execution_time:start_bundle_msecs:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\"X\n\013description\022IThe total estimated execution time of the start bundlefunction in a pardo',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='PROCESS_BUNDLE_MSECS', index=13, number=13,
      serialized_options=b'\322\247\247\226\006\275\001\n8beam:metric:pardo_execution_time:process_bundle_msecs:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\"Z\n\013description\022KThe total estimated execution time of the process bundlefunction in a pardo',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='FINISH_BUNDLE_MSECS', index=14, number=14,
      serialized_options=b'\322\247\247\226\006\274\001\n7beam:metric:pardo_execution_time:finish_bundle_msecs:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\"Z\n\013description\022KThe total estimated execution time of the finish bundle function in a pardo',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='TOTAL_MSECS', index=15, number=15,
      serialized_options=b'\322\247\247\226\006\242\001\n4beam:metric:ptransform_execution_time:total_msecs:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\"C\n\013description\0224The total estimated execution time of the ptransform',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='WORK_REMAINING', index=16, number=16,
      serialized_options=b'\322\247\247\226\006\203\002\n,beam:metric:ptransform_progress:remaining:v1\022\030beam:metrics:progress:v1\032\nPTRANSFORM\"\254\001\n\013description\022\234\001The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='WORK_COMPLETED', index=17, number=17,
      serialized_options=b'\322\247\247\226\006\203\002\n,beam:metric:ptransform_progress:completed:v1\022\030beam:metrics:progress:v1\032\nPTRANSFORM\"\254\001\n\013description\022\234\001The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='DATA_CHANNEL_READ_INDEX', index=18, number=18,
      serialized_options=b'\322\247\247\226\006\203\001\n&beam:metric:data_channel:read_index:v1\022\031beam:metrics:sum_int64:v1\032\nPTRANSFORM\"2\n\013description\022#The read index of the data channel.',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='API_REQUEST_COUNT', index=19, number=19,
      serialized_options=b'\322\247\247\226\006\353\001\n#beam:metric:io:api_request_count:v1\022\031beam:metrics:sum_int64:v1\032\007SERVICE\032\006METHOD\032\010RESOURCE\032\nPTRANSFORM\032\006STATUS\"b\n\013description\022SRequest counts with status made to IO service APIs to batch read or write elements.\"\026\n\016process_metric\022\004true',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='API_REQUEST_LATENCIES', index=20, number=20,
      serialized_options=b'\322\247\247\226\006\220\002\n\'beam:metric:io:api_request_latencies:v1\022\037beam:metrics:histogram_int64:v1\032\007SERVICE\032\006METHOD\032\010RESOURCE\032\nPTRANSFORM\"n\n\013description\022_Histogram counts for request latencies made to IO service APIs to batch read or write elements.\"\025\n\005units\022\014Milliseconds\"\026\n\016process_metric\022\004true',
      type=None,
      create_key=_descriptor._internal_create_key),
  ],
  containing_type=None,
  serialized_options=None,
  serialized_start=352,
  serialized_end=4889,
)
_sym_db.RegisterEnumDescriptor(_MONITORINGINFOSPECS_ENUM)

_MONITORINGINFO_MONITORINGINFOLABELS = _descriptor.EnumDescriptor(
  name='MonitoringInfoLabels',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.MonitoringInfoLabels',
  filename=None,
  file=DESCRIPTOR,
  create_key=_descriptor._internal_create_key,
  values=[
    _descriptor.EnumValueDescriptor(
      name='TRANSFORM', index=0, number=0,
      serialized_options=b'\242\324\340\345\003\014\n\nPTRANSFORM',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='PCOLLECTION', index=1, number=1,
      serialized_options=b'\242\324\340\345\003\r\n\013PCOLLECTION',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='WINDOWING_STRATEGY', index=2, number=2,
      serialized_options=b'\242\324\340\345\003\024\n\022WINDOWING_STRATEGY',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='CODER', index=3, number=3,
      serialized_options=b'\242\324\340\345\003\007\n\005CODER',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='ENVIRONMENT', index=4, number=4,
      serialized_options=b'\242\324\340\345\003\r\n\013ENVIRONMENT',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='NAMESPACE', index=5, number=5,
      serialized_options=b'\242\324\340\345\003\013\n\tNAMESPACE',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='NAME', index=6, number=6,
      serialized_options=b'\242\324\340\345\003\006\n\004NAME',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='SERVICE', index=7, number=7,
      serialized_options=b'\242\324\340\345\003\t\n\007SERVICE',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='METHOD', index=8, number=8,
      serialized_options=b'\242\324\340\345\003\010\n\006METHOD',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='RESOURCE', index=9, number=9,
      serialized_options=b'\242\324\340\345\003\n\n\010RESOURCE',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='STATUS', index=10, number=10,
      serialized_options=b'\242\324\340\345\003\010\n\006STATUS',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BIGQUERY_PROJECT_ID', index=11, number=11,
      serialized_options=b'\242\324\340\345\003\025\n\023BIGQUERY_PROJECT_ID',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BIGQUERY_DATASET', index=12, number=12,
      serialized_options=b'\242\324\340\345\003\022\n\020BIGQUERY_DATASET',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BIGQUERY_TABLE', index=13, number=13,
      serialized_options=b'\242\324\340\345\003\020\n\016BIGQUERY_TABLE',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BIGQUERY_VIEW', index=14, number=14,
      serialized_options=b'\242\324\340\345\003\017\n\rBIGQUERY_VIEW',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BIGQUERY_QUERY_NAME', index=15, number=15,
      serialized_options=b'\242\324\340\345\003\025\n\023BIGQUERY_QUERY_NAME',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='GCS_BUCKET', index=16, number=16,
      serialized_options=b'\242\324\340\345\003\014\n\nGCS_BUCKET',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='GCS_PROJECT_ID', index=17, number=17,
      serialized_options=b'\242\324\340\345\003\020\n\016GCS_PROJECT_ID',
      type=None,
      create_key=_descriptor._internal_create_key),
  ],
  containing_type=None,
  serialized_options=None,
  serialized_start=5171,
  serialized_end=5880,
)
_sym_db.RegisterEnumDescriptor(_MONITORINGINFO_MONITORINGINFOLABELS)

_MONITORINGINFOTYPEURNS_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoTypeUrns.Enum',
  filename=None,
  file=DESCRIPTOR,
  create_key=_descriptor._internal_create_key,
  values=[
    _descriptor.EnumValueDescriptor(
      name='SUM_INT64_TYPE', index=0, number=0,
      serialized_options=b'\242\264\372\302\005\031beam:metrics:sum_int64:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='SUM_DOUBLE_TYPE', index=1, number=1,
      serialized_options=b'\242\264\372\302\005\032beam:metrics:sum_double:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='DISTRIBUTION_INT64_TYPE', index=2, number=2,
      serialized_options=b'\242\264\372\302\005\"beam:metrics:distribution_int64:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='DISTRIBUTION_DOUBLE_TYPE', index=3, number=3,
      serialized_options=b'\242\264\372\302\005#beam:metrics:distribution_double:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='LATEST_INT64_TYPE', index=4, number=4,
      serialized_options=b'\242\264\372\302\005\034beam:metrics:latest_int64:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='LATEST_DOUBLE_TYPE', index=5, number=5,
      serialized_options=b'\242\264\372\302\005\035beam:metrics:latest_double:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='TOP_N_INT64_TYPE', index=6, number=6,
      serialized_options=b'\242\264\372\302\005\033beam:metrics:top_n_int64:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='TOP_N_DOUBLE_TYPE', index=7, number=7,
      serialized_options=b'\242\264\372\302\005\034beam:metrics:top_n_double:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BOTTOM_N_INT64_TYPE', index=8, number=8,
      serialized_options=b'\242\264\372\302\005\036beam:metrics:bottom_n_int64:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='BOTTOM_N_DOUBLE_TYPE', index=9, number=9,
      serialized_options=b'\242\264\372\302\005\037beam:metrics:bottom_n_double:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
    _descriptor.EnumValueDescriptor(
      name='PROGRESS_TYPE', index=10, number=10,
      serialized_options=b'\242\264\372\302\005\030beam:metrics:progress:v1',
      type=None,
      create_key=_descriptor._internal_create_key),
  ],
  containing_type=None,
  serialized_options=None,
  serialized_start=5910,
  serialized_end=6583,
)
_sym_db.RegisterEnumDescriptor(_MONITORINGINFOTYPEURNS_ENUM)


_MONITORINGINFOSPEC = _descriptor.Descriptor(
  name='MonitoringInfoSpec',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpec',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='urn', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpec.urn', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='type', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpec.type', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='required_labels', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpec.required_labels', index=2,
      number=3, 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),
    _descriptor.FieldDescriptor(
      name='annotations', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpec.annotations', 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),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=143,
  serialized_end=283,
)


_ANNOTATION = _descriptor.Descriptor(
  name='Annotation',
  full_name='org.apache.beam.model.pipeline.v1.Annotation',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.pipeline.v1.Annotation.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.pipeline.v1.Annotation.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=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=285,
  serialized_end=325,
)


_MONITORINGINFOSPECS = _descriptor.Descriptor(
  name='MonitoringInfoSpecs',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoSpecs',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
    _MONITORINGINFOSPECS_ENUM,
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=328,
  serialized_end=4889,
)


_MONITORINGINFOLABELPROPS = _descriptor.Descriptor(
  name='MonitoringInfoLabelProps',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoLabelProps',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='name', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfoLabelProps.name', 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=4891,
  serialized_end=4931,
)


_MONITORINGINFO_LABELSENTRY = _descriptor.Descriptor(
  name='LabelsEntry',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.LabelsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.LabelsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='value', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.LabelsEntry.value', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      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=5123,
  serialized_end=5168,
)

_MONITORINGINFO = _descriptor.Descriptor(
  name='MonitoringInfo',
  full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='urn', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.urn', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='type', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.type', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='payload', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.payload', 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='labels', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.labels', 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='start_time', full_name='org.apache.beam.model.pipeline.v1.MonitoringInfo.start_time', 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),
  ],
  extensions=[
  ],
  nested_types=[_MONITORINGINFO_LABELSENTRY, ],
  enum_types=[
    _MONITORINGINFO_MONITORINGINFOLABELS,
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=4934,
  serialized_end=5880,
)


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

_MONITORINGINFOSPEC.fields_by_name['annotations'].message_type = _ANNOTATION
_MONITORINGINFOSPECS_ENUM.containing_type = _MONITORINGINFOSPECS
_MONITORINGINFO_LABELSENTRY.containing_type = _MONITORINGINFO
_MONITORINGINFO.fields_by_name['labels'].message_type = _MONITORINGINFO_LABELSENTRY
_MONITORINGINFO.fields_by_name['start_time'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_MONITORINGINFO_MONITORINGINFOLABELS.containing_type = _MONITORINGINFO
_MONITORINGINFOTYPEURNS_ENUM.containing_type = _MONITORINGINFOTYPEURNS
DESCRIPTOR.message_types_by_name['MonitoringInfoSpec'] = _MONITORINGINFOSPEC
DESCRIPTOR.message_types_by_name['Annotation'] = _ANNOTATION
DESCRIPTOR.message_types_by_name['MonitoringInfoSpecs'] = _MONITORINGINFOSPECS
DESCRIPTOR.message_types_by_name['MonitoringInfoLabelProps'] = _MONITORINGINFOLABELPROPS
DESCRIPTOR.message_types_by_name['MonitoringInfo'] = _MONITORINGINFO
DESCRIPTOR.message_types_by_name['MonitoringInfoTypeUrns'] = _MONITORINGINFOTYPEURNS
DESCRIPTOR.extensions_by_name['label_props'] = label_props
DESCRIPTOR.extensions_by_name['monitoring_info_spec'] = monitoring_info_spec
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

MonitoringInfoSpec = _reflection.GeneratedProtocolMessageType('MonitoringInfoSpec', (_message.Message,), {
  'DESCRIPTOR' : _MONITORINGINFOSPEC,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfoSpec)
  })
_sym_db.RegisterMessage(MonitoringInfoSpec)

Annotation = _reflection.GeneratedProtocolMessageType('Annotation', (_message.Message,), {
  'DESCRIPTOR' : _ANNOTATION,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.Annotation)
  })
_sym_db.RegisterMessage(Annotation)

MonitoringInfoSpecs = _reflection.GeneratedProtocolMessageType('MonitoringInfoSpecs', (_message.Message,), {
  'DESCRIPTOR' : _MONITORINGINFOSPECS,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfoSpecs)
  })
_sym_db.RegisterMessage(MonitoringInfoSpecs)

MonitoringInfoLabelProps = _reflection.GeneratedProtocolMessageType('MonitoringInfoLabelProps', (_message.Message,), {
  'DESCRIPTOR' : _MONITORINGINFOLABELPROPS,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfoLabelProps)
  })
_sym_db.RegisterMessage(MonitoringInfoLabelProps)

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

  'LabelsEntry' : _reflection.GeneratedProtocolMessageType('LabelsEntry', (_message.Message,), {
    'DESCRIPTOR' : _MONITORINGINFO_LABELSENTRY,
    '__module__' : 'metrics_pb2'
    # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfo.LabelsEntry)
    })
  ,
  'DESCRIPTOR' : _MONITORINGINFO,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfo)
  })
_sym_db.RegisterMessage(MonitoringInfo)
_sym_db.RegisterMessage(MonitoringInfo.LabelsEntry)

MonitoringInfoTypeUrns = _reflection.GeneratedProtocolMessageType('MonitoringInfoTypeUrns', (_message.Message,), {
  'DESCRIPTOR' : _MONITORINGINFOTYPEURNS,
  '__module__' : 'metrics_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MonitoringInfoTypeUrns)
  })
_sym_db.RegisterMessage(MonitoringInfoTypeUrns)

label_props.message_type = _MONITORINGINFOLABELPROPS
google_dot_protobuf_dot_descriptor__pb2.EnumValueOptions.RegisterExtension(label_props)
monitoring_info_spec.message_type = _MONITORINGINFOSPEC
google_dot_protobuf_dot_descriptor__pb2.EnumValueOptions.RegisterExtension(monitoring_info_spec)

DESCRIPTOR._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_SUM_INT64"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_SUM_DOUBLE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_DISTRIBUTION_INT64"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_DISTRIBUTION_DOUBLE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_LATEST_INT64"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_LATEST_DOUBLE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_TOP_N_INT64"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_TOP_N_DOUBLE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_BOTTOM_N_INT64"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["USER_BOTTOM_N_DOUBLE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["ELEMENT_COUNT"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["SAMPLED_BYTE_SIZE"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["START_BUNDLE_MSECS"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["PROCESS_BUNDLE_MSECS"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["FINISH_BUNDLE_MSECS"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["TOTAL_MSECS"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["WORK_REMAINING"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["WORK_COMPLETED"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["DATA_CHANNEL_READ_INDEX"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["API_REQUEST_COUNT"]._options = None
_MONITORINGINFOSPECS_ENUM.values_by_name["API_REQUEST_LATENCIES"]._options = None
_MONITORINGINFO_LABELSENTRY._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["TRANSFORM"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["PCOLLECTION"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["WINDOWING_STRATEGY"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["CODER"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["ENVIRONMENT"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["NAMESPACE"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["NAME"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["SERVICE"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["METHOD"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["RESOURCE"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["STATUS"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["BIGQUERY_PROJECT_ID"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["BIGQUERY_DATASET"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["BIGQUERY_TABLE"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["BIGQUERY_VIEW"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["BIGQUERY_QUERY_NAME"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["GCS_BUCKET"]._options = None
_MONITORINGINFO_MONITORINGINFOLABELS.values_by_name["GCS_PROJECT_ID"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["SUM_INT64_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["SUM_DOUBLE_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["DISTRIBUTION_INT64_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["DISTRIBUTION_DOUBLE_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["LATEST_INT64_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["LATEST_DOUBLE_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["TOP_N_INT64_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["TOP_N_DOUBLE_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["BOTTOM_N_INT64_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["BOTTOM_N_DOUBLE_TYPE"]._options = None
_MONITORINGINFOTYPEURNS_ENUM.values_by_name["PROGRESS_TYPE"]._options = None
# @@protoc_insertion_point(module_scope)
