Package org.apache.beam.sdk.options

Interface StreamingOptions

All Superinterfaces:

ApplicationNameOptions, HasDisplayData, PipelineOptions

public interface StreamingOptions
extends ApplicationNameOptions, PipelineOptions

Options used to configure streaming.

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	isStreaming()	Set to true if running a streaming pipeline.
void	setStreaming(boolean value)

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

getAppName, setAppName

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, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Detail

isStreaming

@Hidden
boolean isStreaming()

Set to true if running a streaming pipeline. This will be automatically set to true if the pipeline contains an Unbounded PCollection.

setStreaming

void setStreaming(boolean value)