Class WindowNode

java.lang.Object
org.apache.storm.streams.WindowNode
All Implemented Interfaces:
Serializable

public class WindowNode extends Object
Node that captures the windowing configurations.
See Also:
  • Field Details

    • PUNCTUATION

      public static final String PUNCTUATION
      See Also:
    • outputFields

      protected final Fields outputFields
    • groupingInfo

      protected org.apache.storm.streams.GroupingInfo groupingInfo
    • componentId

      protected String componentId
    • parallelism

      protected int parallelism
  • Method Details

    • getOutputFields

      public Fields getOutputFields()
    • isWindowed

      public boolean isWindowed()
    • setWindowed

      public void setWindowed(boolean windowed)
    • emitsPair

      public boolean emitsPair()
    • setEmitsPair

      public void setEmitsPair(boolean emitsPair)
    • toString

      public String toString()
      Overrides:
      toString in class Object