Package | Description |
---|---|
com.hazelcast.aggregation |
Contains classes related to aggregations.
|
com.hazelcast.aggregation.impl | |
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.map.impl.query |
Modifier and Type | Method and Description |
---|---|
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalAvg() |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalAvg(String attributePath) |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalMax() |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalMax(String attributePath) |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalMin() |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalMin(String attributePath) |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalSum() |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigDecimalSum(String attributePath) |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigIntegerAvg() |
static <I> Aggregator<I,BigDecimal> |
Aggregators.bigIntegerAvg(String attributePath) |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerMax() |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerMax(String attributePath) |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerMin() |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerMin(String attributePath) |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerSum() |
static <I> Aggregator<I,BigInteger> |
Aggregators.bigIntegerSum(String attributePath) |
static <I,R extends Comparable> |
Aggregators.comparableMax() |
static <I,R extends Comparable> |
Aggregators.comparableMax(String attributePath) |
static <I,R extends Comparable> |
Aggregators.comparableMin() |
static <I,R extends Comparable> |
Aggregators.comparableMin(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.count() |
static <I> Aggregator<I,Long> |
Aggregators.count(String attributePath) |
static <I,R> Aggregator<I,Set<R>> |
Aggregators.distinct() |
static <I,R> Aggregator<I,Set<R>> |
Aggregators.distinct(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.doubleAvg() |
static <I> Aggregator<I,Double> |
Aggregators.doubleAvg(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.doubleMax() |
static <I> Aggregator<I,Double> |
Aggregators.doubleMax(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.doubleMin() |
static <I> Aggregator<I,Double> |
Aggregators.doubleMin(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.doubleSum() |
static <I> Aggregator<I,Double> |
Aggregators.doubleSum(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.fixedPointSum() |
static <I> Aggregator<I,Long> |
Aggregators.fixedPointSum(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.floatingPointSum() |
static <I> Aggregator<I,Double> |
Aggregators.floatingPointSum(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.integerAvg() |
static <I> Aggregator<I,Double> |
Aggregators.integerAvg(String attributePath) |
static <I> Aggregator<I,Integer> |
Aggregators.integerMax() |
static <I> Aggregator<I,Integer> |
Aggregators.integerMax(String attributePath) |
static <I> Aggregator<I,Integer> |
Aggregators.integerMin() |
static <I> Aggregator<I,Integer> |
Aggregators.integerMin(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.integerSum() |
static <I> Aggregator<I,Long> |
Aggregators.integerSum(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.longAvg() |
static <I> Aggregator<I,Double> |
Aggregators.longAvg(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.longMax() |
static <I> Aggregator<I,Long> |
Aggregators.longMax(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.longMin() |
static <I> Aggregator<I,Long> |
Aggregators.longMin(String attributePath) |
static <I> Aggregator<I,Long> |
Aggregators.longSum() |
static <I> Aggregator<I,Long> |
Aggregators.longSum(String attributePath) |
static <I> Aggregator<I,I> |
Aggregators.maxBy(String attributePath) |
static <I> Aggregator<I,I> |
Aggregators.minBy(String attributePath) |
static <I> Aggregator<I,Double> |
Aggregators.numberAvg() |
static <I> Aggregator<I,Double> |
Aggregators.numberAvg(String attributePath) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Aggregator.combine(Aggregator aggregator)
Incorporates the intermediary result of the given aggregator to this instance of the aggregator.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregator<I,E,R>
Abstract class providing convenience for concrete implementations of an
Aggregator
It provides built-in extraction capabilities that may be used in the accumulation phase. |
class |
BigDecimalAverageAggregator<I> |
class |
BigDecimalSumAggregator<I> |
class |
BigIntegerAverageAggregator<I> |
class |
BigIntegerSumAggregator<I> |
class |
CountAggregator<I> |
class |
DistinctValuesAggregator<I,R> |
class |
DoubleAverageAggregator<I> |
class |
DoubleSumAggregator<I> |
class |
FixedSumAggregator<I> |
class |
FloatingPointSumAggregator<I> |
class |
IntegerAverageAggregator<I> |
class |
IntegerSumAggregator<I> |
class |
LongAverageAggregator<I> |
class |
LongSumAggregator<I> |
class |
MaxAggregator<I,R extends Comparable> |
class |
MaxByAggregator<I> |
class |
MinAggregator<I,R extends Comparable> |
class |
MinByAggregator<I> |
class |
NumberAverageAggregator<I> |
Modifier and Type | Method and Description |
---|---|
void |
LongAverageAggregator.combine(Aggregator aggregator) |
void |
NumberAverageAggregator.combine(Aggregator aggregator) |
void |
FloatingPointSumAggregator.combine(Aggregator aggregator) |
void |
MinByAggregator.combine(Aggregator aggregator) |
void |
BigIntegerSumAggregator.combine(Aggregator aggregator) |
void |
MaxByAggregator.combine(Aggregator aggregator) |
void |
IntegerSumAggregator.combine(Aggregator aggregator) |
void |
BigDecimalAverageAggregator.combine(Aggregator aggregator) |
void |
DoubleSumAggregator.combine(Aggregator aggregator) |
void |
BigDecimalSumAggregator.combine(Aggregator aggregator) |
void |
BigIntegerAverageAggregator.combine(Aggregator aggregator) |
void |
CountAggregator.combine(Aggregator aggregator) |
void |
FixedSumAggregator.combine(Aggregator aggregator) |
void |
MaxAggregator.combine(Aggregator aggregator) |
void |
DistinctValuesAggregator.combine(Aggregator aggregator) |
void |
LongSumAggregator.combine(Aggregator aggregator) |
void |
MinAggregator.combine(Aggregator aggregator) |
void |
IntegerAverageAggregator.combine(Aggregator aggregator) |
void |
DoubleAverageAggregator.combine(Aggregator aggregator) |
Modifier and Type | Method and Description |
---|---|
protected Aggregator<?,?> |
DefaultMapProjectMessageTask.getAggregator() |
protected Aggregator<?,?> |
MapAggregateWithPredicateMessageTask.getAggregator() |
protected abstract Aggregator<?,?> |
AbstractMapQueryMessageTask.getAggregator() |
protected Aggregator<?,?> |
DefaultMapQueryMessageTask.getAggregator() |
protected Aggregator<?,?> |
MapAggregateMessageTask.getAggregator() |
Modifier and Type | Method and Description |
---|---|
<R> R |
ClientMapProxy.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator) |
<R> R |
ClientMapProxy.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate) |
Modifier and Type | Method and Description |
---|---|
<R> R |
IMap.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator)
Applies the aggregation logic on all map entries and returns the result
|
<R> R |
IMap.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate)
Applies the aggregation logic on map entries filtered with the Predicated and returns the result
|
Modifier and Type | Method and Description |
---|---|
<R> R |
MapProxyImpl.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator) |
<R> R |
MapProxyImpl.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate) |
Modifier and Type | Method and Description |
---|---|
Aggregator |
Query.getAggregator() |
<R> Aggregator<?,R> |
AggregationResult.getAggregator() |
Modifier and Type | Method and Description |
---|---|
protected Collection<Aggregator> |
ParallelAccumulationExecutor.accumulateParallel(Aggregator aggregator,
Collection<QueryableEntry> entries) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Aggregator> |
ParallelAccumulationExecutor.accumulateParallel(Aggregator aggregator,
Collection<QueryableEntry> entries) |
Query.QueryBuilder |
Query.QueryBuilder.aggregator(Aggregator aggregator) |
AggregationResult |
CallerRunsAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
AggregationResult |
ParallelAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
AggregationResult |
AccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
Constructor and Description |
---|
AggregationResult(Aggregator aggregator,
SerializationService serializationService) |
Query(String mapName,
Predicate predicate,
IterationType iterationType,
Aggregator aggregator,
Projection projection) |
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.