org.apache.flink.api.connector.sink2

Interface TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>

All Superinterfaces:

AutoCloseable, CommittingSinkWriter<InputT,CommT>, SinkWriter<InputT>

Enclosing interface:

TwoPhaseCommittingSink<InputT,CommT>

Deprecated.

@PublicEvolving
 @Deprecated
public static interface TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>
extends CommittingSinkWriter<InputT,CommT>

A SinkWriter that performs the first part of a two-phase commit protocol.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

SinkWriter.Context

Method Summary

Methods inherited from interface org.apache.flink.api.connector.sink2.CommittingSinkWriter

prepareCommit

Methods inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

flush, write, writeWatermark

Methods inherited from interface java.lang.AutoCloseable

close