Class Aggregator.Bucket

  • Enclosing class:
    Aggregator<S,​T>

    protected class Aggregator.Bucket
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected Bucket()  
    • Constructor Detail

      • Bucket

        protected Bucket()
    • Method Detail

      • accumulate

        public T accumulate​(S message)
      • getValue

        public T getValue()
      • getFirstTimeMillis

        public java.lang.Long getFirstTimeMillis()