edu.snu.coral.runtime.common.plan.physical

Class BoundedSourceTask<O>

java.lang.Object

edu.snu.coral.common.dag.Vertex

edu.snu.coral.runtime.common.plan.physical.Task

edu.snu.coral.runtime.common.plan.physical.BoundedSourceTask<O>

Type Parameters:

O - the output type.

All Implemented Interfaces:

Serializable

public final class BoundedSourceTask<O>
extends Task

BoundedSourceTask.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BoundedSourceTask(String taskId, String irVertexId, ReadablesWrapper<O> readablesWrapper) Constructor.

Method Summary

Modifier and Type	Method and Description
Readable<O>	getReadable(int readableIdx)

Methods inherited from class edu.snu.coral.runtime.common.plan.physical.Task

getIrVertexId, propertiesToJSON

Methods inherited from class edu.snu.coral.common.dag.Vertex

getId, getNumericId

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedSourceTask

public BoundedSourceTask(String taskId,
                         String irVertexId,
                         ReadablesWrapper<O> readablesWrapper)

Constructor.

Parameters:

taskId - id of the task.

irVertexId - id of the IR vertex.

readablesWrapper - the wrapper of the readables for the source data.

Method Detail

getReadable

public Readable<O> getReadable(int readableIdx)
                        throws Exception

Parameters:

readableIdx - the index of the target readable.

Returns:

the readable of source data.

Throws:

Exception - if fail to get.