Interface | Description |
---|---|
PartitionCommitTrigger |
Partition commit trigger.
|
Class | Description |
---|---|
PartitionTimeCommitTigger |
Partition commit trigger by partition time and watermark, if 'watermark' > 'partition-time' +
'delay', will commit the partition.
|
ProcTimeCommitTigger |
Partition commit trigger by creation time and processing time service, if 'current processing
time' > 'partition creation time' + 'delay', will commit the partition.
|
StreamingFileCommitter |
Committer for
StreamingFileWriter . |
StreamingFileCommitter.CommitMessage |
The message sent upstream.
|
StreamingFileWriter |
Operator for file system sink.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.