Modifier and Type | Method and Description |
---|---|
Committer<PulsarCommittable> |
PulsarSink.createCommitter() |
TwoPhaseCommittingSink.PrecommittingSinkWriter<IN,PulsarCommittable> |
PulsarSink.createWriter(Sink.InitContext initContext) |
SimpleVersionedSerializer<PulsarCommittable> |
PulsarSink.getCommittableSerializer() |
Modifier and Type | Method and Description |
---|---|
PulsarCommittable |
PulsarCommittableSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
byte[] |
PulsarCommittableSerializer.serialize(PulsarCommittable obj) |
Modifier and Type | Method and Description |
---|---|
void |
PulsarCommitter.commit(Collection<Committer.CommitRequest<PulsarCommittable>> requests) |
Modifier and Type | Method and Description |
---|---|
Collection<PulsarCommittable> |
PulsarWriter.prepareCommit() |
Modifier and Type | Method and Description |
---|---|
List<PulsarCommittable> |
TopicProducerRegister.prepareCommit()
Convert the transactions into a committable list for Pulsar Committer.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.