import java.util.List;
/*** A view of events in a sliding window.** @param <T> the type of event that this window contains. E.g. {@link org.apache.storm.tuple.Tuple}*/
public interface Window<T> {/*** Gets the list of events in the window.** @return the list of events in the window.*/List<T> get();/*** Get the list of newly added events in the window since the last time the window was generated.** @return the list of newly added events in the window.*/List<T> getNew();/*** Get the list of events expired from the window since the last time the window was generated.** @return the list of events expired from the window.*/List<T> getExpired();
}

package org.apache.storm.windowing;
import org.apache.storm.tuple.Tuple;
/*** A {@link Window} that contains {@link Tuple} objects.*/
public interface TupleWindow extends Window<Tuple> {
}

package org.apache.storm.windowing;
import org.apache.storm.tuple.Tuple;
import java.util.List;
/*** Holds the expired, new and current tuples in a window.*/
public class TupleWindowImpl implements TupleWindow {private final List<Tuple> tuples;private final List<Tuple> newTuples;private final List<Tuple> expiredTuples;public TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples) {this.tuples = tuples;this.newTuples = newTuples;this.expiredTuples = expiredTuples;}@Overridepublic List<Tuple> get() {return tuples;}@Overridepublic List<Tuple> getNew() {return newTuples;}@Overridepublic List<Tuple> getExpired() {return expiredTuples;}@Overridepublic String toString() {return "TupleWindowImpl{" +"tuples=" + tuples +", newTuples=" + newTuples +", expiredTuples=" + expiredTuples +'}';}@Overridepublic boolean equals(Object o) {if (this == o) return true;if (o == null || getClass() != o.getClass()) return false;TupleWindowImpl that = (TupleWindowImpl) o;if (tuples != null ? !tuples.equals(that.tuples) : that.tuples != null) return false;if (newTuples != null ? !newTuples.equals(that.newTuples) : that.newTuples != null) return false;return expiredTuples != null ? expiredTuples.equals(that.expiredTuples) : that.expiredTuples == null;}@Overridepublic int hashCode() {int result = tuples != null ? tuples.hashCode() : 0;result = 31 * result + (newTuples != null ? newTuples.hashCode() : 0);result = 31 * result + (expiredTuples != null ? expiredTuples.hashCode() : 0);return result;}
}

withWindow(Count windowLength, Count slidingInterval)
Tuple count based sliding window that slides after `slidingInterval` number of tuples.滑窗 窗口长度：tuple数, 滑动间隔: tuple数withWindow(Count windowLength)
Tuple count based window that slides with every incoming tuple.滑窗 窗口长度：tuple数, 滑动间隔: 每个tuple进来都滑，每个tuple传入都会触发一次windowbolt计算。withWindow(Count windowLength, Duration slidingInterval)
Tuple count based sliding window that slides after `slidingInterval` time duration.滑窗 窗口长度：tuple数, 滑动间隔: 时间间隔withWindow(Duration windowLength, Duration slidingInterval)
Time duration based sliding window that slides after `slidingInterval` time duration.滑窗 窗口长度：时间间隔, 滑动间隔: 时间间隔withWindow(Duration windowLength)
Time duration based window that slides with every incoming tuple.滑窗 窗口长度：时间间隔, 滑动间隔: 每个tuple进来都滑withWindow(Duration windowLength, Count slidingInterval)
Time duration based sliding window configuration that slides after `slidingInterval` number of tuples.滑窗 窗口长度：时间间隔, 滑动间隔: 时间间隔

public class SlidingWindowBolt extends BaseWindowedBolt {private OutputCollector collector;@Overridepublic void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {this.collector = collector;}@Overridepublic void execute(TupleWindow inputWindow) {for(Tuple tuple: inputWindow.get()) {// do the windowing computation...}// emit the resultscollector.emit(new Values(computedValue));}
}public static void main(String[] args) {TopologyBuilder builder = new TopologyBuilder();builder.setSpout("spout", new RandomSentenceSpout(), 1);builder.setBolt("slidingwindowbolt", new SlidingWindowBolt().withWindow(new Count(30), new Count(10)),1).shuffleGrouping("spout");Config conf = new Config();conf.setDebug(true);conf.setNumWorkers(1);StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology());}

withTumblingWindow(BaseWindowedBolt.Count count)
Count based tumbling window that tumbles after the specified count of tuples.滚窗 窗口长度：Tuple数withTumblingWindow(BaseWindowedBolt.Duration duration)
Time duration based tumbling window that tumbles after the specified time duration.滚窗 窗口长度：时间间隔

/**
* Specify the tuple field that represents the timestamp as a long value. If this field
* is not present in the incoming tuple, an {@link IllegalArgumentException} will be thrown.
*
* @param fieldName the name of the field that contains the timestamp
*/
public BaseWindowedBolt withTimestampField(String fieldName)

/**
* Specify the maximum time lag of the tuple timestamp in millis. The tuple timestamps
* cannot be out of order by more than this amount.
*
* @param duration the max lag duration
*/
public BaseWindowedBolt withLag(Duration duration)

/**
* Specify the watermark event generation interval. Watermark events
* are used to track the progress of time
*
* @param interval the interval at which watermark events are generated
*/
public BaseWindowedBolt withWatermarkInterval(Duration interval)