Interface | Description |
---|---|
CheckpointedFunction |
This is the core interface for stateful transformation functions, meaning functions
that maintain state across individual stream records.
|
ExternallyInducedSource<T,CD> |
Sources that implement this interface do not trigger checkpoints when receiving a
trigger message from the checkpoint coordinator, but when their input data/events
indicate that a checkpoint should be triggered.
|
ExternallyInducedSource.CheckpointTrigger |
Through the
CheckpointTrigger , the source function notifies the Flink
source operator when to trigger the checkpoint. |
ListCheckpointed<T extends Serializable> |
This interface can be implemented by functions that want to store state in checkpoints.
|
WithMasterCheckpointHook<E> |
This interface can be implemented by streaming functions that need to trigger a
"global action" on the master (in the checkpoint coordinator) as part of every
checkpoint and restore operation.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.