edu.snu.coral.common.ir.vertex

Class SourceVertex<O>

java.lang.Object

edu.snu.coral.common.dag.Vertex

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

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

Type Parameters:

O - output type.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

BeamBoundedSourceVertex, EmptyComponents.EmptySourceVertex, InitializedSourceVertex, SparkBoundedSourceVertex

public abstract class SourceVertex<O>
extends IRVertex

IRVertex that reads data from an external source. It is to be implemented in the compiler frontend with source-specific data fetching logic.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SourceVertex()

Method Summary

Modifier and Type	Method and Description
abstract ReadablesWrapper<O>	getReadableWrapper(int desiredNumOfSplits) Gets parallel readable wrapper.

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

copyExecutionPropertiesTo, getClone, 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

SourceVertex

public SourceVertex()

Method Detail

getReadableWrapper

public abstract ReadablesWrapper<O> getReadableWrapper(int desiredNumOfSplits)
                                                throws Exception

Gets parallel readable wrapper.

Parameters:

desiredNumOfSplits - number of splits desired.

Returns:

the wrapper for a list of readers.

Throws:

Exception - if fail to get.