Interface | Description |
---|---|
CommittableMessage<CommT> |
The message send from
SinkWriter to Committer . |
WithPostCommitTopology<InputT,CommT> |
Allows expert users to implement a custom topology after
Committer . |
WithPreCommitTopology<InputT,CommT> |
Allows expert users to implement a custom topology after
SinkWriter and before Committer . |
WithPreWriteTopology<InputT> |
Allows expert users to implement a custom topology before
SinkWriter . |
Class | Description |
---|---|
CommittableMessageSerializer<CommT> |
The serializer to serialize
CommittableMessage s in custom operators. |
CommittableMessageTypeInfo<CommT> |
The type information for the
CommittableMessage to make it consumable from a DataStream . |
CommittableSummary<CommT> |
This class tracks the information about committables belonging to one checkpoint coming from one
subtask.
|
CommittableWithLineage<CommT> |
Provides metadata.
|
StandardSinkTopologies |
This utility class provides building blocks for custom topologies.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.