edu.iu.dsc.tws.executor.core

Class TaskContextImpl

java.lang.Object

edu.iu.dsc.tws.executor.core.TaskContextImpl

All Implemented Interfaces:

TaskContext

public class TaskContextImpl
extends java.lang.Object
implements TaskContext

Constructor Summary

Constructors

Constructor and Description
TaskContextImpl(int taskIndex, int taskId, int globalTaskId, java.lang.String taskName, int parallelism, int wId, java.util.Map<java.lang.String,java.lang.Object> configs, java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inputs, TaskSchedulePlan taskSchedulePlan, OperationMode opMode)
TaskContextImpl(int taskIndex, int taskId, int globalTaskId, java.lang.String taskName, int parallelism, int wId, OutputCollection collection, java.util.Map<java.lang.String,java.lang.Object> configs, java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inputs, java.util.Map<java.lang.String,java.lang.String> outEdges, TaskSchedulePlan taskSchedulePlan, OperationMode opMode)
TaskContextImpl(int taskIndex, int taskId, int globalTaskId, java.lang.String taskName, int parallelism, int wId, OutputCollection collection, java.util.Map<java.lang.String,java.lang.Object> configs, java.util.Map<java.lang.String,java.lang.String> outEdges, TaskSchedulePlan taskSchedulePlan, OperationMode opMode)

Method Summary

Modifier and Type	Method and Description
void	end(java.lang.String edge) End the current writing
void	endAll() Ends all edges
java.lang.Object	getConfig(java.lang.String name) Get a configuration with a name
java.util.Map<java.lang.String,java.lang.Object>	getConfigurations() Get the task specific configurations
java.util.Map<java.lang.String,java.util.Set<java.lang.String>>	getInEdges() Get the edge names and the tasks connected using those edges
OperationMode	getOperationMode() Get the operation mode of the task graph
java.util.Map<java.lang.String,java.lang.String>	getOutEdges() Get the out edges of this task
int	getParallelism() Get the parallism of the task
int	getWorkerId() Get the worker id this task is running
java.util.Set<WorkerSchedulePlan>	getWorkers() Set of workers in the current topology
java.util.Map<java.lang.Integer,WorkerSchedulePlan>	getWorkersMap() Map of worker where value is the container id
int	globalTaskId() Globally unique id
boolean	isCompleted() Weather all the edges are finished (whether the task is completed)
boolean	isDone(java.lang.String edge) Return true, if this task is done
void	reset() Reset the context
int	taskId() Get the task id for this task
int	taskIndex() The task index
java.lang.String	taskName() Name of the task
boolean	write(java.lang.String edge, java.lang.Object message) Write a message to the destination
boolean	write(java.lang.String edge, java.lang.Object key, java.lang.Object message) Write a message with a key
boolean	writeBarrier(java.lang.String edge, java.lang.Object message) Write a barrier message to the destination
boolean	writeEnd(java.lang.String edge, java.lang.Object message) Write the last message
boolean	writeEnd(java.lang.String edge, java.lang.Object key, java.lang.Object message) Write the last message

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.TaskContext

getTasksByName, getTasksInThisWorkerByName, getWorker

Constructor Detail

TaskContextImpl

public TaskContextImpl(int taskIndex,
                       int taskId,
                       int globalTaskId,
                       java.lang.String taskName,
                       int parallelism,
                       int wId,
                       java.util.Map<java.lang.String,java.lang.Object> configs,
                       java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inputs,
                       TaskSchedulePlan taskSchedulePlan,
                       OperationMode opMode)

TaskContextImpl

public TaskContextImpl(int taskIndex,
                       int taskId,
                       int globalTaskId,
                       java.lang.String taskName,
                       int parallelism,
                       int wId,
                       OutputCollection collection,
                       java.util.Map<java.lang.String,java.lang.Object> configs,
                       java.util.Map<java.lang.String,java.lang.String> outEdges,
                       TaskSchedulePlan taskSchedulePlan,
                       OperationMode opMode)

TaskContextImpl

public TaskContextImpl(int taskIndex,
                       int taskId,
                       int globalTaskId,
                       java.lang.String taskName,
                       int parallelism,
                       int wId,
                       OutputCollection collection,
                       java.util.Map<java.lang.String,java.lang.Object> configs,
                       java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inputs,
                       java.util.Map<java.lang.String,java.lang.String> outEdges,
                       TaskSchedulePlan taskSchedulePlan,
                       OperationMode opMode)

