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

Class STWindowEventTimeExample.DirectProcessWindowedTask

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.ProcessWindow<IntData>

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

All Implemented Interfaces:

Closable, ICompute<IntData>, INode, IWindowedSink<IntData>, IWindowCompute<IntData>, java.io.Serializable

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.DirectProcessWindowedTask
extends ProcessWindow<IntData>

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
DirectProcessWindowedTask(ProcessWindowedFunction<IntData> processWindowedFunction)

Method Summary

Modifier and Type	Method and Description
boolean	process(IWindowMessage<IntData> windowMessage)
boolean	processLateMessages(IMessage<IntData> lateMessage)

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

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

DirectProcessWindowedTask

public DirectProcessWindowedTask(ProcessWindowedFunction<IntData> processWindowedFunction)

Method Detail

process

public boolean process(IWindowMessage<IntData> windowMessage)

Specified by:

process in class ProcessWindow<IntData>

processLateMessages

public boolean processLateMessages(IMessage<IntData> lateMessage)

Specified by:

processLateMessages in class ProcessWindow<IntData>