Modifier and Type | Method and Description |
---|---|
TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> |
TwoPhaseCommittingSink.createWriter(Sink.InitContext context)
Creates a
TwoPhaseCommittingSink.PrecommittingSinkWriter that creates committables on checkpoint or end of
input. |
Modifier and Type | Class and Description |
---|---|
class |
FileWriter<IN>
A
SinkWriter implementation for FileSink . |
Modifier and Type | Method and Description |
---|---|
TwoPhaseCommittingSink.PrecommittingSinkWriter<IN,PulsarCommittable> |
PulsarSink.createWriter(Sink.InitContext initContext) |
Modifier and Type | Class and Description |
---|---|
class |
PulsarWriter<IN>
This class is responsible to write records in a Pulsar topic and to handle the different delivery
DeliveryGuarantee s. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.