edu.snu.coral.common.ir.vertex

Class InitializedSourceVertex<T>

java.lang.Object

edu.snu.coral.common.dag.Vertex

edu.snu.coral.common.ir.vertex.IRVertex

edu.snu.coral.common.ir.vertex.SourceVertex<T>

edu.snu.coral.common.ir.vertex.InitializedSourceVertex<T>

Type Parameters:

T - type of initial data.

All Implemented Interfaces:

Serializable

public final class InitializedSourceVertex<T>
extends SourceVertex<T>

Source vertex with initial data as object.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
InitializedSourceVertex(Iterable<T> initializedSourceData) Constructor.

Method Summary

Modifier and Type	Method and Description
InitializedSourceVertex<T>	getClone()
ReadablesWrapper<T>	getReadableWrapper(int desiredNumOfSplits) Gets parallel readable wrapper.

Methods inherited from class edu.snu.coral.common.ir.vertex.IRVertex

copyExecutionPropertiesTo, getExecutionProperties, getProperty, irVertexPropertiesToString, setProperty

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

getId, getNumericId, propertiesToJSON

Methods inherited from class java.lang.Object

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

Constructor Detail

InitializedSourceVertex

public InitializedSourceVertex(Iterable<T> initializedSourceData)

Constructor.

Parameters:

initializedSourceData - the initial data object.

Method Detail

getClone

public InitializedSourceVertex<T> getClone()

Specified by:

getClone in class IRVertex

Returns:

a clone elemnt of the IRVertex.

getReadableWrapper

public ReadablesWrapper<T> getReadableWrapper(int desiredNumOfSplits)
                                       throws Exception

Description copied from class: SourceVertex

Gets parallel readable wrapper.

Specified by:

getReadableWrapper in class SourceVertex<T>

Parameters:

desiredNumOfSplits - number of splits desired.

Returns:

the wrapper for a list of readers.

Throws:

Exception - if fail to get.