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

Class STWindowEventTimeExample.ProcessFunctionImpl

java.lang.Object

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

All Implemented Interfaces:

IFunction<IntData>, IWindowFunction<IntData>, ProcessWindowedFunction<IntData>, java.io.Serializable

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.ProcessFunctionImpl
extends java.lang.Object
implements ProcessWindowedFunction<IntData>

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ProcessFunctionImpl()

Method Summary

Modifier and Type	Method and Description
IntData	onMessage(IntData object1, IntData object2) The actual message callback
IWindowMessage<IntData>	process(IWindowMessage<IntData> windowMessage)
IMessage<IntData>	processLateMessage(IMessage<IntData> lateMessage)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessFunctionImpl

protected ProcessFunctionImpl()

Method Detail

process

public IWindowMessage<IntData> process(IWindowMessage<IntData> windowMessage)

Specified by:

process in interface ProcessWindowedFunction<IntData>

processLateMessage

public IMessage<IntData> processLateMessage(IMessage<IntData> lateMessage)

Specified by:

processLateMessage in interface ProcessWindowedFunction<IntData>

onMessage

public IntData onMessage(IntData object1,
                         IntData object2)

Description copied from interface: IFunction

The actual message callback

Specified by:

onMessage in interface IFunction<IntData>

Parameters:

object1 - the actual message

object2 - the actual message