Package org.apache.beam.runners.flink.translation.wrappers.streaming.io.source

package org.apache.beam.runners.flink.translation.wrappers.streaming.io.source

Internal implementation of the Beam runner for Apache Flink.

Related Packages

Package	Description
org.apache.beam.runners.flink.translation.wrappers.streaming.io	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.bounded	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.impulse	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.unbounded	Internal implementation of the Beam runner for Apache Flink.

Class	Description
FlinkSource<T,OutputT>	The base class for FlinkBoundedSource and FlinkUnboundedSource.
FlinkSource.TimestampExtractor<T>
FlinkSourceReaderBase<T,OutputT>	An abstract implementation of SourceReader which encapsulates Beam Sources for data reading.
FlinkSourceSplit<T>	A Flink SourceSplit implementation that encapsulates a Beam Source.
FlinkSourceSplitEnumerator<T>	A Flink SplitEnumerator implementation that holds a Beam Source and does the following: Split the Beam Source to desired number of splits.
LazyFlinkSourceSplitEnumerator<T>	A Flink SplitEnumerator implementation that holds a Beam Source and does the following: Split the Beam Source to desired number of splits.