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

Class WindowComputeTSet<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.streaming.StreamingTSetImpl<O>

edu.iu.dsc.tws.tset.sets.streaming.WindowComputeTSet<O,I>

Type Parameters:

O - Output type of TSet

I - Input Type of TSet

All Implemented Interfaces:

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

public class WindowComputeTSet<O,I>
extends StreamingTSetImpl<O>

WindowComputeTSet is the TSet abstraction designed for windowing. This class contains windowing functions. 1. Process Function (calls the compute function and process the TSet elements on user the defined function) 2. Aggregate Function (calls the compute and do the TSet element aggregation on user-defined logic.

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
WindowComputeTSet(StreamingEnvironment tSetEnv, int parallelism, WindowParameter winParam, Schema inputSchema)
WindowComputeTSet(StreamingEnvironment tSetEnv, java.lang.String name, int parallelism, WindowParameter winParam, Schema inputSchema)

Method Summary

Modifier and Type	Method and Description
WindowComputeTSet<O,I>	aggregate(AggregateFunc<O> aggregateFunction) This method reduces the values inside a window
ICompute<I>	getINode()
WindowComputeTSet<O,I>	process(WindowComputeFunc<O,I> processFunction)
WindowComputeTSet<O,I>	setName(java.lang.String name) Sets the name
WindowComputeTSet<O,I>	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

WindowComputeTSet

public WindowComputeTSet(StreamingEnvironment tSetEnv,
                         int parallelism,
                         WindowParameter winParam,
                         Schema inputSchema)

WindowComputeTSet

public WindowComputeTSet(StreamingEnvironment tSetEnv,
                         java.lang.String name,
                         int parallelism,
                         WindowParameter winParam,
                         Schema inputSchema)

Method Detail

setName

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

Description copied from interface: TSet

Sets the name

getINode

public ICompute<I> getINode()

process

public WindowComputeTSet<O,I> process(WindowComputeFunc<O,I> processFunction)

aggregate

public WindowComputeTSet<O,I> aggregate(AggregateFunc<O> aggregateFunction)

This method reduces the values inside a window

Parameters:

aggregateFunction - reduce function definition

Returns:

reduced value of type O

withSchema

public WindowComputeTSet<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 StreamingTSetImpl<O>

Parameters:

schema - data type as a MessageType

Returns:

this TSet