| Package | Description |
|---|---|
| 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> |
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<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(String, DistributedFunction, DistributedFunction). |
static <T,K,V> ProcessorMetaSupplier |
SinkProcessors.updateRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.remoteMapWithEntryProcessor(String, ClientConfig, DistributedFunction,
DistributedFunction). |
| Modifier and Type | Method and Description |
|---|---|
static <T,K,V> Sink<T> |
Sinks.mapWithEntryProcessor(IMap<? super K,? super V> map,
DistributedFunction<? super T,? extends K> toKeyFn,
DistributedFunction<? super T,? extends 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.mapWithEntryProcessor(String mapName,
DistributedFunction<? super E,? extends K> toKeyFn,
DistributedFunction<? super E,? extends 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,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedFunction<? super E,? extends K> toKeyFn,
DistributedFunction<? super E,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a sink equivalent to
Sinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.jet.function.DistributedFunction<? super E, ? extends K>, com.hazelcast.jet.function.DistributedFunction<? super E, ? extends 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.