@Experimental public interface SupportsPreCommitTopology<WriterResultT,CommittableT>
SinkWriter
and before Committer
.
It is recommended to use immutable committables because mutating committables can have unexpected side-effects.
Modifier and Type | Method and Description |
---|---|
DataStream<CommittableMessage<CommittableT>> |
addPreCommitTopology(DataStream<CommittableMessage<WriterResultT>> committables)
Intercepts and modifies the committables sent on checkpoint or at end of input.
|
SimpleVersionedSerializer<WriterResultT> |
getWriteResultSerializer()
Returns the serializer of the WriteResult type.
|
DataStream<CommittableMessage<CommittableT>> addPreCommitTopology(DataStream<CommittableMessage<WriterResultT>> committables)
CommittableMessage
s appropriately.committables
- the stream of committables.Committer
.SimpleVersionedSerializer<WriterResultT> getWriteResultSerializer()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.