edu.iu.dsc.tws.executor.core.streaming

Class PendingCheckpoint

java.lang.Object

edu.iu.dsc.tws.executor.core.streaming.PendingCheckpoint

public class PendingCheckpoint
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PendingCheckpoint(java.lang.String taskGraphName, CheckpointableTask checkpointableTask, int globalTaskId, IParallelOperation[] streamingInParOps, int noOfedges, CheckpointingClient checkpointingClient, StateStore stateStore, SnapshotImpl snapshot)

Method Summary

Modifier and Type	Method and Description
long	execute()
boolean	isPending()
void	schedule(java.lang.String edge, long barrierId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PendingCheckpoint

public PendingCheckpoint(java.lang.String taskGraphName,
                         CheckpointableTask checkpointableTask,
                         int globalTaskId,
                         IParallelOperation[] streamingInParOps,
                         int noOfedges,
                         CheckpointingClient checkpointingClient,
                         StateStore stateStore,
                         SnapshotImpl snapshot)

Method Detail

schedule

public void schedule(java.lang.String edge,
                     long barrierId)

isPending

public boolean isPending()

execute

public long execute()