edu.iu.dsc.tws.examples.task.streaming

Class STKeyedReduceExample

java.lang.Object

edu.iu.dsc.tws.examples.task.BenchTaskWorker

edu.iu.dsc.tws.examples.task.streaming.STKeyedReduceExample

All Implemented Interfaces:

Twister2Worker

public class STKeyedReduceExample
extends BenchTaskWorker

todo keyedreduce for streaming is not applicable. This will be removed, or used only with windowing

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	STKeyedReduceExample.KeyedReduceSinkTask

Nested classes/interfaces inherited from class edu.iu.dsc.tws.examples.task.BenchTaskWorker

BenchTaskWorker.SourceTask, BenchTaskWorker.SourceWindowTask, BenchTaskWorker.SourceWindowTimeStampTask

Field Summary

Fields inherited from class edu.iu.dsc.tws.examples.task.BenchTaskWorker

computeConnection, computeGraph, computeGraphBuilder, executionPlan, inputDataArray, jobParameters, receiversInProgress, resultsRecorder, sendersInProgress, SINK, SOURCE

Constructor Summary

Constructors

Constructor and Description
STKeyedReduceExample()

Method Summary

Modifier and Type	Method and Description
ComputeGraphBuilder	buildTaskGraph()

Methods inherited from class edu.iu.dsc.tws.examples.task.BenchTaskWorker

execute, getTimingCondition, verifyResults

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

STKeyedReduceExample

public STKeyedReduceExample()

Method Detail

buildTaskGraph

public ComputeGraphBuilder buildTaskGraph()

Specified by:

buildTaskGraph in class BenchTaskWorker