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

Class STWindowEventTimeExample.DirectProcessWindowedIntTask

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<EventTimeData>

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

All Implemented Interfaces:

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

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.DirectProcessWindowedIntTask
extends ProcessWindow<EventTimeData>

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
DirectProcessWindowedIntTask(ProcessWindowedFunction<EventTimeData> processWindowedFunction)

Method Summary

Modifier and Type	Method and Description
boolean	process(IWindowMessage<EventTimeData> windowMessage)
boolean	processLateMessages(IMessage<EventTimeData> 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

DirectProcessWindowedIntTask

public DirectProcessWindowedIntTask(ProcessWindowedFunction<EventTimeData> processWindowedFunction)

Method Detail

process

public boolean process(IWindowMessage<EventTimeData> windowMessage)

Specified by:

process in class ProcessWindow<EventTimeData>

processLateMessages

public boolean processLateMessages(IMessage<EventTimeData> lateMessage)

Specified by:

processLateMessages in class ProcessWindow<EventTimeData>