edu.iu.dsc.tws.api.compute.modifiers

Interface Closable

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, BootstrapPoint, 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, 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, EntryPoint, FoldWindow, GatherCompute, GraphDataCompute, GraphDataSink, GraphDataSource, InputDataStreamer, IterativeDataStream, IterativePredictionDataStreamer, IterativeStreamingCompute, IterativeStreamingDataStreamer, IterativeStreamingSinkEvaluator, IterativeStreamingWindowedCompute, IterativeSVMAccuracyReduce, IterativeSVMCompute, IterativeSVMDataObjectCompute, IterativeSVMDataObjectDirectSink, IterativeSVMDataPointReduce, IterativeSVMPrimaryDataObjectDirectSink, IterativeSVMPrimaryWeightVectorObjectCompute, IterativeSVMReduce, IterativeSVMWeightVectorObjectCompute, IterativeSVMWeightVectorObjectDirectSink, IterativeSVMWeightVectorReduce, 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, 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, Twister2Environment, WindowComputeOp, WindowedCompute

public interface Closable

A task which needs to clean up resources at the end should implement this method

Method Summary

Modifier and Type	Method and Description
void	close() Close method for cleaning up the resources
default void	reset() Reset the task

Method Detail

close

void close()

Close method for cleaning up the resources

reset

default void reset()

Reset the task