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
-
class
apache_beam.portability.api.metrics_pb2_urns.MonitoringInfoSpecs[source]¶ Bases:
object-
class
Enum[source]¶ Bases:
object-
USER_COUNTER= PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user" type_urn: "beam:metrics:sum_int_64" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user numeric counters." } , label_props=)¶
-
ELEMENT_COUNT= PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:element_count:v1" type_urn: "beam:metrics:sum_int_64" 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_urn: "beam:metrics:distribution_int_64" 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_urn: "beam:metrics:sum_int_64" 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_urn: "beam:metrics:sum_int_64" 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_urn: "beam:metrics:sum_int_64" 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_urn: "beam:metrics:sum_int_64" required_labels: "PTRANSFORM" annotations { key: "description" value: "The total estimated execution time of the ptransform" } , label_props=)¶
-
USER_DISTRIBUTION_COUNTER= PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:user_distribution" type_urn: "beam:metrics:distribution_int_64" required_labels: "PTRANSFORM" required_labels: "NAMESPACE" required_labels: "NAME" annotations { key: "description" value: "URN utilized to report user distribution counters." } , label_props=)¶
-
WORK_REMAINING= PropertiesFromEnumValue(urn='', constant='', spec=urn: "beam:metric:ptransform_progress:remaining:v1" type_urn: "beam:metrics:latest_doubles" 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_urn: "beam:metrics:latest_doubles" 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=)¶
-
-
class
-
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_int_64', constant='', spec=, label_props=)¶
-
DISTRIBUTION_INT64_TYPE= PropertiesFromEnumValue(urn='beam:metrics:distribution_int_64', constant='', spec=, label_props=)¶
-
LATEST_INT64_TYPE= PropertiesFromEnumValue(urn='beam:metrics:latest_int_64', constant='', spec=, label_props=)¶
-
LATEST_DOUBLES_TYPE= PropertiesFromEnumValue(urn='beam:metrics:latest_doubles', constant='', spec=, label_props=)¶
-
-
class