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

Class ComputeTSet<O,I>

java.lang.Object

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

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

edu.iu.dsc.tws.tset.sets.batch.BatchTSetImpl<O>

edu.iu.dsc.tws.tset.sets.batch.ComputeTSet<O,I>

All Implemented Interfaces:

AcceptingData<O>, BatchTSet<O>, TSet<O>, StoringData<O>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class ComputeTSet<O,I>
extends BatchTSetImpl<O>

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
ComputeTSet()
ComputeTSet(BatchEnvironment tSetEnv, ComputeCollectorFunc<O,I> computeFn, int parallelism, Schema inputSchema)
ComputeTSet(BatchEnvironment tSetEnv, ComputeFunc<O,I> computeFn, int parallelism, Schema inputSchema)
ComputeTSet(BatchEnvironment tSetEnv, java.lang.String name, ComputeCollectorFunc<O,I> computeFn, int parallelism, Schema inputSchema)
ComputeTSet(BatchEnvironment tSetEnv, java.lang.String name, ComputeFunc<O,I> computeFn, int parallelism, Schema inputSchema)

Method Summary

Modifier and Type	Method and Description
ComputeTSet<O,I>	addInput(java.lang.String key, StorableTBase<?> input) Adds data to this TSet
TFunction<O,I>	getComputeFunc() Get the compute function associated with this TSet
ICompute<I>	getINode()
ComputeTSet<O,I>	setName(java.lang.String name) Sets the name
ComputeTSet<O,I>	withSchema(Schema schema) Sets the data type of the TSet output.

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

allGather, allReduce, cache, direct, gather, getTSetEnv, lazyCache, lazyPersist, mapToTuple, partition, partition, persist, pipe, reduce, replicate, union, union

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

ComputeTSet

public ComputeTSet()

ComputeTSet

public ComputeTSet(BatchEnvironment tSetEnv,
                   ComputeFunc<O,I> computeFn,
                   int parallelism,
                   Schema inputSchema)

ComputeTSet

public ComputeTSet(BatchEnvironment tSetEnv,
                   ComputeCollectorFunc<O,I> computeFn,
                   int parallelism,
                   Schema inputSchema)

ComputeTSet

public ComputeTSet(BatchEnvironment tSetEnv,
                   java.lang.String name,
                   ComputeFunc<O,I> computeFn,
                   int parallelism,
                   Schema inputSchema)

ComputeTSet

public ComputeTSet(BatchEnvironment tSetEnv,
                   java.lang.String name,
                   ComputeCollectorFunc<O,I> computeFn,
                   int parallelism,
                   Schema inputSchema)

Method Detail

setName

public ComputeTSet<O,I> setName(java.lang.String name)

Description copied from interface: TSet

Sets the name

addInput

public ComputeTSet<O,I> addInput(java.lang.String key,
                                 StorableTBase<?> input)

Description copied from interface: BatchTSet

Adds data to this TSet

Specified by:

addInput in interface AcceptingData<O>

Specified by:

addInput in interface BatchTSet<O>

Overrides:

addInput in class BatchTSetImpl<O>

Parameters:

key - the key used to store the given TSet

input - a @StorableTBase TSet to be added as an input

Returns:

this test

withSchema

public ComputeTSet<O,I> withSchema(Schema schema)

Description copied from interface: TSet

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 TSet<O>

Overrides:

withSchema in class BatchTSetImpl<O>

Parameters:

schema - data type as a MessageType

Returns:

this TSet

getINode

public ICompute<I> getINode()

getComputeFunc

public TFunction<O,I> getComputeFunc()

Get the compute function associated with this TSet

Returns:

the compute function