package metrics
This package contains the schema types for metrics collected during a pipeline run.
- Source
- package.scala
Linear Supertypes
Type Members
- final case class BeamDistribution(sum: Long, count: Long, min: Long, max: Long, mean: Double) extends Product with Serializable
- final case class BeamGauge(value: Long, timestamp: Instant) extends Product with Serializable
- final case class BeamMetric[T](namespace: String, name: String, value: MetricValue[T]) extends Product with Serializable
- final case class BeamMetrics(counters: Iterable[BeamMetric[Long]], distributions: Iterable[BeamMetric[BeamDistribution]], gauges: Iterable[BeamMetric[BeamGauge]]) extends Product with Serializable
- final case class MetricValue[T](attempted: T, committed: Option[T]) extends Product with Serializable
Contains the aggregated value of a metric.
Contains the aggregated value of a metric. See ScioResult.allCounters, ScioResult.allDistributions and ScioResult.allGauges.
- attempted
The value across all attempts of executing all parts of the pipeline.
- committed
The value across all successfully completed parts of the pipeline.
- final case class Metrics(version: String, scalaVersion: String, appName: String, state: String, beamMetrics: BeamMetrics) extends Product with Serializable
Case class holding metadata and service-level metrics of the job.
Case class holding metadata and service-level metrics of the job. See ScioResult.getMetrics.