edu.iu.dsc.tws.tset.sets.streaming

Class SSinkTSet<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.streaming.StreamingTSetImpl<T>

edu.iu.dsc.tws.tset.sets.streaming.SSinkTSet<T>

All Implemented Interfaces:

StreamingTSet<T>, TSet<T>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class SSinkTSet<T>
extends StreamingTSetImpl<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
SSinkTSet(StreamingEnvironment tSetEnv, SinkFunc<T> s, int parallelism, Schema inputSchema) Creates SinkTSet with the given parameters
SSinkTSet(StreamingEnvironment 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
ICompute	getINode()
SSinkTSet<T>	setName(java.lang.String n) Sets the name
SSinkTSet<T>	withSchema(Schema schema) Sets the data type of the TSet output.

Methods inherited from class edu.iu.dsc.tws.tset.sets.streaming.StreamingTSetImpl

allGather, allReduce, direct, gather, getTSetEnv, mapToTuple, partition, partition, 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

SSinkTSet

public SSinkTSet(StreamingEnvironment 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

SSinkTSet

public SSinkTSet(StreamingEnvironment tSetEnv,
                 SinkFunc<T> s,
                 int parallelism,
                 Schema inputSchema)

Creates SinkTSet with the given parameters

Parameters:

tSetEnv - The TSetEnv used for execution

s - The Sink function to be used

parallelism - the parallelism of the sink

Method Detail

setName

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

Description copied from interface: TSet

Sets the name

withSchema

public SSinkTSet<T> 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<T>

Overrides:

withSchema in class StreamingTSetImpl<T>

Parameters:

schema - data type as a MessageType

Returns:

this TSet

getINode

public ICompute getINode()