Uses of Interface
org.apache.flink.streaming.api.functions.source.SourceFunction

Packages that use SourceFunction

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.sql.tests
org.apache.flink.streaming.api.checkpoint
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.connectors.wikiedits
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.tests
org.apache.flink.streaming.util
org.apache.flink.table.connector.source
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.table.toolbox
org.apache.flink.test
org.apache.flink.walkthrough.common.source

Uses of SourceFunction in org.apache.flink.connector.file.sink

Classes in org.apache.flink.connector.file.sink that implement SourceFunction

Modifier and Type	Class and Description
static class	FileSinkProgram.Generator Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.sql.tests

Classes in org.apache.flink.sql.tests that implement SourceFunction

Modifier and Type	Class and Description
static class	StreamSQLTestProgram.Generator Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.api.checkpoint

Subinterfaces of SourceFunction in org.apache.flink.streaming.api.checkpoint

Modifier and Type	Interface and Description
interface	ExternallyInducedSource<T,CD> Deprecated. This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

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

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

Modifier and Type	Method and Description
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function) Deprecated. This method relies on the SourceFunction API, which is due to be removed. Use the StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String) method based on the new Source API instead.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, String sourceName) Deprecated. This method relies on the SourceFunction API, which is due to be removed. Use the StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String) method based on the new Source API instead.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, String sourceName, TypeInformation<OUT> typeInfo) Deprecated. This method relies on the SourceFunction API, which is due to be removed. Use the StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String, TypeInformation) method based on the new Source API instead.
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function, TypeInformation<OUT> typeInfo) Deprecated. This method relies on the SourceFunction API, which is due to be removed. Use the StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String, TypeInformation) method based on the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.api.functions.source

Subinterfaces of SourceFunction in org.apache.flink.streaming.api.functions.source

Modifier and Type	Interface and Description
interface	ParallelSourceFunction<OUT> Deprecated. This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Classes in org.apache.flink.streaming.api.functions.source that implement SourceFunction

Modifier and Type	Class and Description
class	ContinuousFileMonitoringFunction<OUT> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FileMonitoringFunction Deprecated. Internal class deprecated in favour of ContinuousFileMonitoringFunction.
class	FromElementsFunction<T> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FromIteratorFunction<T> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FromSplittableIteratorFunction<T> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	InputFormatSourceFunction<OUT> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	MessageAcknowledgingSourceBase<Type,UId> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	MultipleIdsMessageAcknowledgingSourceBase<Type,UId,SessionId> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	RichParallelSourceFunction<OUT> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	RichSourceFunction<OUT> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	SocketTextStreamFunction Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	StatefulSequenceSource Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.api.functions.source.datagen

Classes in org.apache.flink.streaming.api.functions.source.datagen that implement SourceFunction

Modifier and Type	Class and Description
class	DataGeneratorSource<T> Deprecated. Use org.apache.flink.connector.datagen.source.DataGeneratorSource instead.

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

Classes in org.apache.flink.streaming.api.operators with type parameters of type SourceFunction

Modifier and Type	Class and Description
class	StreamSource<OUT,SRC extends SourceFunction<OUT>> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.connectors.wikiedits

Classes in org.apache.flink.streaming.connectors.wikiedits that implement SourceFunction

Modifier and Type	Class and Description
class	WikipediaEditsSource Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.runtime.tasks

Classes in org.apache.flink.streaming.runtime.tasks with type parameters of type SourceFunction

Modifier and Type	Class and Description
class	SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.tests

Classes in org.apache.flink.streaming.tests that implement SourceFunction

Modifier and Type	Class and Description
static class	PeriodicStreamingJob.PeriodicSourceGenerator Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	SequenceGeneratorSource Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.streaming.util

Classes in org.apache.flink.streaming.util that implement SourceFunction

Modifier and Type	Class and Description
class	FiniteTestSource<T> Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

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

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

Modifier and Type	Method and Description
SourceFunction<RowData>	SourceFunctionProvider.createSourceFunction() Deprecated. Creates a SourceFunction instance.

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

Modifier and Type	Method and Description
static SourceFunctionProvider	SourceFunctionProvider.of(SourceFunction<RowData> sourceFunction, boolean isBounded) Deprecated. Helper method for creating a static provider.
static SourceFunctionProvider	SourceFunctionProvider.of(SourceFunction<RowData> sourceFunction, boolean isBounded, Integer sourceParallelism) Deprecated. Helper method for creating a Source provider with a provided source parallelism.

Uses of SourceFunction in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type SourceFunction

Modifier and Type	Method and Description
protected Transformation<RowData>	CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment env, SourceFunction<RowData> function, boolean isBounded, String operatorName, TypeInformation<RowData> outputTypeInfo, int sourceParallelism, boolean sourceParallelismConfigured) Deprecated. This method relies on the SourceFunction API, which is due to be removed.

Uses of SourceFunction in org.apache.flink.table.runtime.arrow.sources

Classes in org.apache.flink.table.runtime.arrow.sources that implement SourceFunction

Modifier and Type	Class and Description
class	ArrowSourceFunction Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.table.toolbox

Classes in org.apache.flink.table.toolbox that implement SourceFunction

Modifier and Type	Class and Description
class	TestSourceFunction A source function used to test.

Uses of SourceFunction in org.apache.flink.test

Classes in org.apache.flink.test that implement SourceFunction

Modifier and Type	Class and Description
static class	StatefulStreamingJob.MySource Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

Uses of SourceFunction in org.apache.flink.walkthrough.common.source

Classes in org.apache.flink.walkthrough.common.source that implement SourceFunction

Modifier and Type	Class and Description
class	TransactionSource Deprecated. This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.