edu.iu.dsc.tws.tset.sets.batch.row

Class RowSourceTSet

java.lang.Object

edu.iu.dsc.tws.tset.sets.BaseTSet<T>

edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema<Row>

edu.iu.dsc.tws.tset.sets.batch.row.BatchRowTSetImpl

edu.iu.dsc.tws.tset.sets.batch.row.RowSourceTSet

All Implemented Interfaces:

AcceptingData<Row>, BatchRowTSet, StoringData<Row>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class RowSourceTSet
extends BatchRowTSetImpl

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

BaseTSet.StateType

Constructor Summary

Constructors

Constructor and Description
RowSourceTSet(BatchEnvironment tSetEnv, SourceFunc<Row> src, int parallelism)
RowSourceTSet(BatchEnvironment tSetEnv, java.lang.String name, SourceFunc<Row> src, int parallelism, Schema schema)

Method Summary

Modifier and Type	Method and Description
INode	getINode()
RowSourceTSet	withSchema(RowSchema schema) Sets the data type of the TSet output.

Methods inherited from class edu.iu.dsc.tws.tset.sets.batch.row.BatchRowTSetImpl

addInput, cache, direct, getTSetEnv, join, lazyCache, lazyPersist, partition, persist, pipe, setName

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema

getInputSchema, getOutputSchema, setOutputSchema

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

addChildToGraph, addChildToGraph, equals, getId, getInputs, getName, getParallelism, getStateType, hashCode, isMutable, rename, setMutable, setStateType, setTSetEnv, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

getId, getName

Methods inherited from interface edu.iu.dsc.tws.tset.sets.BuildableTSet

build

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Constructor Detail

RowSourceTSet

public RowSourceTSet(BatchEnvironment tSetEnv,
                     SourceFunc<Row> src,
                     int parallelism)

RowSourceTSet

public RowSourceTSet(BatchEnvironment tSetEnv,
                     java.lang.String name,
                     SourceFunc<Row> src,
                     int parallelism,
                     Schema schema)

Method Detail

getINode

public INode getINode()

withSchema

public RowSourceTSet withSchema(RowSchema schema)

Description copied from interface: BatchRowTSet

Sets the data type of the TSet output. This will be used in the packers for efficient SER-DE operations in the following TLinks

Specified by:

withSchema in interface BatchRowTSet

Overrides:

withSchema in class BatchRowTSetImpl

Parameters:

schema - data type as a MessageType

Returns:

this TSet