Class WindowNode

    • Field Detail

      • outputFields

        protected final Fields outputFields
      • groupingInfo

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

        protected String componentId
      • parallelism

        protected int parallelism
    • Method Detail

      • getOutputFields

        public Fields getOutputFields()
      • isWindowed

        public boolean isWindowed()
      • setWindowed

        public void setWindowed​(boolean windowed)
      • emitsPair

        public boolean emitsPair()
      • setEmitsPair

        public void setEmitsPair​(boolean emitsPair)