Package 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	Description
Boolean	getUseDataStreamForBatch()
void	setUseDataStreamForBatch(Boolean useDataStreamForBatch)

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

populateDisplayData

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

Method Details

getUseDataStreamForBatch

@Boolean(false)
Boolean getUseDataStreamForBatch()

setUseDataStreamForBatch

void setUseDataStreamForBatch(Boolean useDataStreamForBatch)