Modifier and Type | Method and Description |
---|---|
Committer<CommT> |
TwoPhaseCommittingSink.createCommitter()
Creates a
Committer that permanently makes the previously written data visible
through commit(Collection) . |
Modifier and Type | Method and Description |
---|---|
Committer<FileSinkCommittable> |
FileSink.createCommitter() |
Modifier and Type | Method and Description |
---|---|
Committer<org.apache.flink.connector.kafka.sink.KafkaCommittable> |
KafkaSink.createCommitter() |
Modifier and Type | Method and Description |
---|---|
Committer<PulsarCommittable> |
PulsarSink.createCommitter() |
Modifier and Type | Method and Description |
---|---|
static <CommT> void |
StandardSinkTopologies.addGlobalCommitter(DataStream<CommittableMessage<CommT>> committables,
SerializableSupplier<Committer<CommT>> committerFactory,
SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializer)
Adds a global committer to the pipeline that runs as final operator with a parallelism of
one.
|
Modifier and Type | Method and Description |
---|---|
Collection<CommittableWithLineage<CommT>> |
CommittableManager.commit(boolean fullyReceived,
Committer<CommT> committer)
Commits all due committables.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.