Package | Description |
---|---|
org.apache.flink.streaming.runtime.operators.sink.committables |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointCommittableManager<CommT>
This interface adds checkpoint meta information to the committable.
|
Modifier and Type | Method and Description |
---|---|
CommittableManager<CommT> |
CommittableCollector.getEndOfInputCommittable()
Returns
CheckpointCommittableManager that is currently hold by the collector and
associated with the CommittableCollector.EOI checkpoint id. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.