Uses of Interface
com.hazelcast.map.EntryProcessor
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains Hazelcast map module classes.
-
Uses of EntryProcessor in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionMapSinkEntryProcessorBuilder.toEntryProcessorFn
(FunctionEx<? super E, ? extends EntryProcessor<K, V, R>> toEntryProcessorFn) -
Uses of EntryProcessor in com.hazelcast.map
Modifier and TypeMethodDescriptiondefault EntryProcessor<K,
V, R> EntryProcessor.getBackupProcessor()
Get the entry processor to be applied to backup entries.Modifier and TypeMethodDescriptionIMap.executeOnEntries
(EntryProcessor<K, V, R> entryProcessor) Applies the user definedEntryProcessor
to the all entries in the map.IMap.executeOnEntries
(EntryProcessor<K, V, R> entryProcessor, Predicate<K, V> predicate) Applies the user definedEntryProcessor
to the entries in the map which satisfy provided predicate.<R> R
IMap.executeOnKey
(K key, EntryProcessor<K, V, R> entryProcessor) Applies the user definedEntryProcessor
to the entry mapped by thekey
.IMap.executeOnKeys
(Set<K> keys, EntryProcessor<K, V, R> entryProcessor) Applies the user definedEntryProcessor
to the entries mapped by the collection of keys.<R> CompletionStage<R>
IMap.submitToKey
(K key, EntryProcessor<K, V, R> entryProcessor) Applies the user definedEntryProcessor
to the entry mapped by thekey
.<R> CompletionStage<Map<K,
R>> IMap.submitToKeys
(Set<K> keys, EntryProcessor<K, V, R> entryProcessor)