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

Class STWindowEventTimeExample.DirectReduceWindowedTask

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.ReduceWindow<int[]>

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

All Implemented Interfaces:

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

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.DirectReduceWindowedTask
extends ReduceWindow<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
DirectReduceWindowedTask(ReduceWindowedFunction<int[]> reduceWindowedFunction)

Method Summary

Modifier and Type	Method and Description
boolean	reduce(int[] content)
boolean	reduceLateMessage(int[] content)

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

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

DirectReduceWindowedTask

public DirectReduceWindowedTask(ReduceWindowedFunction<int[]> reduceWindowedFunction)

Method Detail

reduce

public boolean reduce(int[] content)

Specified by:

reduce in class ReduceWindow<int[]>

reduceLateMessage

public boolean reduceLateMessage(int[] content)

Specified by:

reduceLateMessage in class ReduceWindow<int[]>