接口的使用
org.apache.flink.streaming.api.checkpoint.CheckpointedFunction

使用CheckpointedFunction的程序包

程序包	说明
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen
org.apache.flink.streaming.api.operators.collect

org.apache.flink.streaming.api.functions.sink中CheckpointedFunction的使用

实现CheckpointedFunction的org.apache.flink.streaming.api.functions.sink中的类

限定符和类型	类和说明
class	TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT> 已过时。 This interface will be removed in future versions. Use the new Sink interface instead.

org.apache.flink.streaming.api.functions.sink.filesystem中CheckpointedFunction的使用

实现CheckpointedFunction的org.apache.flink.streaming.api.functions.sink.filesystem中的类

限定符和类型	类和说明
class	StreamingFileSink<IN> 已过时。 Use org.apache.flink.connector.file.sink.FileSink instead.

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

实现CheckpointedFunction的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	FromElementsFunction<T> 已过时。 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	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中CheckpointedFunction的使用

实现CheckpointedFunction的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.collect中CheckpointedFunction的使用

实现CheckpointedFunction的org.apache.flink.streaming.api.operators.collect中的类

限定符和类型	类和说明
class	CollectSinkFunction<IN> A sink function that collects query results and sends them back to the client.