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

Class SinkTSet<T>

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.SinkTSet<T>

All Implemented Interfaces:

AcceptingData<T>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class SinkTSet<T>
extends BaseTSetWithSchema<T>
implements AcceptingData<T>

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
SinkTSet(BatchEnvironment tSetEnv, SinkFunc<T> sinkFn, int parallelism, Schema inputSchema) Creates SinkTSet with the given parameters
SinkTSet(BatchEnvironment tSetEnv, SinkFunc<T> s, Schema inputSchema) Creates SinkTSet with the given parameters, the parallelism of the TSet is taken as 1

Method Summary

Modifier and Type	Method and Description
SinkTSet<T>	addInput(java.lang.String key, StorableTBase<?> input) Allows users to pass in other TSets as inputs for a TSet
ICompute	getINode()
SinkTSet<T>	setName(java.lang.String n) Sets the name for the TBase
SinkTSet<T>	withSchema(Schema schema)

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, getTSetEnv, 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.tset.sets.BuildableTSet

build

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

generateID, getTBaseGraph

Constructor Detail

SinkTSet

public SinkTSet(BatchEnvironment tSetEnv,
                SinkFunc<T> s,
                Schema inputSchema)

Creates SinkTSet with the given parameters, the parallelism of the TSet is taken as 1

Parameters:

tSetEnv - The TSetEnv used for execution

s - The Sink function to be used

SinkTSet

public SinkTSet(BatchEnvironment tSetEnv,
                SinkFunc<T> sinkFn,
                int parallelism,
                Schema inputSchema)

Creates SinkTSet with the given parameters

Parameters:

tSetEnv - The TSetEnv used for execution

sinkFn - The Sink function to be used

parallelism - the parallelism of the sink

Method Detail

getINode

public ICompute getINode()

Specified by:

getINode in interface BuildableTSet

setName

public SinkTSet<T> setName(java.lang.String n)

Description copied from interface: TBase

Sets the name for the TBase

Specified by:

setName in interface TBase

addInput

public SinkTSet<T> addInput(java.lang.String key,
                            StorableTBase<?> input)

Description copied from interface: AcceptingData

Allows users to pass in other TSets as inputs for a TSet

Specified by:

addInput in interface AcceptingData<T>

Parameters:

key - the key used to store the given TSet

input - a StorableTBase TSet to be added as an input

Returns:

this TSet

withSchema

public SinkTSet<T> withSchema(Schema schema)