Class DeferringBucketCollector

    • Constructor Detail

      • DeferringBucketCollector

        public DeferringBucketCollector()
        Sole constructor.
    • Method Detail

      • setDeferredCollector

        public abstract void setDeferredCollector​(java.lang.Iterable<BucketCollector> deferredCollectors)
        Set the deferred collectors.
      • replay

        public final void replay​(long... selectedBuckets)
                          throws java.io.IOException
        Throws:
        java.io.IOException
      • prepareSelectedBuckets

        public abstract void prepareSelectedBuckets​(long... selectedBuckets)
                                             throws java.io.IOException
        Throws:
        java.io.IOException
      • wrap

        public Aggregator wrap​(Aggregator in)
        Wrap the provided aggregator so that it behaves (almost) as if it had been collected directly.