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

Class RowSinkTSet

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

All Implemented Interfaces:

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

public class RowSinkTSet
extends BaseTSetWithSchema<Row>
implements AcceptingData<Row>

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
RowSinkTSet(BatchEnvironment tSetEnv, SinkFunc<Row> sinkFn, int parallelism, Schema inputSchema) Creates SinkTSet with the given parameters
RowSinkTSet(BatchEnvironment tSetEnv, SinkFunc<Row> 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
RowSinkTSet	addInput(java.lang.String key, StorableTBase<?> input) Allows users to pass in other TSets as inputs for a TSet
INode	getINode()
TBase	setName(java.lang.String name) Sets the name for the TBase
RowSinkTSet	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

RowSinkTSet

public RowSinkTSet(BatchEnvironment tSetEnv,
                   SinkFunc<Row> 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

RowSinkTSet

public RowSinkTSet(BatchEnvironment tSetEnv,
                   SinkFunc<Row> 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

addInput

public RowSinkTSet 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<Row>

Parameters:

key - the key used to store the given TSet

input - a StorableTBase TSet to be added as an input

Returns:

this TSet

getINode

public INode getINode()

Specified by:

getINode in interface BuildableTSet

setName

public TBase setName(java.lang.String name)

Description copied from interface: TBase

Sets the name for the TBase

Specified by:

setName in interface TBase

withSchema

public RowSinkTSet withSchema(Schema schema)