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 Details

    • SlidingTupleTsTopology

      public SlidingTupleTsTopology()
  • Method Details