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

Interface ISource

All Superinterfaces:

INode, java.io.Serializable

All Known Implementing Classes:

BaseSource, BaseWindowSource, BasicComputation.SourceTask, BenchTaskWorker.SourceTask, BenchTaskWorker.SourceWindowTask, BenchTaskWorker.SourceWindowTimeStampTask, BenchWindowTaskWorker.SourceWindowTask, BTJoinExample.JoinSource, CheckpointedSourceOp, CheckpointingTaskExample.SourceTask, ConnectedSource, CSVInputFormatTest.TestSource, DataFileReplicatedReadSource, DataFileSplittedReadSource, DataGeneratorSource, DataObjectCSVSource, DataObjectSource, DataParallelTask, DataStreamer, GraphDataSource, InputDataStreamer, IterativeDataStream, IterativePredictionDataStreamer, IterativeStreamingDataStreamer, KafkaExample.KSource, KafkaSource, KeyedSourceOp, KMeansComputeJob.KMeansSourceTask, KMeansConnectedDataflowExample.KMeansSourceTask, PointDataSource, PredictionSourceTask, RowSourceOp, SourceOp, StormBenchmark.Generator, SVMDataObjectSource, TaskGraphBuildTest.TestSource, TaskSchedulerClassTest.TestSource, TeraSort.FileDataSource, TeraSort.RandomDataSource, TeraSort.Sampler, Twister2Spout

public interface ISource
extends INode

The interface that all data input sources (Batch, Streaming, etc)

Method Summary

Modifier and Type	Method and Description
void	execute() Execute without an incoming message

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

prepare

Method Detail

execute

void execute()

Execute without an incoming message