apache_beam.portability.api.metrics_pb2_urns module

class apache_beam.portability.api.metrics_pb2_urns.MonitoringInfo[source]

Bases: object

class MonitoringInfoLabels[source]

Bases: object

TRANSFORM = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "PTRANSFORM" )
PCOLLECTION = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "PCOLLECTION" )
WINDOWING_STRATEGY = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "WINDOWING_STRATEGY" )
CODER = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "CODER" )
ENVIRONMENT = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "ENVIRONMENT" )
NAMESPACE = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "NAMESPACE" )
NAME = PropertiesFromEnumValue(urn='', constant='', spec=, label_props=name: "NAME" )
class apache_beam.portability.api.metrics_pb2_urns.MonitoringInfoSpecs[source]

Bases: object

class Enum[source]

Bases: object

USER_SUM_INT64 = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:sum_int64:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_SUM_DOUBLE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:sum_double:v1" type: "beam:metrics:sum_double:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_DISTRIBUTION_INT64 = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:distribution_int64:v1" type: "beam:metrics:distribution_int64:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_DISTRIBUTION_DOUBLE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:distribution_double:v1" type: "beam:metrics:distribution_double:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_LATEST_INT64 = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:latest_int64:v1" type: "beam:metrics:latest_int64:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_LATEST_DOUBLE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:latest_double:v1" type: "beam:metrics:latest_double:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_TOP_N_INT64 = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:top_n_int64:v1" type: "beam:metrics:top_n_int64:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_TOP_N_DOUBLE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:top_n_double:v1" type: "beam:metrics:top_n_double:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_BOTTOM_N_INT64 = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:bottom_n_int64:v1" type: "beam:metrics:bottom_n_int64:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
USER_BOTTOM_N_DOUBLE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user:bottom_n_double:v1" type: "beam:metrics:bottom_n_double:v1" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user metric." } , label_props=)
ELEMENT_COUNT = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:element_count:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PCOLLECTION" annotations { key: "description" value: "The total elements output to a Pcollection by a PTransform." } , label_props=)
SAMPLED_BYTE_SIZE = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:sampled_byte_size:v1" type: "beam:metrics:distribution_int64:v1" required_labels: "PCOLLECTION" annotations { key: "description" value: "The 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." } , label_props=)
START_BUNDLE_MSECS = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:pardo_execution_time:start_bundle_msecs:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The total estimated execution time of the start bundlefunction in a pardo" } , label_props=)
PROCESS_BUNDLE_MSECS = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:pardo_execution_time:process_bundle_msecs:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The total estimated execution time of the process bundlefunction in a pardo" } , label_props=)
FINISH_BUNDLE_MSECS = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:pardo_execution_time:finish_bundle_msecs:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The total estimated execution time of the finish bundle function in a pardo" } , label_props=)
TOTAL_MSECS = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:ptransform_execution_time:total_msecs:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The total estimated execution time of the ptransform" } , label_props=)
WORK_REMAINING = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:ptransform_progress:remaining:v1" type: "beam:metrics:progress:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element." } , label_props=)
WORK_COMPLETED = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:ptransform_progress:completed:v1" type: "beam:metrics:progress:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The remaining amount of work for each active element. Each active element represents an independent amount of work not shared with any other active element." } , label_props=)
DATA_CHANNEL_READ_INDEX = PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:data_channel:read_index:v1" type: "beam:metrics:sum_int64:v1" required_labels: "PTRANSFORM" annotations { key: "description" value: "The read index of the data channel." } , label_props=)
class apache_beam.portability.api.metrics_pb2_urns.MonitoringInfoTypeUrns[source]

Bases: object

class Enum[source]

Bases: object

SUM_INT64_TYPE = PropertiesFromEnumValue(urn='beam:metrics:sum_int64:v1', constant='', spec=, label_props=)
SUM_DOUBLE_TYPE = PropertiesFromEnumValue(urn='beam:metrics:sum_double:v1', constant='', spec=, label_props=)
DISTRIBUTION_INT64_TYPE = PropertiesFromEnumValue(urn='beam:metrics:distribution_int64:v1', constant='', spec=, label_props=)
DISTRIBUTION_DOUBLE_TYPE = PropertiesFromEnumValue(urn='beam:metrics:distribution_double:v1', constant='', spec=, label_props=)
LATEST_INT64_TYPE = PropertiesFromEnumValue(urn='beam:metrics:latest_int64:v1', constant='', spec=, label_props=)
LATEST_DOUBLE_TYPE = PropertiesFromEnumValue(urn='beam:metrics:latest_double:v1', constant='', spec=, label_props=)
TOP_N_INT64_TYPE = PropertiesFromEnumValue(urn='beam:metrics:top_n_int64:v1', constant='', spec=, label_props=)
TOP_N_DOUBLE_TYPE = PropertiesFromEnumValue(urn='beam:metrics:top_n_double:v1', constant='', spec=, label_props=)
BOTTOM_N_INT64_TYPE = PropertiesFromEnumValue(urn='beam:metrics:bottom_n_int64:v1', constant='', spec=, label_props=)
BOTTOM_N_DOUBLE_TYPE = PropertiesFromEnumValue(urn='beam:metrics:bottom_n_double:v1', constant='', spec=, label_props=)
PROGRESS_TYPE = PropertiesFromEnumValue(urn='beam:metrics:progress:v1', constant='', spec=, label_props=)