Method Detail

getWorkers

public java.util.Set<WorkerSchedulePlan> getWorkers()

Description copied from interface: TaskContext

Set of workers in the current topology

Specified by:

getWorkers in interface TaskContext

getWorkersMap

public java.util.Map<java.lang.Integer,WorkerSchedulePlan> getWorkersMap()

Description copied from interface: TaskContext

Map of worker where value is the container id

Specified by:

getWorkersMap in interface TaskContext

getOperationMode

public OperationMode getOperationMode()

Description copied from interface: TaskContext

Get the operation mode of the task graph

Specified by:

getOperationMode in interface TaskContext

Returns:

the operation mode

reset

public void reset()

Reset the context

Specified by:

reset in interface TaskContext

taskIndex

public int taskIndex()

The task index

Specified by:

taskIndex in interface TaskContext

Returns:

index

globalTaskId

public int globalTaskId()

Globally unique id

Specified by:

globalTaskId in interface TaskContext

Returns:

the task id

taskId

public int taskId()

Get the task id for this task

Specified by:

taskId in interface TaskContext

Returns:

task id

taskName

public java.lang.String taskName()

Name of the task

Specified by:

taskName in interface TaskContext

getParallelism

public int getParallelism()

Get the parallism of the task

Specified by:

getParallelism in interface TaskContext

Returns:

number of parallel instances

getWorkerId

public int getWorkerId()

Get the worker id this task is running

Specified by:

getWorkerId in interface TaskContext

Returns:

worker id

getConfigurations

public java.util.Map<java.lang.String,java.lang.Object> getConfigurations()

Get the task specific configurations

Specified by:

getConfigurations in interface TaskContext

Returns:

map of configurations

getConfig

public java.lang.Object getConfig(java.lang.String name)

Get a configuration with a name

Specified by:

getConfig in interface TaskContext

Parameters:

name - name of the config

Returns:

the config, if not found return null

getOutEdges

public java.util.Map<java.lang.String,java.lang.String> getOutEdges()

Get the out edges of this task

Specified by:

getOutEdges in interface TaskContext

Returns:

the output edges, edge name and task connected to this edge

getInEdges

public java.util.Map<java.lang.String,java.util.Set<java.lang.String>> getInEdges()

Get the edge names and the tasks connected using those edges

Specified by:

getInEdges in interface TaskContext

Returns:

a map with edge, and task connected to this edge

write

public boolean write(java.lang.String edge,
                     java.lang.Object key,
                     java.lang.Object message)

Write a message with a key

Specified by:

write in interface TaskContext

Parameters:

edge - the edge

key - key

message - message

Returns:

true if the message is accepted

write

public boolean write(java.lang.String edge,
                     java.lang.Object message)

Write a message to the destination

Specified by:

write in interface TaskContext

Parameters:

edge - edge

message - message

writeBarrier

public boolean writeBarrier(java.lang.String edge,
                            java.lang.Object message)

Description copied from interface: TaskContext

Write a barrier message to the destination

Specified by:

writeBarrier in interface TaskContext

Parameters:

edge - edge

message - message

writeEnd

public boolean writeEnd(java.lang.String edge,
                        java.lang.Object message)

Write the last message

Specified by:

writeEnd in interface TaskContext

Parameters:

edge - edge

message - message

writeEnd

public boolean writeEnd(java.lang.String edge,
                        java.lang.Object key,
                        java.lang.Object message)

Write the last message

Specified by:

writeEnd in interface TaskContext

Parameters:

edge - edge

key - key

message - message

end

public void end(java.lang.String edge)

End the current writing

Specified by:

end in interface TaskContext

Parameters:

edge - edge

endAll

public void endAll()

Ends all edges

Specified by:

endAll in interface TaskContext

isDone

public boolean isDone(java.lang.String edge)

Return true, if this task is done

Specified by:

isDone in interface TaskContext

Parameters:

edge - edge name

Returns:

boolean

isCompleted

public boolean isCompleted()

Weather all the edges are finished (whether the task is completed)

Returns:

true if all the edges are finished