Class TumblingCountWindowStrategy<T>

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

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

    • TumblingCountWindowStrategy

      public TumblingCountWindowStrategy(WindowConfig tumblingCountWindow)
  • Method Details

    • 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.