edu.iu.dsc.tws.task.window

Interface IWindowCompute<T>

All Superinterfaces:

ICompute<T>, INode, java.io.Serializable

All Known Implementing Classes:

AbstractSingleWindowDataCompute, AggregateWindow, BaseWindowCompute, BaseWindowedSink, FoldWindow, IterativeStreamingWindowedCompute, ProcessWindow, ReduceWindow, STWindowCustomExample.DirectCustomWindowReceiver, STWindowEventTimeExample.DirectAggregateWindowedTask, STWindowEventTimeExample.DirectFoldWindowedTask, STWindowEventTimeExample.DirectProcessWindowedIntTask, STWindowEventTimeExample.DirectProcessWindowedTask, STWindowEventTimeExample.DirectReduceWindowedTask, STWindowEventTimeExample.DirectWindowedReceivingTask, STWindowExample.DirectAggregateWindowedTask, STWindowExample.DirectFoldWindowedTask, STWindowExample.DirectProcessWindowedTask, STWindowExample.DirectReduceWindowedTask, STWindowExample.DirectWindowedReceivingTask, STWindowMPI.DirectWindowedReceivingTask, WindowComputeOp, WindowedCompute

public interface IWindowCompute<T>
extends ICompute<T>

Method Summary

Modifier and Type	Method and Description
boolean	execute(IMessage<T> message) Execute with an incoming message

Methods inherited from interface edu.iu.dsc.tws.api.compute.nodes.ICompute

endExecute

Methods inherited from interface edu.iu.dsc.tws.api.compute.nodes.INode

prepare

Method Detail

execute

boolean execute(IMessage<T> message)

Description copied from interface: ICompute

Execute with an incoming message

Specified by:

execute in interface ICompute<T>