Uses of Interface
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter

Packages that use TwoPhaseCommittingSink.PrecommittingSinkWriter

Package	Description
org.apache.flink.api.connector.sink2

Uses of TwoPhaseCommittingSink.PrecommittingSinkWriter in org.apache.flink.api.connector.sink2

Methods in org.apache.flink.api.connector.sink2 that return TwoPhaseCommittingSink.PrecommittingSinkWriter

Modifier and Type	Method	Description
TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>	TwoPhaseCommittingSink.createWriter(Sink.InitContext context)	Creates a TwoPhaseCommittingSink.PrecommittingSinkWriter that creates committables on checkpoint or end of input.