org.apache.storm.trident.windowing.strategy

Interface WindowStrategy<T>

All Known Implementing Classes:

BaseWindowStrategy, SlidingCountWindowStrategy, SlidingDurationWindowStrategy, TumblingCountWindowStrategy, TumblingDurationWindowStrategy

public interface WindowStrategy<T>

Strategy for windowing which will have respective trigger and eviction policies.

Method Summary

Modifier and Type	Method and Description
EvictionPolicy<T,?>	getEvictionPolicy() Returns an EvictionPolicy instance for this strategy with the given configuration.
TriggerPolicy<T,?>	getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy by creating with triggerHandler and evictionPolicy with the given configuration.

Method Detail

getTriggerPolicy

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

Returns a TriggerPolicy by creating with triggerHandler and evictionPolicy with the given configuration.

Parameters:

triggerHandler -

evictionPolicy -

Returns:

getEvictionPolicy

EvictionPolicy<T,?> getEvictionPolicy()

Returns an EvictionPolicy instance for this strategy with the given configuration.

Returns: