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

Class STWindowExample.DirectAggregateWindowedTask

java.lang.Object

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

edu.iu.dsc.tws.task.window.api.BaseWindowSink<T>

edu.iu.dsc.tws.task.window.core.AbstractSingleWindowDataSink<T>

edu.iu.dsc.tws.task.window.core.BaseWindowedSink<T>

edu.iu.dsc.tws.task.window.collectives.AggregateWindow<int[]>

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

All Implemented Interfaces:

Closable, ICompute<int[]>, INode, IWindowedSink<int[]>, IWindowCompute<int[]>, java.io.Serializable

Enclosing class:

STWindowExample

protected static class STWindowExample.DirectAggregateWindowedTask
extends AggregateWindow<int[]>

See Also:

Serialized Form

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.window.core.BaseWindowedSink

allowedLateness, collectiveEvents, collectiveOutput, DEFAULT_MAX_LAG, DEFAULT_WATERMARK_INTERVAL, evictionPolicy, iTimestampExtractor, iWindow, maxLagMs, watermarkEventGenerator, watermarkInterval, windowingPolicy, windowLifeCycleListener, windowManager, windowParameter

Fields inherited from class edu.iu.dsc.tws.api.compute.nodes.BaseNode

config, context

Constructor Summary

Constructors

Constructor and Description
DirectAggregateWindowedTask(AggregateWindowedFunction aggregateWindowedFunction)

Method Summary

Modifier and Type	Method and Description
boolean	aggregate(int[] message)
boolean	aggregateLateMessages(int[] message)

Methods inherited from class edu.iu.dsc.tws.task.window.collectives.AggregateWindow

execute, getExpire, getLateMessages

Methods inherited from class edu.iu.dsc.tws.task.window.core.BaseWindowedSink

close, execute, getEvictionPolicy, getWindowingPolicy, initialize, isTimestamped, newWindowLifeCycleListener, prepare, reset, setPolicies, start, withAllowedLateness, withCustomTimestampExtractor, withSlidingCountWindow, withSlidingDurationWindow, withTimestampExtractor, withTumblingCountWindow, withTumblingDurationWindow, withWatermarkInterval, withWindow

Methods inherited from class java.lang.Object

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

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

endExecute

Constructor Detail

DirectAggregateWindowedTask

public DirectAggregateWindowedTask(AggregateWindowedFunction aggregateWindowedFunction)

Method Detail

aggregate

public boolean aggregate(int[] message)

Specified by:

aggregate in class AggregateWindow<int[]>

aggregateLateMessages

public boolean aggregateLateMessages(int[] message)

Specified by:

aggregateLateMessages in class AggregateWindow<int[]>