Interface | Description |
---|---|
Checkpointed<T extends Serializable> | Deprecated
Please use
ListCheckpointed as illustrated above, or
CheckpointedFunction for more control over the checkpointing process. |
CheckpointedAsynchronously<T extends Serializable> | Deprecated
Please use
ListCheckpointed and CheckpointedFunction instead,
as illustrated in the example above. |
CheckpointedFunction |
This is the core interface for stateful transformation functions, meaning functions
that maintain state across individual stream records.
|
CheckpointedRestoring<T extends Serializable> | Deprecated |
ListCheckpointed<T extends Serializable> |
This interface can be implemented by functions that want to store state in checkpoints.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.