@PublicEvolving public static interface TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> extends SinkWriter<InputT>
SinkWriterthat performs the first part of a two-phase commit protocol.
|Modifier and Type||Method and Description|
Prepares for a commit.
flush, write, writeWatermark
Collection<CommT> prepareCommit() throws IOException, InterruptedException
This method will be called after
SinkWriter.flush(boolean) and before
IOException- if fail to prepare for a commit.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.