edu.iu.dsc.tws.api.tset

Class TSetContext

java.lang.Object

edu.iu.dsc.tws.api.tset.TSetContext

All Implemented Interfaces:

java.io.Serializable

public class TSetContext
extends java.lang.Object
implements java.io.Serializable

This is the runtime context for a TSet. This holds the information related to indices, inputs etc. This will be passed on to TFunction in the runtime, so that corresponding TSet information is available for the functions.

This is made Serializable because, it will be created with instances of BaseOp and it would need to be serialized and deserialized to create TaskInstances.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TSetContext() Creates and empty TSet Context
TSetContext(Config cfg, int tSetIndex, java.lang.String tSetId, java.lang.String tSetName, int parallelism, int wId, java.util.Map<java.lang.String,java.lang.Object> configs) TSet context

Method Summary

Modifier and Type	Method and Description
void	addInput(java.lang.String key, DataPartition<?> data) Adds a input object into the map
void	addInputMap(java.util.Map<java.lang.String,DataPartition<?>> map) Adds the given map into inputMap
Config	getConfig() Configuration
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 tSet specific configurations
java.lang.String	getId() tSet id
int	getIndex() The tSet index
DataPartition<?>	getInput(java.lang.String key) Retrives the input object that corresponds to the given key
java.util.Map<java.lang.String,DataPartition<?>>	getInputMap() get the complete input map
Schema	getInputSchema() Returns the input schema of the TSet
java.lang.String	getName() Name of the tSet
Schema	getOutputSchema() Returns the output schema of the TSet
int	getParallelism() Get the parallelism of the tSet
int	getWorkerId() Get the worker id this tSet is running
void	setId(java.lang.String id) Sets the ID of the corresponding TSet
void	setInputMap(java.util.Map<java.lang.String,DataPartition<?>> inputMap) Set a new input map
void	setName(java.lang.String name) Sets the tset name
void	setParallelism(int parallelism) Sets the TSet parallelism
void	updateRuntimeInfo(Config conf, TaskContext taskCtx) Updates the runtime information for the TSet instances

Methods inherited from class java.lang.Object

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

Constructor Detail

TSetContext

public TSetContext()

Creates and empty TSet Context

TSetContext

public TSetContext(Config cfg,
                   int tSetIndex,
                   java.lang.String tSetId,
                   java.lang.String tSetName,
                   int parallelism,
                   int wId,
                   java.util.Map<java.lang.String,java.lang.Object> configs)

TSet context

Parameters:

cfg - configuration

tSetIndex - index

tSetId - id

tSetName - name

parallelism - parallelism

wId - worker id

configs - configuration

Method Detail

getIndex

public int getIndex()

The tSet index

Returns:

index

getId

public java.lang.String getId()

tSet id

Returns:

the tSet id

getName

public java.lang.String getName()

Name of the tSet

getParallelism

public int getParallelism()

Get the parallelism of the tSet

Returns:

number of parallel instances

getWorkerId

public int getWorkerId()

Get the worker id this tSet is running

Returns:

worker id

getConfigurations

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

Get the tSet specific configurations

Returns:

map of configurations

getConfig

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

Get a configuration with a name

Parameters:

name - name of the config

Returns:

the config, if not found return null

getConfig

public Config getConfig()

Configuration

Returns:

configuration

getInputMap

public java.util.Map<java.lang.String,DataPartition<?>> getInputMap()

get the complete input map

Returns:

the current input map

getInput

public DataPartition<?> getInput(java.lang.String key)

Retrives the input object that corresponds to the given key

Parameters:

key - key of the input object

Returns:

the input object if the key is present or null

getInputSchema

public Schema getInputSchema()

Returns the input schema of the TSet

Returns:

input schema

getOutputSchema

public Schema getOutputSchema()

Returns the output schema of the TSet

Returns:

output schema

addInput

public void addInput(java.lang.String key,
                     DataPartition<?> data)

Adds a input object into the map

Parameters:

key - the key to be associated with the input object

data - the input object

setInputMap

public void setInputMap(java.util.Map<java.lang.String,DataPartition<?>> inputMap)

Set a new input map

Parameters:

inputMap - the map to be set for this context

addInputMap

public void addInputMap(java.util.Map<java.lang.String,DataPartition<?>> map)

Adds the given map into inputMap

Parameters:

map - the map to be added

setId

public void setId(java.lang.String id)

Sets the ID of the corresponding TSet

Parameters:

id - tset ID

setName

public void setName(java.lang.String name)

Sets the tset name

Parameters:

name - tset name

setParallelism

public void setParallelism(int parallelism)

Sets the TSet parallelism

Parameters:

parallelism - parallelism

updateRuntimeInfo

public void updateRuntimeInfo(Config conf,
                              TaskContext taskCtx)

Updates the runtime information for the TSet instances

Parameters:

conf - configuration

taskCtx - task context