Class TumblingDurationWindowStrategy<T>

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

public final class TumblingDurationWindowStrategy<T> extends BaseWindowStrategy<T>
This class represents tumbling window strategy based on the window duration from the given slidingCountWindow configuration. In this strategy , window and sliding durations are equal.
  • Constructor Details

    • TumblingDurationWindowStrategy

      public TumblingDurationWindowStrategy(WindowConfig tumblingDurationWindow)
  • Method Details

    • getTriggerPolicy

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

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