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
EntryProcessor s 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.