Partition commit trigger.
Operator for file system sink.
The message sent by upstream.
Committer operator for partitions.
Partition commit trigger by partition time and watermark, if 'watermark' > 'partition-time' + 'delay', will commit the partition.
Partition commit trigger by creation time and processing time service, if 'current processing time' > 'partition creation time' + 'delay', will commit the partition.
Writer for emitting
Helper for creating streaming file sink.
Track the upstream tasks to determine whether all the upstream data of a checkpoint has been received.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.