Package org.apache.storm.starter
Class SlidingTupleTsTopology
- java.lang.Object
-
- org.apache.storm.starter.SlidingTupleTsTopology
-
public class SlidingTupleTsTopology extends Object
Windowing based on tuple timestamp (e.g. the time when tuple is generated rather than when its processed).
-
-
Constructor Summary
Constructors Constructor Description SlidingTupleTsTopology()
-