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

Class SourceStreamingInstance

java.lang.Object

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

All Implemented Interfaces:

INodeInstance

public class SourceStreamingInstance
extends java.lang.Object
implements INodeInstance

Constructor Summary

Constructors

Constructor and Description

SourceStreamingInstance(ISource streamingTask, java.util.concurrent.BlockingQueue<IMessage> outStreamingQueue, Config config, java.lang.String tName, int taskId, int globalTaskId, int tIndex, int parallel, int wId, java.util.Map<java.lang.String,java.lang.Object> cfgs, java.util.Map<java.lang.String,java.lang.String> outEdges, TaskSchedulePlan taskSchedule, CheckpointingClient checkpointingClient, java.lang.String taskGraphName, long tasksVersion)

Method Summary

Modifier and Type	Method and Description
void	close() Calls at the end to clean up
boolean	execute() Execution Method calls the SourceTasks run method to get context
int	getIndex()
INode	getNode() Get the node of this instance
java.util.concurrent.BlockingQueue<IMessage>	getOutStreamingQueue()
void	prepare(Config cfg) Prepare for an execution
void	registerOutParallelOperation(java.lang.String edge, IParallelOperation op)
void	scheduleBarriers(java.lang.Long bid)
void	scheduleCheckpoint(java.lang.Long bid)

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.compute.executor.INodeInstance

getId, isComplete, reset

Constructor Detail

SourceStreamingInstance

public SourceStreamingInstance(ISource streamingTask,
                               java.util.concurrent.BlockingQueue<IMessage> outStreamingQueue,
                               Config config,
                               java.lang.String tName,
                               int taskId,
                               int globalTaskId,
                               int tIndex,
                               int parallel,
                               int wId,
                               java.util.Map<java.lang.String,java.lang.Object> cfgs,
                               java.util.Map<java.lang.String,java.lang.String> outEdges,
                               TaskSchedulePlan taskSchedule,
                               CheckpointingClient checkpointingClient,
                               java.lang.String taskGraphName,
                               long tasksVersion)

Method Detail

prepare

public void prepare(Config cfg)

Description copied from interface: INodeInstance

Prepare for an execution

Specified by:

prepare in interface INodeInstance

Parameters:

cfg - configuration

getIndex

public int getIndex()

Specified by:

getIndex in interface INodeInstance

execute

public boolean execute()

Execution Method calls the SourceTasks run method to get context

Specified by:

execute in interface INodeInstance

Returns:

true if further execution is needed

getNode

public INode getNode()

Description copied from interface: INodeInstance

Get the node of this instance

Specified by:

getNode in interface INodeInstance

Returns:

the graph node

close

public void close()

Description copied from interface: INodeInstance

Calls at the end to clean up

Specified by:

close in interface INodeInstance

getOutStreamingQueue

public java.util.concurrent.BlockingQueue<IMessage> getOutStreamingQueue()

scheduleCheckpoint

public void scheduleCheckpoint(java.lang.Long bid)

scheduleBarriers

public void scheduleBarriers(java.lang.Long bid)

registerOutParallelOperation

public void registerOutParallelOperation(java.lang.String edge,
                                         IParallelOperation op)