org.apache.beam.it.gcp

Class IOStressTestBase

java.lang.Object

org.apache.beam.it.gcp.LoadTestBase

org.apache.beam.it.gcp.IOLoadTestBase

org.apache.beam.it.gcp.IOStressTestBase

public class IOStressTestBase
extends IOLoadTestBase

Base class for IO Stress tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	IOStressTestBase.LoadPeriod Represents a period of time with associated load increase properties for stress testing scenarios.
protected static class	IOStressTestBase.MultiplierDoFn<T> Custom Apache Beam DoFn designed for use in stress testing scenarios.

Nested classes/interfaces inherited from class org.apache.beam.it.gcp.IOLoadTestBase

IOLoadTestBase.CountingFn<T>, IOLoadTestBase.PipelineMetricsType

Nested classes/interfaces inherited from class org.apache.beam.it.gcp.LoadTestBase

LoadTestBase.MetricsConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
protected static int[]	DEFAULT_LOAD_INCREASE_ARRAY The load will initiate at 1x, progressively increase to 2x and 4x, then decrease to 2x and eventually return to 1x.
protected static int	DEFAULT_ROWS_PER_SECOND

Fields inherited from class org.apache.beam.it.gcp.IOLoadTestBase

BEAM_METRICS_NAMESPACE, tempBucketName

Fields inherited from class org.apache.beam.it.gcp.LoadTestBase

CREDENTIALS, CREDENTIALS_PROVIDER, monitoringClient, pipelineLauncher, pipelineOperator, project, region, testName, watcher

Constructor Summary

Constructors

Constructor and Description
IOStressTestBase()

Method Summary

Modifier and Type	Method and Description
protected java.util.List<IOStressTestBase.LoadPeriod>	getLoadPeriods(int minutesTotal, int[] loadIncreaseArray) Generates and returns a list of LoadPeriod instances representing periods of load increase based on the specified load increase array and total duration in minutes.

Methods inherited from class org.apache.beam.it.gcp.IOLoadTestBase

exportMetrics, getBeamMetricsName, launcher, setUpBase, tearDownBase

Methods inherited from class org.apache.beam.it.gcp.LoadTestBase

calculateAverage, createConfig, exportMetricsToBigQuery, getCpuUtilizationMetrics, getDataFreshnessMetrics, getMetrics, getMetrics, getMetrics, getMetrics, getSystemLatencyMetrics, getThroughputMetrics, getWorkerTimeInterval, setUp, setUpClass, tearDownLoadTestBase, waitForNumMessages

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LOAD_INCREASE_ARRAY

protected static final int[] DEFAULT_LOAD_INCREASE_ARRAY

The load will initiate at 1x, progressively increase to 2x and 4x, then decrease to 2x and eventually return to 1x.

DEFAULT_ROWS_PER_SECOND

protected static final int DEFAULT_ROWS_PER_SECOND

See Also:

Constant Field Values

Constructor Detail

IOStressTestBase

public IOStressTestBase()

Method Detail

getLoadPeriods

protected java.util.List<IOStressTestBase.LoadPeriod> getLoadPeriods(int minutesTotal,
                                                                     int[] loadIncreaseArray)

Generates and returns a list of LoadPeriod instances representing periods of load increase based on the specified load increase array and total duration in minutes.

Parameters:

minutesTotal - The total duration in minutes for which the load periods are generated.

Returns:

A list of LoadPeriod instances defining periods of load increase.