stream.scotty.slicing

Class WindowManager

java.lang.Object

stream.scotty.slicing.WindowManager

public class WindowManager
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	WindowManager.AggregationWindowCollector

Field Summary

Fields

Modifier and Type	Field and Description
private AggregationStore	aggregationStore
private java.util.List<WindowContext>	contextAwareWindows
private java.util.List<ContextFreeWindow>	contextFreeWindows
private boolean	hasContextAwareWindows
private boolean	hasFixedWindows
private long	lastWatermark
private long	maxLateness
private long	minSessionTimeout
private StateFactory	stateFactory
private java.util.List<AggregateFunction>	windowFunctions

Constructor Summary

Constructors

Constructor and Description
WindowManager(StateFactory stateFactory, AggregationStore aggregationStore)

Method Summary

Modifier and Type	Method and Description
<InputType,Agg,OutputType> void	addAggregation(AggregateFunction<InputType,Agg,OutputType> windowFunction)
void	addWindowAssigner(Window window)
private void	assignContextAwareWindows(long watermarkTs, WindowManager.AggregationWindowCollector windows)
private void	assignContextFreeWindows(long watermarkTs, WindowCollector windowCollector)
java.util.List<AggregateFunction>	getAggregations()
java.util.List<? extends WindowContext>	getContextAwareWindows()
java.util.List<ContextFreeWindow>	getContextFreeWindows()
long	getMaxLateness()
long	getMinSessionTimeout()
boolean	hasContextAwareWindow()
boolean	hasFixedWindows()
java.util.List<AggregateWindow>	processWatermark(long watermarkTs)

Methods inherited from class java.lang.Object

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

Field Detail

aggregationStore

private final AggregationStore aggregationStore

stateFactory

private final StateFactory stateFactory

hasContextAwareWindows

private boolean hasContextAwareWindows

hasFixedWindows

private boolean hasFixedWindows

minSessionTimeout

private long minSessionTimeout

maxLateness

private long maxLateness

contextFreeWindows

private final java.util.List<ContextFreeWindow> contextFreeWindows

contextAwareWindows

private final java.util.List<WindowContext> contextAwareWindows

windowFunctions

private final java.util.List<AggregateFunction> windowFunctions

lastWatermark

private long lastWatermark

Constructor Detail

WindowManager

public WindowManager(StateFactory stateFactory,
                     AggregationStore aggregationStore)

Method Detail

processWatermark

public java.util.List<AggregateWindow> processWatermark(long watermarkTs)

assignContextAwareWindows

private void assignContextAwareWindows(long watermarkTs,
                                       WindowManager.AggregationWindowCollector windows)

assignContextFreeWindows

private void assignContextFreeWindows(long watermarkTs,
                                      WindowCollector windowCollector)

addWindowAssigner

public void addWindowAssigner(Window window)

addAggregation

public <InputType,Agg,OutputType> void addAggregation(AggregateFunction<InputType,Agg,OutputType> windowFunction)

hasContextAwareWindow

public boolean hasContextAwareWindow()

hasFixedWindows

public boolean hasFixedWindows()

getMinSessionTimeout

public long getMinSessionTimeout()

getMaxLateness

public long getMaxLateness()

getContextFreeWindows

public java.util.List<ContextFreeWindow> getContextFreeWindows()

getAggregations

public java.util.List<AggregateFunction> getAggregations()

getContextAwareWindows

public java.util.List<? extends WindowContext> getContextAwareWindows()