Class SlidingDurationWindowStrategy<T>

java.lang.Object
org.apache.storm.trident.windowing.strategy.BaseWindowStrategy<T>
org.apache.storm.trident.windowing.strategy.SlidingDurationWindowStrategy<T>
All Implemented Interfaces:
WindowStrategy<T>

public final class SlidingDurationWindowStrategy<T> extends BaseWindowStrategy<T>
This class represents sliding window strategy based on the sliding window duration and sliding interval from the given slidingCountWindow configuration.
  • Constructor Details

    • SlidingDurationWindowStrategy

      public SlidingDurationWindowStrategy(WindowConfig slidingDurationWindow)
  • Method Details

    • getTriggerPolicy

      public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)
      Returns a TriggerPolicy which triggers for every configured sliding window duration.
    • getEvictionPolicy

      public EvictionPolicy<T,?> getEvictionPolicy()
      Returns an EvictionPolicy instance which evicts elements after window duration is reached.