Package org.apache.flink.table.filesystem.stream

Interface Summary

Interface	Description
PartitionCommitTrigger	Partition commit trigger.

Class Summary

Class	Description
AbstractStreamingWriter<IN,OUT>	Operator for file system sink.
PartitionCommitInfo	The message sent by upstream.
PartitionCommitter	Committer operator for partitions.
PartitionTimeCommitTrigger	Partition commit trigger by partition time and watermark, if 'watermark' > 'partition-time' + 'delay', will commit the partition.
ProcTimeCommitTrigger	Partition commit trigger by creation time and processing time service, if 'current processing time' > 'partition creation time' + 'delay', will commit the partition.
StreamingFileWriter<IN>	Writer for emitting PartitionCommitInfo to downstream.
StreamingSink	Helper for creating streaming file sink.
TaskTracker	Track the upstream tasks to determine whether all the upstream data of a checkpoint has been received.