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

Class RowComputeTSet

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.RowComputeTSet

All Implemented Interfaces:

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

public class RowComputeTSet
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
RowComputeTSet(BatchEnvironment tSetEnv, ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFn, int parallelism, RowSchema inputSchema, boolean iterative)
RowComputeTSet(BatchEnvironment tSetEnv, java.lang.String name, ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFn, int parallelism, RowSchema inputSchema, boolean iterative)

Method Summary

Modifier and Type	Method and Description
TFunction<Row,java.util.Iterator<Row>>	getComputeFunc() Get the compute function associated with this TSet
INode	getINode()

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

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

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

RowComputeTSet

public RowComputeTSet(BatchEnvironment tSetEnv,
                      ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFn,
                      int parallelism,
                      RowSchema inputSchema,
                      boolean iterative)

RowComputeTSet

public RowComputeTSet(BatchEnvironment tSetEnv,
                      java.lang.String name,
                      ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFn,
                      int parallelism,
                      RowSchema inputSchema,
                      boolean iterative)

Method Detail

getINode

public INode getINode()

getComputeFunc

public TFunction<Row,java.util.Iterator<Row>> getComputeFunc()

Get the compute function associated with this TSet

Returns:

the compute function