edu.iu.dsc.tws.api.compute.nodes

Interface ICompute<T>

All Superinterfaces:

INode, java.io.Serializable

All Known Subinterfaces:

IWindowCompute<T>

All Known Implementing Classes:

AbstractIterableDataCompute, AbstractListDataCompute, AbstractSingleDataCompute, AbstractSingleWindowDataCompute, AggregateWindow, AllGatherCompute, AllReduceCompute, BaseCompute, BaseComputeOp, BaseWindowCompute, BaseWindowedSink, BasicComputation.ComputeTask, BasicComputation.GraphInitialization, BasicComputation.GraphPartiton, BBroadCastCompute, BJoinCompute, BKeyedGatherGroupedCompute, BKeyedGatherUnGroupedCompute, BKeyedPartitionCompute, BKeyedReduceCompute, BPartitionCompute, BTAllGatherExample.AllGatherSinkTask, BTAllReduceExample.AllReduceSinkTask, BTBroadCastExample.BroadcastSinkTask, BTDirectExample.PartitionSinkTask, BTGatherExample.GatherSinkTask, BTJoinExample.JoinSinkTask, BTKeyedGatherExample.KeyedGatherGroupedSinkTask, BTKeyedReduceExample.KeyedReduceSinkTask, BTPartitionExample.PartitionSinkTask, BTPartitionKeyedExample.BKeyedPartitionSinkTask, BTReduceExample.ReduceSinkTask, CheckpointingSGatherSink, CheckpointingTaskExample.ComputeTask, CheckpointingTaskExample.SinkTask, ComputeCollectorOp, ComputeCollectorToTupleOp, ComputeOp, ComputeToTupleOp, ConnectedSink, ConstructDataStr, CSVInputFormatTest.TestSink, DataFileSink, DataGeneratorSink, DataInitializationSinkTask, DataObjectCompute, DataObjectSink, DataObjectSink, DataSinkTask, DirectCompute, FoldWindow, GatherCompute, GraphDataCompute, GraphDataSink, IterativeStreamingCompute, IterativeStreamingSinkEvaluator, IterativeStreamingWindowedCompute, IterativeSVMAccuracyReduce, IterativeSVMCompute, IterativeSVMDataObjectCompute, IterativeSVMDataObjectDirectSink, IterativeSVMDataPointReduce, IterativeSVMPrimaryDataObjectDirectSink, IterativeSVMPrimaryWeightVectorObjectCompute, IterativeSVMReduce, IterativeSVMWeightVectorObjectCompute, IterativeSVMWeightVectorObjectDirectSink, IterativeSVMWeightVectorReduce, KafkaExample.KSink, KeyedGatherCompute, KMeansComputeJob.KMeansAllReduceTask, KMeansConnectedDataflowExample.KMeansAllReduceTask, KMeansDataObjectCompute, KMeansDataObjectDirectSink, PageRankValueHolderCompute, PageRankValueHolderSink, PredictionReduceTask, ProcessWindow, ReduceCompute, ReduceWindow, RowComupteCollectorOp, RowItrComputeCollectorOp, RowSinkOp, SBroadCastCompute, SinkOp, SKeyedPartitionCompute, SKeyedReduceCompute, SPartitionCompute, SsspInitialCompute, SsspInitialSink, STAllGatherExample.AllGatherSinkTask, STAllReduceExample.AllReduceSinkTask, STBroadCastExample.BroadCastSinkTask, STGatherExample.GatherSinkTask, STKeyedGatherExample.KeyedGatherSinkTask, STKeyedReduceExample.KeyedReduceSinkTask, StormBenchmark.DataSink, STPartitionExample.PartitionSinkTask, STPartitionKeyedExample.SKeyedPartitionSinkTask, STReduceExample.ReduceSinkTask, STWindowCustomExample.DirectCustomWindowReceiver, STWindowEventTimeExample.DirectAggregateWindowedTask, STWindowEventTimeExample.DirectFoldWindowedTask, STWindowEventTimeExample.DirectProcessWindowedIntTask, STWindowEventTimeExample.DirectProcessWindowedTask, STWindowEventTimeExample.DirectReceiveTask, STWindowEventTimeExample.DirectReduceWindowedTask, STWindowEventTimeExample.DirectWindowedReceivingTask, STWindowExample.DirectAggregateWindowedTask, STWindowExample.DirectFoldWindowedTask, STWindowExample.DirectProcessWindowedTask, STWindowExample.DirectReceiveTask, STWindowExample.DirectReduceWindowedTask, STWindowExample.DirectWindowedReceivingTask, STWindowMPI.DirectWindowedReceivingTask, SVMCompute, SVMReduce, TaskGraphBuildTest.TestSink1, TaskGraphBuildTest.TestSink2, TaskSchedulerClassTest.TestCompute, TaskSchedulerClassTest.TestComputeChild, TaskSchedulerClassTest.TestSink, TeraSort.Receiver, TeraSort.SamplerReduce, Twister2Bolt, WindowComputeOp, WindowedCompute

public interface ICompute<T>
extends INode

Base interface for tasks

Method Summary

Modifier and Type	Method and Description
default void	endExecute() Callback that is gets called when the stream ends
boolean	execute(IMessage<T> content) Execute with an incoming message

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

prepare

Method Detail

execute

boolean execute(IMessage<T> content)

Execute with an incoming message

endExecute

default void endExecute()

Callback that is gets called when the stream ends