Class and Description |
---|
CommittableMessage
The message send from
SinkWriter to Committer . |
WithPreCommitTopology
Allows expert users to implement a custom topology after
SinkWriter and before Committer . |
Class and Description |
---|
CommittableMessage
The message send from
SinkWriter to Committer . |
Class and Description |
---|
CommittableMessage
The message send from
SinkWriter to Committer . |
Class and Description |
---|
CommittableMessage
The message send from
SinkWriter to Committer . |
Class and Description |
---|
CommittableMessage
The message send from
SinkWriter to Committer . |
CommittableSummary
This class tracks the information about committables belonging to one checkpoint coming from one
subtask.
|
CommittableWithLineage
Provides metadata.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.