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

使用ParallelSourceFunction的程序包

程序包	说明
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen

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

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

限定符和类型	类和说明
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	RichParallelSourceFunction<OUT> 已过时。 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中ParallelSourceFunction的使用

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

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