接口的使用
org.apache.flink.streaming.api.functions.source.SourceFunction

使用SourceFunction的程序包

程序包	说明
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.runtime.tasks	This package contains classes that realize streaming tasks.

org.apache.flink.streaming.api.checkpoint中SourceFunction的使用

org.apache.flink.streaming.api.checkpoint中SourceFunction的子接口

限定符和类型	接口和说明
interface	ExternallyInducedSource<T,CD> 已过时。 This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

org.apache.flink.streaming.api.environment中SourceFunction的使用

参数类型为SourceFunction的org.apache.flink.streaming.api.environment中的方法

限定符和类型	方法和说明
<OUT> DataStreamSource<OUT>	StreamExecutionEnvironment.addSource(SourceFunction<OUT> function) 已过时。 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) 已过时。 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, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> typeInfo) 已过时。 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, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> typeInfo) 已过时。 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.

org.apache.flink.streaming.api.functions.source中SourceFunction的使用

org.apache.flink.streaming.api.functions.source中SourceFunction的子接口

限定符和类型	接口和说明
interface	ParallelSourceFunction<OUT> 已过时。 This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

实现SourceFunction的org.apache.flink.streaming.api.functions.source中的类

限定符和类型	类和说明
class	ContinuousFileMonitoringFunction<OUT> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FileMonitoringFunction 已过时。 Internal class deprecated in favour of ContinuousFileMonitoringFunction.
class	FromElementsFunction<T> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FromIteratorFunction<T> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	FromSplittableIteratorFunction<T> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	InputFormatSourceFunction<OUT> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	MessageAcknowledgingSourceBase<Type,UId> 已过时。 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> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	RichParallelSourceFunction<OUT> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	RichSourceFunction<OUT> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	SocketTextStreamFunction 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
class	StatefulSequenceSource 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

org.apache.flink.streaming.api.functions.source.datagen中SourceFunction的使用

实现SourceFunction的org.apache.flink.streaming.api.functions.source.datagen中的类

限定符和类型	类和说明
class	DataGeneratorSource<T> 已过时。 Use org.apache.flink.connector.datagen.source.DataGeneratorSource instead.

org.apache.flink.streaming.api.operators中SourceFunction的使用

类型参数类型为SourceFunction的org.apache.flink.streaming.api.operators中的类

限定符和类型	类和说明
class	StreamSource<OUT,SRC extends SourceFunction<OUT>> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

org.apache.flink.streaming.runtime.tasks中SourceFunction的使用

类型参数类型为SourceFunction的org.apache.flink.streaming.runtime.tasks中的类

限定符和类型	类和说明
class	SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>> 已过时。 This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.