org.apache.storm.trident.windowing.strategy

Class SlidingCountWindowStrategy<T>

java.lang.Object

org.apache.storm.trident.windowing.strategy.BaseWindowStrategy<T>

org.apache.storm.trident.windowing.strategy.SlidingCountWindowStrategy<T>

All Implemented Interfaces:

WindowStrategy<T>

public class SlidingCountWindowStrategy<T>
extends BaseWindowStrategy<T>

This class represents sliding window strategy based on the sliding window count and sliding interval count from the given slidingCountWindow configuration.

Field Summary

Fields inherited from class org.apache.storm.trident.windowing.strategy.BaseWindowStrategy

windowConfig

Constructor Summary

Constructors

Constructor and Description
SlidingCountWindowStrategy(WindowConfig slidingCountWindow)

Method Summary

Modifier and Type	Method and Description
EvictionPolicy<T,?>	getEvictionPolicy() Returns an EvictionPolicy instance which evicts elements after a count of given window length.
TriggerPolicy<T,?>	getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy which triggers for every count of given sliding window.

Methods inherited from class java.lang.Object

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

Constructor Detail

SlidingCountWindowStrategy

public SlidingCountWindowStrategy(WindowConfig slidingCountWindow)

Method Detail

getTriggerPolicy

public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler,
                                           EvictionPolicy<T,?> evictionPolicy)

Returns a TriggerPolicy which triggers for every count of given sliding window.

getEvictionPolicy

public EvictionPolicy<T,?> getEvictionPolicy()

Returns an EvictionPolicy instance which evicts elements after a count of given window length.