Package org.roaringbitmap.buffer
Class BufferParallelAggregation.ContainerCollector
- java.lang.Object
-
- org.roaringbitmap.buffer.BufferParallelAggregation.ContainerCollector
-
- All Implemented Interfaces:
java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
- Enclosing class:
- BufferParallelAggregation
public static class BufferParallelAggregation.ContainerCollector extends java.lang.Object implements java.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
Collects containers grouped by their key into a RoaringBitmap, applying the supplied aggregation function to each group.
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.function.Function<java.util.List<MappeableContainer>,MappeableContainer>
reducer
-
Constructor Summary
Constructors Constructor Description ContainerCollector(java.util.function.Function<java.util.List<MappeableContainer>,MappeableContainer> reducer)
Creates a collector with the reducer function.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.function.BiConsumer<MutableRoaringArray,java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>>
accumulator()
java.util.Set<java.util.stream.Collector.Characteristics>
characteristics()
java.util.function.BinaryOperator<MutableRoaringArray>
combiner()
java.util.function.Function<MutableRoaringArray,MutableRoaringBitmap>
finisher()
java.util.function.Supplier<MutableRoaringArray>
supplier()
-
-
-
Field Detail
-
reducer
private final java.util.function.Function<java.util.List<MappeableContainer>,MappeableContainer> reducer
-
-
Constructor Detail
-
ContainerCollector
ContainerCollector(java.util.function.Function<java.util.List<MappeableContainer>,MappeableContainer> 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<MutableRoaringArray> supplier()
- Specified by:
supplier
in interfacejava.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
-
accumulator
public java.util.function.BiConsumer<MutableRoaringArray,java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>> accumulator()
- Specified by:
accumulator
in interfacejava.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
-
combiner
public java.util.function.BinaryOperator<MutableRoaringArray> combiner()
- Specified by:
combiner
in interfacejava.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
-
finisher
public java.util.function.Function<MutableRoaringArray,MutableRoaringBitmap> finisher()
- Specified by:
finisher
in interfacejava.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
-
characteristics
public java.util.Set<java.util.stream.Collector.Characteristics> characteristics()
- Specified by:
characteristics
in interfacejava.util.stream.Collector<java.util.Map.Entry<java.lang.Character,java.util.List<MappeableContainer>>,MutableRoaringArray,MutableRoaringBitmap>
-
-