Uses of Interface
com.hazelcast.map.EntryProcessor

Packages that use EntryProcessor

Package	Description
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.

Uses of EntryProcessor in com.hazelcast.jet.core.processor

Method parameters in com.hazelcast.jet.core.processor with type arguments of type EntryProcessor

Modifier and Type	Method and Description
static <T,K,V,R> ProcessorMetaSupplier	SinkProcessors.updateMapP(int maxParallelAsyncOps, String mapName, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn) Returns a supplier of processors for Sinks.mapWithEntryProcessor(int, String, FunctionEx, FunctionEx).
static <T,K,V,R> ProcessorMetaSupplier	SinkProcessors.updateMapP(String mapName, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn) Returns a supplier of processors for Sinks.mapWithEntryProcessor(String, FunctionEx, FunctionEx).
static <T,K,V,R> ProcessorMetaSupplier	SinkProcessors.updateRemoteMapP(String mapName, ClientConfig clientConfig, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn) Returns a supplier of processors for Sinks.remoteMapWithEntryProcessor(String, ClientConfig, FunctionEx, FunctionEx).

Uses of EntryProcessor in com.hazelcast.jet.pipeline

Method parameters in com.hazelcast.jet.pipeline with type arguments of type EntryProcessor

Modifier and Type	Method and Description
static <T,K,V,R> Sink<T>	Sinks.mapWithEntryProcessor(IMap<? super K,? super V> map, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends EntryProcessor<K,V,R>> 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,R> Sink<E>	Sinks.mapWithEntryProcessor(int maxParallelAsyncOps, String mapName, FunctionEx<? super E,? extends K> toKeyFn, FunctionEx<? super E,? extends EntryProcessor<K,V,R>> 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,R> Sink<E>	Sinks.mapWithEntryProcessor(String mapName, FunctionEx<? super E,? extends K> toKeyFn, FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn) Convenience for Sinks.mapWithEntryProcessor(int, String, FunctionEx, FunctionEx) when the maximum number of async operations is not specified.
static <E,K,V,R> Sink<E>	Sinks.remoteMapWithEntryProcessor(String mapName, ClientConfig clientConfig, FunctionEx<? super E,? extends K> toKeyFn, FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn) Returns a sink equivalent to Sinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.function.FunctionEx<? super E, ? extends K>, com.hazelcast.function.FunctionEx<? super E, ? extends com.hazelcast.map.EntryProcessor<K, V, R>>), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.

Uses of EntryProcessor in com.hazelcast.map

Methods in com.hazelcast.map that return EntryProcessor

Modifier and Type	Method and Description
default EntryProcessor<K,V,R>	EntryProcessor.getBackupProcessor() Get the entry processor to be applied to backup entries.

Methods in com.hazelcast.map with parameters of type EntryProcessor

Modifier and Type	Method and Description
<R> Map<K,R>	IMap.executeOnEntries(EntryProcessor<K,V,R> entryProcessor) Applies the user defined EntryProcessor to the all entries in the map.
<R> Map<K,R>	IMap.executeOnEntries(EntryProcessor<K,V,R> entryProcessor, Predicate<K,V> predicate) Applies the user defined EntryProcessor to the entries in the map which satisfy provided predicate.
<R> R	IMap.executeOnKey(K key, EntryProcessor<K,V,R> entryProcessor) Applies the user defined EntryProcessor to the entry mapped by the key.
<R> Map<K,R>	IMap.executeOnKeys(Set<K> keys, EntryProcessor<K,V,R> entryProcessor) Applies the user defined EntryProcessor to the entries mapped by the collection of keys.
<R> CompletionStage<R>	IMap.submitToKey(K key, EntryProcessor<K,V,R> entryProcessor) Applies the user defined EntryProcessor to the entry mapped by the key.
<R> CompletionStage<Map<K,R>>	IMap.submitToKeys(Set<K> keys, EntryProcessor<K,V,R> entryProcessor) Async version of IMap.executeOnKeys(java.util.Set<K>, com.hazelcast.map.EntryProcessor<K, V, R>).