edu.snu.coral.compiler.frontend.beam.source

Class BeamBoundedSourceVertex<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>

edu.snu.coral.compiler.frontend.beam.source.BeamBoundedSourceVertex<O>

Type Parameters:

O - output type.

All Implemented Interfaces:

Serializable

public final class BeamBoundedSourceVertex<O>
extends SourceVertex<O>

SourceVertex implementation for BoundedSource.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BeamBoundedSourceVertex(org.apache.beam.sdk.io.BoundedSource<O> source) Constructor of BeamBoundedSourceVertex.

Method Summary

Modifier and Type	Method and Description
BeamBoundedSourceVertex	getClone()
ReadablesWrapper<O>	getReadableWrapper(int desiredNumOfSplits) Gets parallel readable wrapper.
String	propertiesToJSON()

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamBoundedSourceVertex

public BeamBoundedSourceVertex(org.apache.beam.sdk.io.BoundedSource<O> source)

Constructor of BeamBoundedSourceVertex.

Parameters:

source - BoundedSource to read from.

Method Detail

getClone

public BeamBoundedSourceVertex getClone()

Specified by:

getClone in class IRVertex

Returns:

a clone elemnt of the IRVertex.

getReadableWrapper

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

Description copied from class: SourceVertex

Gets parallel readable wrapper.

Specified by:

getReadableWrapper in class SourceVertex<O>

Parameters:

desiredNumOfSplits - number of splits desired.

Returns:

the wrapper for a list of readers.

Throws:

Exception - if fail to get.

propertiesToJSON

public String propertiesToJSON()

Overrides:

propertiesToJSON in class Vertex

Returns:

JSON representation of additional properties