Deprecated API

Contents

• Fields
• Methods
• Enum Constants

Fields

Field	Description
org.apache.beam.runners.dataflow.util.PropertyNames.RESTRICTION_CODER	Uses the incorrect terminology. PropertyNames.RESTRICTION_ENCODING. Should be removed once non FnAPI SplittableDoFn expansion for Dataflow is removed.

Methods

Method	Description
org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions.getUnboundedReaderMaxReadTimeSec()	use DataflowPipelineDebugOptions.getUnboundedReaderMaxReadTimeMs() instead
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.getWorkerHarnessContainerImage()	Use DataflowPipelineWorkerPoolOptions.getSdkContainerImage() instead.
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.setWorkerHarnessContainerImage(String)	Use DataflowPipelineWorkerPoolOptions.setSdkContainerImage(java.lang.String) instead.
org.apache.beam.runners.dataflow.options.DataflowStreamingPipelineOptions.getUseSeparateWindmillHeartbeatStreams()	since beam 2.73.0
org.apache.beam.runners.dataflow.options.DataflowStreamingPipelineOptions.getUseWindmillIsolatedChannels()	since 2.73.0
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.getDefaultWorkerLogLevel()	Prefer SdkHarnessOptions.getDefaultSdkHarnessLogLevel() which works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.getWorkerLogLevelOverrides()	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() which works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.getWorkerSystemErrMessageLevel()	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() to override the 'System.err' logger as this works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.getWorkerSystemOutMessageLevel()	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() to override the 'System.out' logger as this works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.setDefaultWorkerLogLevel(DataflowWorkerLoggingOptions.Level)	Prefer SdkHarnessOptions.getDefaultSdkHarnessLogLevel() which works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.setWorkerLogLevelOverrides(DataflowWorkerLoggingOptions.WorkerLogLevelOverrides)	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() which works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.setWorkerSystemErrMessageLevel(DataflowWorkerLoggingOptions.Level)	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() to override the 'System.err' logger as this works across runners.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.setWorkerSystemOutMessageLevel(DataflowWorkerLoggingOptions.Level)	Prefer using SdkHarnessOptions.getSdkHarnessLogLevelOverrides() to override the 'System.out' logger as this works across runners.
org.apache.beam.runners.dataflow.util.MonitoringUtil.getJobMonitoringPageURL(String, String)	this method defaults the region to "us-central1". Prefer using the overload with an explicit regionId parameter.

Enum Constants

Enum Constant	Description
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.BASIC	use DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.THROUGHPUT_BASED.