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