Package | Description |
---|---|
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.mapreduce.aggregation |
This package contains the aggregation API and the convenience helper classes
to retrieve predefined aggregation implementations.
|
com.hazelcast.mapreduce.aggregation.impl |
This package contains a set of predefined aggregation implementations
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
ClientMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation) |
<SuppliedValue,Result> |
ClientMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation) |
<SuppliedValue,Result> |
ClientMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
<SuppliedValue,Result> |
ClientMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
IMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation)
Executes a predefined aggregation on the maps data set.
|
<SuppliedValue,Result> |
MultiMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation)
Executes a predefined aggregation on the multimaps data set.
|
<SuppliedValue,Result> |
IMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
Executes a predefined aggregation on the maps data set.
|
<SuppliedValue,Result> |
MultiMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
Executes a predefined aggregation on the multimaps data set.
|
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
MapProxyImpl.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation) |
<SuppliedValue,Result> |
MapProxyImpl.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Modifier and Type | Method and Description |
---|---|
static <KeyIn,ValueIn,ValueOut> |
Supplier.all()
The predefined Supplier selects all values and does not perform any kind of data
transformation.
|
static <KeyIn,ValueIn,ValueOut> |
Supplier.all(PropertyExtractor<ValueIn,ValueOut> propertyExtractor)
The predefined Supplier selects all values and performs the given
PropertyExtractor s transformation to the
input data. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate)
The predefined Supplier selects values using the given
KeyPredicate
and does not perform any kind of data transformation. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)
The predefined Supplier selects values using the given
KeyPredicate
and chains the filtered value to the given Supplier which might perform data transformation. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromPredicate(Predicate<KeyIn,ValueIn> predicate)
The predefined Supplier selects values using the given
Predicate
and does not perform any kind of data transformation. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromPredicate(Predicate<KeyIn,ValueIn> predicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)
The predefined Supplier selects values using the given
Predicate
and chains the filtered value to the given Supplier which might perform data transformation. |
Modifier and Type | Method and Description |
---|---|
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)
The predefined Supplier selects values using the given
KeyPredicate
and chains the filtered value to the given Supplier which might perform data transformation. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromPredicate(Predicate<KeyIn,ValueIn> predicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)
The predefined Supplier selects values using the given
Predicate
and chains the filtered value to the given Supplier which might perform data transformation. |
Mapper |
Aggregation.getMapper(Supplier<Key,?,Supplied> supplier)
Returns the Mapper for this aggregation.
|
Modifier and Type | Class and Description |
---|---|
class |
AcceptAllSupplier<KeyIn,ValueIn,ValueOut>
A standard implementation of the
Supplier
interface which accepts all input values and may apply a given
PropertyExtractor on those. |
class |
KeyPredicateSupplier<KeyIn,ValueIn,ValueOut>
The default supplier for
KeyPredicate s, used
to filter and optionally transform data (using the given
Supplier ). |
class |
PredicateSupplier<KeyIn,ValueIn,ValueOut>
|
Constructor and Description |
---|
KeyPredicateSupplier(KeyPredicate<KeyIn> keyPredicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier) |
PredicateSupplier(Predicate<KeyIn,ValueIn> predicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier) |
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
ObjectMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation) |
<SuppliedValue,Result> |
ObjectMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.