org.apache.beam.sdk.options

Interface MemoryMonitorOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowWorkerHarnessOptions, SdkHarnessOptions, TestDataflowPipelineOptions

public interface MemoryMonitorOptions
extends PipelineOptions

Options that are used to control the Memory Monitor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.Double	getGCThrashingPercentagePerPeriod() The GC thrashing threshold percentage.
void	setGCThrashingPercentagePerPeriod(java.lang.Double value)

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getGCThrashingPercentagePerPeriod

@Default.Double(value=50.0)
java.lang.Double getGCThrashingPercentagePerPeriod()

The GC thrashing threshold percentage. A given period of time is considered "thrashing" if this percentage of CPU time is spent in garbage collection. Harness will force fail tasks after sustained periods of thrashing.

If 100 is given as the value, MemoryMonitor will be disabled.

setGCThrashingPercentagePerPeriod

void setGCThrashingPercentagePerPeriod(java.lang.Double value)