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

Class STWindowExample.AggregateFunctionImpl

java.lang.Object

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

All Implemented Interfaces:

IFunction<int[]>, AggregateWindowedFunction<int[]>, IWindowFunction<int[]>, java.io.Serializable

Enclosing class:

STWindowExample

protected static class STWindowExample.AggregateFunctionImpl
extends java.lang.Object
implements AggregateWindowedFunction<int[]>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AggregateFunctionImpl(int weight1, int weight2)

Method Summary

Modifier and Type	Method and Description
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

AggregateFunctionImpl

public AggregateFunctionImpl(int weight1,
                             int weight2)

Method Detail

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