| 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.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
| com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
| com.hazelcast.map |
Contains Hazelcast map module classes.
|
| Modifier and Type | Method and Description |
|---|---|
Map<K,Object> |
ClientMapProxy.executeOnEntries(EntryProcessor entryProcessor) |
Map<K,Object> |
ClientMapProxy.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
Object |
ClientMapProxy.executeOnKey(K key,
EntryProcessor entryProcessor) |
Object |
NearCachedClientMapProxy.executeOnKeyInternal(Object key,
EntryProcessor entryProcessor) |
Object |
ClientMapProxy.executeOnKeyInternal(Object key,
EntryProcessor entryProcessor) |
Map<K,Object> |
ClientMapProxy.executeOnKeys(Set<K> keys,
EntryProcessor entryProcessor) |
ICompletableFuture |
ClientMapProxy.submitToKey(K key,
EntryProcessor entryProcessor) |
void |
ClientMapProxy.submitToKey(K key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
ICompletableFuture |
NearCachedClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor entryProcessor) |
ICompletableFuture |
ClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor entryProcessor) |
void |
NearCachedClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
void |
ClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
| Modifier and Type | Method and Description |
|---|---|
Map<K,Object> |
IMap.executeOnEntries(EntryProcessor entryProcessor)
Applies the user defined
EntryProcessor to the all entries in the map. |
Map<K,Object> |
IMap.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate)
Applies the user defined
EntryProcessor to the entries in the map which satisfy provided predicate. |
Object |
IMap.executeOnKey(K key,
EntryProcessor entryProcessor)
Applies the user defined
EntryProcessor to the entry mapped by the key. |
Map<K,Object> |
IMap.executeOnKeys(Set<K> keys,
EntryProcessor entryProcessor)
Applies the user defined
EntryProcessor to the entries mapped by the collection of keys. |
ICompletableFuture |
IMap.submitToKey(K key,
EntryProcessor entryProcessor)
Applies the user defined
EntryProcessor to the entry mapped by the key. |
void |
IMap.submitToKey(K key,
EntryProcessor entryProcessor,
ExecutionCallback callback)
Applies the user defined
EntryProcessor to the entry mapped by the key with
specified ExecutionCallback to listen event status and returns immediately. |
| Modifier and Type | Method and Description |
|---|---|
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateMapP(String mapName,
DistributedFunction<T,K> toKeyFn,
DistributedFunction<T,EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(String, DistributedFunction, DistributedFunction). |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateRemoteMapP(String mapName,
ClientConfig clientConfig,
DistributedFunction<T,K> toKeyFn,
DistributedFunction<T,EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.remoteMapWithEntryProcessor(String, ClientConfig, DistributedFunction,
DistributedFunction). |
| Modifier and Type | Method and Description |
|---|---|
static <E,K,V> Sink<E> |
Sinks.mapWithEntryProcessor(String mapName,
DistributedFunction<E,K> toKeyFn,
DistributedFunction<E,EntryProcessor<K,V>> toEntryProcessorFn)
Returns a sink that uses the items it receives to create
EntryProcessors it submits to a Hazelcast IMap with the
specified name. |
static <E,K,V> Sink<E> |
Sinks.remoteMapWithEntryProcessor(String mapName,
ClientConfig clientConfig,
DistributedFunction<E,K> toKeyFn,
DistributedFunction<E,EntryProcessor<K,V>> toEntryProcessorFn)
Returns a sink equivalent to
Sinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.jet.function.DistributedFunction<E, K>, com.hazelcast.jet.function.DistributedFunction<E, com.hazelcast.map.EntryProcessor<K, V>>), but for a map
in a remote Hazelcast cluster identified by the supplied ClientConfig. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractEntryProcessor<K,V>
An abstract
EntryProcessor that already has implemented the AbstractEntryProcessor.getBackupProcessor(). |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.