public class ParallelAggregation
extends java.lang.Object
//...
ExecutorService executor = ...
RoaringBitmap[] bitmaps = ...
// executes on executors threads
RoaringBitmap result = executor.submit(() -> ParallelAggregation.or(bitmaps)).get();
| 限定符和类型 | 类和说明 |
|---|---|
static class |
ParallelAggregation.ContainerCollector
Collects containers grouped by their key into a RoaringBitmap, applying the
supplied aggregation function to each group.
|
static class |
ParallelAggregation.OrCollector
Collects a list of containers into a single container.
|
| 构造器和说明 |
|---|
ParallelAggregation() |
| 限定符和类型 | 方法和说明 |
|---|---|
static java.util.SortedMap<java.lang.Character,java.util.List<Container>> |
groupByKey(RoaringBitmap... bitmaps)
Groups the containers by their keys
|
static RoaringBitmap |
or(RoaringBitmap... bitmaps)
Computes the bitwise union of the input bitmaps
|
static RoaringBitmap |
xor(RoaringBitmap... bitmaps)
Computes the bitwise symmetric difference of the input bitmaps
|
public static java.util.SortedMap<java.lang.Character,java.util.List<Container>> groupByKey(RoaringBitmap... bitmaps)
bitmaps - input bitmapspublic static RoaringBitmap or(RoaringBitmap... bitmaps)
bitmaps - the input bitmapspublic static RoaringBitmap xor(RoaringBitmap... bitmaps)
bitmaps - the input bitmaps