public static class CheckpointingTaskExample.SinkTask extends BaseCompute<java.lang.Integer> implements CheckpointableTask
Constructor and Description |
---|
SinkTask() |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IMessage<java.lang.Integer> content)
Execute with an incoming message
|
void |
initSnapshot(Snapshot snapshot)
This method could be used to predefine packers
|
void |
restoreSnapshot(Snapshot snapshot)
This method will be called when task is initializing
|
void |
takeSnapshot(Snapshot snapshot)
Snapshot should be updated in this method with new values |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onCheckpointPropagated, onSnapshotPersisted
endExecute
public boolean execute(IMessage<java.lang.Integer> content)
ICompute
public void restoreSnapshot(Snapshot snapshot)
CheckpointableTask
restoreSnapshot
in interface CheckpointableTask
public void takeSnapshot(Snapshot snapshot)
CheckpointableTask
Snapshot
should be updated in this method with new valuestakeSnapshot
in interface CheckpointableTask
public void initSnapshot(Snapshot snapshot)
CheckpointableTask
initSnapshot
in interface CheckpointableTask