com.parabon.client
Interface TaskCheckpointEvent

All Superinterfaces:

TaskEvent

public interface TaskCheckpointEvent
extends TaskEvent

A TaskCheckpointEvent is generated when a task logs a checkpoint. Note that not all task events are guaranteed to be propogated back to listeners; in particular, checkpoint events are generally only propogated to listeners in local execution mode, but even this is not guaranteed.

Method Summary

java.io.InputStream

getCheckpoint() Returns an InputStream from which a task checkpoint can be read, as reported via TaskContext.logCheckpoint.

Methods inherited from interface com.parabon.client.TaskEvent

getProgress, getRunMode, getTaskAttributes, getTaskProxy, isActive, isComplete

Method Detail

getCheckpoint

java.io.InputStream getCheckpoint()

Returns an InputStream from which a task checkpoint can be read, as reported via TaskContext.logCheckpoint. If this checkpoint was logged via SerializableTaskContext.logCheckpoint(), the contents of the returned stream may be used as parameters to a new TaskSpec instance as long as that TaskSpec is given the same runnable class as returned by the task's original TaskSpec.getRunnableClass().

This InputStream instance is valid only for the lifetime of the event listener method invocation, and it should not be maintained or accessed outside this scope or used after the method completes; any attempt to do so will result in undefined behaviour.

See Also:

TaskContext.logCheckpoint(com.parabon.runtime.DataBuffer)