Packages

package metrics

This package contains the schema types for metrics collected during a pipeline run.

Linear Supertypes

Type Members

  1. final case class BeamDistribution(sum: Long, count: Long, min: Long, max: Long, mean: Double) extends Product with Serializable
  2. final case class BeamGauge(value: Long, timestamp: Instant) extends Product with Serializable
  3. final case class BeamMetric[T](namespace: String, name: String, value: MetricValue[T]) extends Product with Serializable
  4. final case class BeamMetrics(counters: Iterable[BeamMetric[Long]], distributions: Iterable[BeamMetric[BeamDistribution]], gauges: Iterable[BeamMetric[BeamGauge]]) extends Product with Serializable
  5. 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.

  6. 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.

Inherited from AnyRef

Inherited from Any

Ungrouped