org.apache.beam.runners.flink

Interface VersionDependentFlinkPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

FlinkPipelineOptions

public interface VersionDependentFlinkPipelineOptions
extends PipelineOptions

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.Boolean	getUseDataStreamForBatch()
void	setUseDataStreamForBatch(java.lang.Boolean useDataStreamForBatch)

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

getUseDataStreamForBatch

@Default.Boolean(value=false)
java.lang.Boolean getUseDataStreamForBatch()

setUseDataStreamForBatch

void setUseDataStreamForBatch(java.lang.Boolean useDataStreamForBatch)