Package | Description |
---|---|
org.apache.paimon.flink.sink.partition |
Constructor and Description |
---|
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
PartitionTimeExtractor timeExtractor,
java.time.Duration timeInterval,
java.time.Duration idleTime,
boolean markDoneWhenEndInput) |
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
PartitionTimeExtractor timeExtractor,
java.time.Duration timeInterval,
java.time.Duration idleTime,
long currentTimeMillis,
boolean markDoneWhenEndInput) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.