List<Integer> data = ImmutableList.of(1, 2,3);
// agg inline
Summarizer<IN, OUT> summarizer = Summarizers<>
.withAggregators(....)
.build().
summarizer.offer(data);
Summary summary = summarizer.read();
// Agg out of band
Summarizer<Integer> summarizer = Summarizers<>
.withAggregators(....)
.emittingEvery(someDuration)
.to(someConsumer or someSubscriber)
.build().
summarizer.offer(data);
Interfaces
Package: aggregators
Interfaces / Types
Cardinality
Percentile
TopN
Classes:
???
Package: aggregators.approximate Same as aggregator but with error rates
Interfaces:
ApproximateAggregator
Classes:
- What if we want to emit based on data time vs clock time?
These are to be converted to Github Issues
-
Maven plugin broken due to ASM Java 9 bugs:
- maven-dependency-plugin -- See MDEP-559
- modernizer -- gaul/modernizer-maven-plugin#60
Workaround is to disable the plugins via properties:
<op.check.skip-dependency>true</op.check.skip-dependency> <op.check.skip-modernizer>true</op.check.skip-modernizer>