Package org.apache.beam.sdk.io.kafka

Interface KafkaIO.Read.FakeFlinkPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

Enclosing class:

KafkaIO.Read<K,V>

public static interface KafkaIO.Read.FakeFlinkPipelineOptions
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
Long	getCheckpointingInterval()
void	setCheckpointingInterval(Long interval)

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

getCheckpointingInterval

@Long(-1L)
Long getCheckpointingInterval()

setCheckpointingInterval

void setCheckpointingInterval(Long interval)