Package | Description |
---|---|
org.apache.flink.streaming.runtime.operators.sink.committables |
Modifier and Type | Method and Description |
---|---|
CommittableCollector<CommT> |
CommittableCollector.copy()
Returns a new committable collector that deep copies all internals.
|
CommittableCollector<CommT> |
CommittableCollectorSerializer.deserialize(int version,
byte[] serialized) |
static <CommT> CommittableCollector<CommT> |
CommittableCollector.of(RuntimeContext context)
Creates a
CommittableCollector based on the current runtime information. |
Modifier and Type | Method and Description |
---|---|
void |
CommittableCollector.merge(CommittableCollector<CommT> cc)
Merges all information from an external collector into this collector.
|
byte[] |
CommittableCollectorSerializer.serialize(CommittableCollector<CommT> committableCollector) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.