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

Interface INode

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

ICompute<T>, ISink, ISource, IWindowCompute<T>, IWindowedSink<T>, Twister2StormNode

All Known Implementing Classes:

AbstractIterableDataCompute, AbstractListDataCompute, AbstractSingleDataCompute, AbstractSingleWindowDataCompute, AbstractSingleWindowDataSink, AggregateWindow, AllGatherCompute, AllReduceCompute, BaseCompute, BaseComputeOp, BaseNode, BaseSource, BaseWindowCompute, BaseWindowedSink, BaseWindowSink, BaseWindowSource, BasicComputation.ComputeTask, BasicComputation.GraphInitialization, BasicComputation.GraphPartiton, BasicComputation.SourceTask, BBroadCastCompute, BenchTaskWorker.SourceTask, BenchTaskWorker.SourceWindowTask, BenchTaskWorker.SourceWindowTimeStampTask, BenchWindowTaskWorker.SourceWindowTask, BJoinCompute, BKeyedGatherGroupedCompute, BKeyedGatherUnGroupedCompute, BKeyedPartitionCompute, BKeyedReduceCompute, BPartitionCompute, BTAllGatherExample.AllGatherSinkTask, BTAllReduceExample.AllReduceSinkTask, BTBroadCastExample.BroadcastSinkTask, BTDirectExample.PartitionSinkTask, BTGatherExample.GatherSinkTask, BTJoinExample.JoinSinkTask, BTJoinExample.JoinSource, BTKeyedGatherExample.KeyedGatherGroupedSinkTask, BTKeyedReduceExample.KeyedReduceSinkTask, BTPartitionExample.PartitionSinkTask, BTPartitionKeyedExample.BKeyedPartitionSinkTask, BTReduceExample.ReduceSinkTask, CheckpointedSourceOp, CheckpointingSGatherSink, CheckpointingTaskExample.ComputeTask, CheckpointingTaskExample.SinkTask, CheckpointingTaskExample.SourceTask, ComputeCollectorOp, ComputeCollectorToTupleOp, ComputeOp, ComputeToTupleOp, ConnectedSink, ConnectedSource, ConstructDataStr, CSVInputFormatTest.TestSink, CSVInputFormatTest.TestSource, DataFileReplicatedReadSource, DataFileSink, DataFileSplittedReadSource, DataGeneratorSink, DataGeneratorSource, DataInitializationSinkTask, DataObjectCompute, DataObjectCSVSource, DataObjectSink, DataObjectSink, DataObjectSource, DataParallelTask, DataSinkTask, DataStreamer, DirectCompute, FoldWindow, GatherCompute, GraphDataCompute, GraphDataSink, GraphDataSource, InputDataStreamer, IterativeDataStream, IterativePredictionDataStreamer, IterativeStreamingCompute, IterativeStreamingDataStreamer, IterativeStreamingSinkEvaluator, IterativeStreamingWindowedCompute, IterativeSVMAccuracyReduce, IterativeSVMCompute, IterativeSVMDataObjectCompute, IterativeSVMDataObjectDirectSink, IterativeSVMDataPointReduce, IterativeSVMPrimaryDataObjectDirectSink, IterativeSVMPrimaryWeightVectorObjectCompute, IterativeSVMReduce, IterativeSVMWeightVectorObjectCompute, IterativeSVMWeightVectorObjectDirectSink, IterativeSVMWeightVectorReduce, KafkaExample.KSink, KafkaExample.KSource, KafkaSource, KeyedGatherCompute, KeyedSourceOp, KMeansComputeJob.KMeansAllReduceTask, KMeansComputeJob.KMeansSourceTask, KMeansConnectedDataflowExample.KMeansAllReduceTask, KMeansConnectedDataflowExample.KMeansSourceTask, KMeansDataObjectCompute, KMeansDataObjectDirectSink, PageRankValueHolderCompute, PageRankValueHolderSink, PointDataSource, PredictionReduceTask, PredictionSourceTask, ProcessWindow, ReduceCompute, ReduceWindow, RowComupteCollectorOp, RowItrComputeCollectorOp, RowSinkOp, RowSourceOp, SBroadCastCompute, SinkOp, SKeyedPartitionCompute, SKeyedReduceCompute, SourceOp, SPartitionCompute, SsspInitialCompute, SsspInitialSink, STAllGatherExample.AllGatherSinkTask, STAllReduceExample.AllReduceSinkTask, STBroadCastExample.BroadCastSinkTask, STGatherExample.GatherSinkTask, STKeyedGatherExample.KeyedGatherSinkTask, STKeyedReduceExample.KeyedReduceSinkTask, StormBenchmark.DataSink, StormBenchmark.Generator, 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, SVMDataObjectSource, SVMReduce, TaskGraphBuildTest.TestSink1, TaskGraphBuildTest.TestSink2, TaskGraphBuildTest.TestSource, TaskSchedulerClassTest.TestCompute, TaskSchedulerClassTest.TestComputeChild, TaskSchedulerClassTest.TestSink, TaskSchedulerClassTest.TestSource, TeraSort.FileDataSource, TeraSort.RandomDataSource, TeraSort.Receiver, TeraSort.Sampler, TeraSort.SamplerReduce, Twister2Bolt, Twister2Spout, WindowComputeOp, WindowedCompute

public interface INode
extends java.io.Serializable

This is the base interface of all nodes in the dataflow graph.

Method Summary

Modifier and Type	Method and Description
void	prepare(Config cfg, TaskContext context) Prepare the task to be executed

Method Detail

prepare

void prepare(Config cfg,
             TaskContext context)

Prepare the task to be executed

Parameters:

cfg - the configuration

context - the task context, this has runtime information about the task