Class ParallelAggregation.ContainerCollector

  • All Implemented Interfaces:
    java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>
    Enclosing class:
    ParallelAggregation

    public static class ParallelAggregation.ContainerCollector
    extends java.lang.Object
    implements java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>
    Collects containers grouped by their key into a RoaringBitmap, applying the supplied aggregation function to each group.
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface java.util.stream.Collector

        java.util.stream.Collector.Characteristics
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.function.Function<java.util.List<Container>,​Container> reducer  
    • Constructor Summary

      Constructors 
      Constructor Description
      ContainerCollector​(java.util.function.Function<java.util.List<Container>,​Container> reducer)
      Creates a collector with the reducer function.
    • Field Detail

      • reducer

        private final java.util.function.Function<java.util.List<Container>,​Container> reducer
    • Constructor Detail

      • ContainerCollector

        ContainerCollector​(java.util.function.Function<java.util.List<Container>,​Container> reducer)
        Creates a collector with the reducer function.
        Parameters:
        reducer - a function to apply to containers with the same key.
    • Method Detail

      • supplier

        public java.util.function.Supplier<RoaringArray> supplier()
        Specified by:
        supplier in interface java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>
      • accumulator

        public java.util.function.BiConsumer<RoaringArray,​java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>> accumulator()
        Specified by:
        accumulator in interface java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>
      • combiner

        public java.util.function.BinaryOperator<RoaringArray> combiner()
        Specified by:
        combiner in interface java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>
      • characteristics

        public java.util.Set<java.util.stream.Collector.Characteristics> characteristics()
        Specified by:
        characteristics in interface java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,​java.util.List<Container>>,​RoaringArray,​RoaringBitmap>