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

Class STWindowEventTimeExample.DirectFoldWindowedTask

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.FoldWindow<int[],java.lang.String>

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

All Implemented Interfaces:

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

Enclosing class:

STWindowEventTimeExample

protected static class STWindowEventTimeExample.DirectFoldWindowedTask
extends FoldWindow<int[],java.lang.String>

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
DirectFoldWindowedTask(FoldWindowedFunction<int[],java.lang.String> foldWindowedFunction)

Method Summary

Modifier and Type	Method and Description
boolean	fold(java.lang.String content)
boolean	foldLateMessage(java.lang.String lateMessage)

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

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

DirectFoldWindowedTask

public DirectFoldWindowedTask(FoldWindowedFunction<int[],java.lang.String> foldWindowedFunction)

Method Detail

fold

public boolean fold(java.lang.String content)

Specified by:

fold in class FoldWindow<int[],java.lang.String>

foldLateMessage

public boolean foldLateMessage(java.lang.String lateMessage)

Specified by:

foldLateMessage in class FoldWindow<int[],java.lang.String>