edu.iu.dsc.tws.task.window.api

Interface IWindowedSink<T>

All Superinterfaces:

INode, java.io.Serializable

All Known Implementing Classes:

AbstractSingleWindowDataSink, AggregateWindow, BaseWindowedSink, BaseWindowSink, 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

public interface IWindowedSink<T>
extends INode

Method Summary

Modifier and Type	Method and Description
boolean	execute(IMessage<T> message)

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

prepare

Method Detail

execute

boolean execute(IMessage<T> message)