Class TopSpeedWindowing


  • public class TopSpeedWindowing
    extends Object
    An example of grouped stream windowing where different eviction and trigger policies can be used. A source fetches events from cars containing their id, their current speed (kmh), overall elapsed distance (m) and a timestamp. The streaming example triggers the top speed of each car every x meters elapsed for the last y seconds.
    • Constructor Detail

      • TopSpeedWindowing

        public TopSpeedWindowing()