Uses of Interface
org.apache.flink.api.connector.source.Source

Packages that use Source

Package	Description
org.apache.flink.api.connector.source.lib
org.apache.flink.connector.file.src
org.apache.flink.connector.kafka.source
org.apache.flink.connectors.hive
org.apache.flink.runtime.source.coordinator
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.transformations
org.apache.flink.table.connector.source

Uses of Source in org.apache.flink.api.connector.source.lib

Classes in org.apache.flink.api.connector.source.lib that implement Source

Modifier and Type	Class and Description
class	NumberSequenceSource A data source that produces a sequence of numbers (longs).

Uses of Source in org.apache.flink.connector.file.src

Classes in org.apache.flink.connector.file.src that implement Source

Modifier and Type	Class and Description
class	AbstractFileSource<T,SplitT extends FileSourceSplit> The base class for File Sources.
class	FileSource<T> A unified data source that reads files - both in batch and in streaming mode.

Uses of Source in org.apache.flink.connector.kafka.source

Classes in org.apache.flink.connector.kafka.source that implement Source

Modifier and Type	Class and Description
class	KafkaSource<OUT> The Source implementation of Kafka.

Uses of Source in org.apache.flink.connectors.hive

Classes in org.apache.flink.connectors.hive that implement Source

Modifier and Type	Class and Description
class	HiveSource A unified data source that reads a hive table.

Uses of Source in org.apache.flink.runtime.source.coordinator

Constructors in org.apache.flink.runtime.source.coordinator with parameters of type Source

Constructor and Description
SourceCoordinator(String operatorName, ExecutorService coordinatorExecutor, Source<?,SplitT,EnumChkT> source, SourceCoordinatorContext<SplitT> context)
SourceCoordinatorProvider(String operatorName, OperatorID operatorID, Source<?,SplitT,?> source, int numWorkerThreads) Construct the SourceCoordinatorProvider.

Uses of Source in org.apache.flink.streaming.api.datastream

Constructors in org.apache.flink.streaming.api.datastream with parameters of type Source

Constructor and Description
DataStreamSource(StreamExecutionEnvironment environment, Source<T,?,?> source, WatermarkStrategy<T> watermarkStrategy, TypeInformation<T> outTypeInfo, String sourceName) Constructor for new Sources (FLIP-27).

Uses of Source in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment with parameters of type Source

Modifier and Type	Method and Description
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source, WatermarkStrategy<OUT> timestampsAndWatermarks, String sourceName) Adds a data Source to the environment to get a DataStream.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source, WatermarkStrategy<OUT> timestampsAndWatermarks, String sourceName, TypeInformation<OUT> typeInfo) Adds a data Source to the environment to get a DataStream.

Uses of Source in org.apache.flink.streaming.api.operators

Constructors in org.apache.flink.streaming.api.operators with parameters of type Source

Constructor and Description
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy)
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks)
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks, int numCoordinatorWorkerThread)

Uses of Source in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return Source

Modifier and Type	Method and Description
Source<OUT,SplitT,EnumChkT>	SourceTransformation.getSource()

Constructors in org.apache.flink.streaming.api.transformations with parameters of type Source

Constructor and Description
SourceTransformation(String name, Source<OUT,SplitT,EnumChkT> source, WatermarkStrategy<OUT> watermarkStrategy, TypeInformation<OUT> outputType, int parallelism) Creates a new Transformation with the given name, output type and parallelism.

Uses of Source in org.apache.flink.table.connector.source

Methods in org.apache.flink.table.connector.source that return Source

Modifier and Type	Method and Description
Source<RowData,?,?>	SourceProvider.createSource() Creates a Source instance.

Methods in org.apache.flink.table.connector.source with parameters of type Source

Modifier and Type	Method and Description
static SourceProvider	SourceProvider.of(Source<RowData,?,?> source) Helper method for creating a static provider.