Interface IStatefulWindowedBolt<T extends State>

All Superinterfaces:
IComponent, IStatefulComponent<T>, IWindowedBolt, Serializable
All Known Implementing Classes:
BaseStatefulWindowedBolt

public interface IStatefulWindowedBolt<T extends State> extends IStatefulComponent<T>, IWindowedBolt
A windowed bolt abstraction for supporting windowing operation with state.
  • Method Details

    • isPersistent

      default boolean isPersistent()
      If the stateful windowed bolt should have its windows persisted in state and maintain a subset of events in memory.

      The default is to keep all the window events in memory.

      Returns:
      true if the windows should be persisted
    • maxEventsInMemory

      default long maxEventsInMemory()
      The maximum number of window events to keep in memory.