edu.iu.dsc.tws.examples.task.streaming.windowing

Class STWindowEventTimeExample.FoldFunctionImpl

java.lang.Object

edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.FoldFunctionImpl

All Implemented Interfaces:

IFunction<int[]>, FoldWindowedFunction<int[],java.lang.String>, IWindowFunction<int[]>, java.io.Serializable

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.FoldFunctionImpl
extends java.lang.Object
implements FoldWindowedFunction<int[],java.lang.String>

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FoldFunctionImpl()

Method Summary

Modifier and Type	Method and Description
java.lang.String	computeFold()
int[]	onMessage(int[] object1, int[] object2) The actual message callback

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FoldFunctionImpl

protected FoldFunctionImpl()

Method Detail

computeFold

public java.lang.String computeFold()

Specified by:

computeFold in interface FoldWindowedFunction<int[],java.lang.String>

onMessage

public int[] onMessage(int[] object1,
                       int[] object2)

Description copied from interface: IFunction

The actual message callback

Specified by:

onMessage in interface IFunction<int[]>

Parameters:

object1 - the actual message

object2 - the actual message