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

Class STWindowEventTimeExample

java.lang.Object

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

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

All Implemented Interfaces:

Twister2Worker

public class STWindowEventTimeExample
extends BenchTaskWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	STWindowEventTimeExample.AggregateFunctionImpl
protected static class	STWindowEventTimeExample.DirectAggregateWindowedTask
protected static class	STWindowEventTimeExample.DirectFoldWindowedTask
protected static class	STWindowEventTimeExample.DirectProcessWindowedIntTask
protected static class	STWindowEventTimeExample.DirectProcessWindowedTask
protected static class	STWindowEventTimeExample.DirectReceiveTask
protected static class	STWindowEventTimeExample.DirectReduceWindowedTask
protected static class	STWindowEventTimeExample.DirectWindowedReceivingTask
protected static class	STWindowEventTimeExample.FoldFunctionImpl
protected static class	STWindowEventTimeExample.ProcessFunctionImpl
protected static class	STWindowEventTimeExample.ProcessFunctionIntImpl
protected static class	STWindowEventTimeExample.ReduceFunctionImpl

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
STWindowEventTimeExample()

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

STWindowEventTimeExample

public STWindowEventTimeExample()

Method Detail

buildTaskGraph

public ComputeGraphBuilder buildTaskGraph()

Specified by:

buildTaskGraph in class BenchTaskWorker