org.apache.beam.it.gcp

Class LoadTestBase.MetricsConfiguration

java.lang.Object

org.apache.beam.it.gcp.LoadTestBase.MetricsConfiguration

Enclosing class:

LoadTestBase

public abstract static class LoadTestBase.MetricsConfiguration
extends java.lang.Object

Utils for the metrics.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LoadTestBase.MetricsConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
MetricsConfiguration()

Method Summary

Modifier and Type	Method and Description
static LoadTestBase.MetricsConfiguration.Builder	builder()
abstract java.lang.String	inputPCollection() Input PCollection of the Dataflow job to query additional metrics.
abstract java.lang.String	inputPCollectionV2() Input PCollection name under Dataflow runner v2.
abstract java.lang.String	outputPCollection() Input PCollection of the Dataflow job to query additional metrics.
abstract java.lang.String	outputPCollectionV2()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricsConfiguration

public MetricsConfiguration()

Method Detail

inputPCollection

@Nullable
public abstract java.lang.String inputPCollection()

Input PCollection of the Dataflow job to query additional metrics. If not provided, the metrics for inputPCollection will not be calculated.

inputPCollectionV2

@Nullable
public abstract java.lang.String inputPCollectionV2()

Input PCollection name under Dataflow runner v2.

outputPCollection

@Nullable
public abstract java.lang.String outputPCollection()

Input PCollection of the Dataflow job to query additional metrics. If not provided, the metrics for inputPCollection will not be calculated.

outputPCollectionV2

@Nullable
public abstract java.lang.String outputPCollectionV2()

builder

public static LoadTestBase.MetricsConfiguration.Builder builder()