Uses of Interface
com.tangosol.util.InvocableMap.EntryProcessor

Packages that use InvocableMap.EntryProcessor

Package	Description
com.oracle.coherence.cdi.events	Support for adapting Coherence interceptors to standard CDI events.
com.oracle.coherence.concurrent.executor	Classes to allow submission of tasks to the grid for execution.
com.oracle.coherence.concurrent.executor.processors	EntryProcessors used by the Coherence Executor Service.
com.oracle.coherence.grpc.proxy.common.v0
com.tangosol.coherence.dslquery.statement	This package contains StatementBuilder implementations.
com.tangosol.coherence.rest.util.processor	Contains classes related to REST-based entry processing.
com.tangosol.net	Contains basic cluster interfaces and factories.
com.tangosol.net.cache	Contains classes providing various caching strategies.
com.tangosol.net.events.partition.cache	Contains classes related to PartitionedCache events within the Coherence Live Event Model.
com.tangosol.util	Contains various generic utilities.
com.tangosol.util.processor	Contains concrete InvocableMap.EntryProcessor implementations.

Uses of InvocableMap.EntryProcessor in com.oracle.coherence.cdi.events

Methods in com.oracle.coherence.cdi.events that return types with arguments of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
Class<? extends InvocableMap.EntryProcessor>	Processor.Literal.value()	The processor class.

Method parameters in com.oracle.coherence.cdi.events with type arguments of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
static Processor.Literal	Processor.Literal.of(Class<? extends InvocableMap.EntryProcessor> clzProcessor)	Create a Processor.Literal.

Uses of InvocableMap.EntryProcessor in com.oracle.coherence.concurrent.executor

Classes in com.oracle.coherence.concurrent.executor that implement InvocableMap.EntryProcessor

Modifier and Type	Class	Description
static class	ClusteredAssignment.AssignmentProcessor	An InvocableMap.EntryProcessor which updates an assignment due to an assignment ExecutionPlan.Action.
static class	ClusteredAssignment.SetStateProcessor	An InvocableMap.EntryProcessor to compare and set the state of a ClusteredAssignment, returning the previous state.
static class	ClusteredExecutorInfo.SetStateProcessor	An InvocableMap.EntryProcessor to compare and set the state of a ClusteredExecutorInfo, returning the previous state.
static class	ClusteredExecutorInfo.TouchProcessor	An InvocableMap.EntryProcessor to update the last update timestamp of a ClusteredExecutorInfo.
static class	ClusteredExecutorInfo.UpdateInfoProcessor	An InvocableMap.EntryProcessor to update the state of an TaskExecutorService.ExecutorInfo.
static class	ClusteredProperties.SetPropertyValueProcessor<K extends Serializable, V extends Serializable>	An InvocableMap.EntryProcessor for inserting/updating ClusteredProperties.PropertyKey/ClusteredProperties.PropertyValue mappings.
static class	ClusteredTaskManager.CancellationProcessor	An InvocableMap.EntryProcessor to terminate a running Task.
static class	ClusteredTaskManager.ChainedProcessor	A ClusteredTaskManager.ChainedProcessor executes zero or more contained InvocableMap.EntryProcessors in sequence against a single InvocableMap.Entry as a single transaction.
static class	ClusteredTaskManager.NotifyExecutionStrategyProcessor	An InvocableMap.EntryProcessor to notify the Task that an event has occurred which requires the ExecutionStrategy to be re-evaluated.
static class	ClusteredTaskManager.OptimizeExecutionPlanProcessor	An InvocableMap.EntryProcessor to optimize the ExecutionPlan for a Task.
static class	ClusteredTaskManager.RetainProcessor	Handles updating the ClusteredTaskManager appropriately if the task is being retained after execution.
static class	ClusteredTaskManager.SetActionProcessor	An InvocableMap.EntryProcessor to compare and set the action of a ExecutionPlan for a given Executor.
static class	ClusteredTaskManager.UpdateCollectedResultProcessor<T>	An PortableAbstractProcessor to update the collected result for a Task.
static class	ClusteredTaskManager.UpdateContributedResultProcessor	An InvocableMap.EntryProcessor to update a contributed Result for a specific Executor, returning true if the update was successful, false otherwise.
static class	ClusteredTaskManager.UpdateExecutionPlanProcessor	An InvocableMap.EntryProcessor to update the ExecutionPlan for a Task after the ExecutionStrategy has been evaluated.
class	PortableAbstractProcessor<K,V,R>	A portable AbstractProcessor. a convenience interface for implementations having no properties to serialize.

Fields in com.oracle.coherence.concurrent.executor with type parameters of type InvocableMap.EntryProcessor

Modifier and Type	Field	Description
protected ArrayList<InvocableMap.EntryProcessor>	ClusteredTaskManager.ChainedProcessor.m_listProcessors	InvocableMap.EntryProcessors to be invoked in list-order.

Methods in com.oracle.coherence.concurrent.executor with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
ClusteredTaskManager.ChainedProcessor	ClusteredTaskManager.ChainedProcessor.andThen(InvocableMap.EntryProcessor<String, ClusteredTaskManager, ?> processor)	Adds another InvocableMap.EntryProcessor to the ClusteredTaskManager.ChainedProcessor.

Uses of InvocableMap.EntryProcessor in com.oracle.coherence.concurrent.executor.processors

Classes in com.oracle.coherence.concurrent.executor.processors that implement InvocableMap.EntryProcessor

Modifier and Type	Class	Description
class	LocalOnlyProcessor<K,V,R>	An InvocableMap.EntryProcessor that invokes another InvocableMap.EntryProcessor only on Map.Entrys that are located in the process that created the LocalOnlyProcessor.

Fields in com.oracle.coherence.concurrent.executor.processors declared as InvocableMap.EntryProcessor

Modifier and Type	Field	Description
protected InvocableMap.EntryProcessor<K,V,R>	LocalOnlyProcessor.m_processor	The InvocableMap.EntryProcessor to invoke.

Methods in com.oracle.coherence.concurrent.executor.processors with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
static <K,V,R> LocalOnlyProcessor<K,V,R>	LocalOnlyProcessor.of(InvocableMap.EntryProcessor<K,V,R> processor)	Creates a LocalOnlyProcessor for the specified InvocableMap.EntryProcessor.

Constructors in com.oracle.coherence.concurrent.executor.processors with parameters of type InvocableMap.EntryProcessor

Modifier	Constructor	Description
	LocalOnlyProcessor(InvocableMap.EntryProcessor<K,V,R> processor)	Constructs a LocalOnlyProcessor for the specified InvocableMap.EntryProcessor.

Uses of InvocableMap.EntryProcessor in com.oracle.coherence.grpc.proxy.common.v0

Methods in com.oracle.coherence.grpc.proxy.common.v0 that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
protected InvocableMap.EntryProcessor<Binary,Binary,Binary>	BaseNamedCacheServiceImpl.castProcessor(InvocableMap.EntryProcessor<Binary,Binary,?> ep)	Cast an InvocableMap.EntryProcessor to an InvocableMap.EntryProcessor that returns a Binary result.

Methods in com.oracle.coherence.grpc.proxy.common.v0 with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
protected InvocableMap.EntryProcessor<Binary,Binary,Binary>	BaseNamedCacheServiceImpl.castProcessor(InvocableMap.EntryProcessor<Binary,Binary,?> ep)	Cast an InvocableMap.EntryProcessor to an InvocableMap.EntryProcessor that returns a Binary result.

Uses of InvocableMap.EntryProcessor in com.tangosol.coherence.dslquery.statement

Fields in com.tangosol.coherence.dslquery.statement declared as InvocableMap.EntryProcessor

Modifier and Type	Field	Description
protected final InvocableMap.EntryProcessor	UpdateStatementBuilder.UpdateStatement.f_processor	The InvocableMap.EntryProcessor that will perform the "update" command.

Constructors in com.tangosol.coherence.dslquery.statement with parameters of type InvocableMap.EntryProcessor

Modifier	Constructor	Description
	UpdateStatement(String sCache, Filter filter, InvocableMap.EntryProcessor processor)	Construct a UpdateStatement that will update the specified cache.

Uses of InvocableMap.EntryProcessor in com.tangosol.coherence.rest.util.processor

Methods in com.tangosol.coherence.rest.util.processor that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
protected InvocableMap.EntryProcessor	DefaultProcessorFactory.createProcessor(String sProperty)	Create and initialize a new processor instance.
InvocableMap.EntryProcessor	DefaultProcessorFactory.getProcessor(String... asArgs)	Return a processor instantiated by calling a processor class constructor.
InvocableMap.EntryProcessor	NumberIncrementorFactory.getProcessor(String... asArgs)	Returns a processor instance.
InvocableMap.EntryProcessor	NumberMultiplierFactory.getProcessor(String... asArgs)	Returns a processor instance.
InvocableMap.EntryProcessor<K,V,R>	ProcessorFactory.getProcessor(String... asArgs)	Returns a processor instance.
InvocableMap.EntryProcessor	ProcessorRegistry.getProcessor(String sRequest)	Returns a configured processor.

Uses of InvocableMap.EntryProcessor in com.tangosol.net

Methods in com.tangosol.net with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
<R> CompletableFuture<R>	AsyncNamedMap.invoke(K key, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the Entry specified by the passed key asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation.
<R> CompletableFuture<Map<K,R>>	AsyncNamedMap.invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation for each entry.
default <R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<K,V,R> processor, BiConsumer<? super K, ? super R> callback)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.
<R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> callback)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.
default <R> CompletableFuture<Map<K,R>>	AsyncNamedMap.invokeAll(InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against all the entries asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation for each entry.
default <R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(InvocableMap.EntryProcessor<K,V,R> processor, BiConsumer<? super K, ? super R> callback)	Invoke the passed EntryProcessor against all the entries asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.
default <R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> callback)	Invoke the passed EntryProcessor against all the entries asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.
<R> CompletableFuture<Map<K,R>>	AsyncNamedMap.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the entries specified by the passed keys asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation for each entry.
default <R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> processor, BiConsumer<? super K, ? super R> callback)	Invoke the passed EntryProcessor against the entries specified by the passed keys asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.
<R> CompletableFuture<Void>	AsyncNamedMap.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> callback)	Invoke the passed EntryProcessor against the entries specified by the passed keys asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.

Uses of InvocableMap.EntryProcessor in com.tangosol.net.cache

Classes in com.tangosol.net.cache that implement InvocableMap.EntryProcessor

Modifier and Type	Class	Description
protected class	ContinuousQueryCache.ConverterAsynchronousProcessor	Wraps an AsynchronousProcessor to ensure the result of the EntryProcessor execution is deserialized prior to passing to the provided AsynchronousProcessor.

Methods in com.tangosol.net.cache that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
protected InvocableMap.EntryProcessor	ContinuousQueryCache.ensureConverted(InvocableMap.EntryProcessor processor)	Wrap any AsynchronousProcessor instances with a custom wrapper to perform conversion of result returned by the processor.
InvocableMap.EntryProcessor	ContinuousQueryCache.ConverterAsynchronousProcessor.getProcessor()

Methods in com.tangosol.net.cache with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
protected InvocableMap.EntryProcessor	ContinuousQueryCache.ensureConverted(InvocableMap.EntryProcessor processor)	Wrap any AsynchronousProcessor instances with a custom wrapper to perform conversion of result returned by the processor.
<R> R	ContinuousQueryCache.invoke(K key, InvocableMap.EntryProcessor<K,V_FRONT,R> processor)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> R	NearCache.invoke(K key, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> R	ReadonlyNamedCache.invoke(K key, InvocableMap.EntryProcessor<K,V,R> agent)	Should not be called.
<R> R	WrapperNamedCache.invoke(K key, InvocableMap.EntryProcessor<K,V,R> agent)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> Map<K,R>	ContinuousQueryCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V_FRONT,R> processor)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
<R> Map<K,R>	ContinuousQueryCache.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V_FRONT,R> processor)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
<R> Map<K,R>	NearCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
<R> Map<K,R>	NearCache.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
<R> Map<K,R>	ReadonlyNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> agent)	Should not be called.
<R> Map<K,R>	ReadonlyNamedCache.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> agent)	Should not be called.
<R> Map<K,R>	WrapperNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> agent)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
<R> Map<K,R>	WrapperNamedCache.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> agent)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.

Uses of InvocableMap.EntryProcessor in com.tangosol.net.events.partition.cache

Methods in com.tangosol.net.events.partition.cache that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
InvocableMap.EntryProcessor	EntryProcessorEvent.getProcessor()	Return the InvocableMap.EntryProcessor associated with this EntryProcessorEvent.

Uses of InvocableMap.EntryProcessor in com.tangosol.util

Classes in com.tangosol.util that implement InvocableMap.EntryProcessor

Modifier and Type	Class	Description
static class	NullImplementation.NullEntryProcessor	An implementation of an EntryProcessor that does nothing and returns Boolean.TRUE as a result of execution.

Methods in com.tangosol.util that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
static InvocableMap.EntryProcessor	NullImplementation.getEntryProcessor()	Factory method: Obtain a null implementation of an EntryProcessor.
static <K,V> InvocableMap.EntryProcessor<K,V,V>	Processors.preload()	Construct the preload request processor.
static <K,V> InvocableMap.EntryProcessor<K,V,Boolean>	Processors.remove()	Construct a remove processor that unconditionally removes an InvocableMap entry.
static <K,V> InvocableMap.EntryProcessor<K,V,V>	Processors.remove(boolean fReturn)	Construct a remove processor that unconditionally removes an InvocableMap entry, and optionally returns the removed value.
static <K,V> InvocableMap.EntryProcessor<K,V,Void>	Processors.touch()	Construct a touch processor.

Methods in com.tangosol.util with parameters of type InvocableMap.EntryProcessor

Modifier and Type	Method	Description
static <K,V,R> AsynchronousProcessor<K,V,R>	Processors.asynchronous(InvocableMap.EntryProcessor<K,V,R> processor)	Construct an asynchronous processor for a given processor.
static <K,V,R> AsynchronousProcessor<K,V,R>	Processors.asynchronous(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)	Construct an asynchronous processor for a given processor with unit-of-order id.
static <K,V> CompositeProcessor<K,V>	Processors.composite(InvocableMap.EntryProcessor<K,V,?>[] aProcessor)	Construct a composite processor for the specified array of individual entry processors.
static <K,V,T> ConditionalProcessor<K,V,T>	Processors.conditional(Filter<V> filter, InvocableMap.EntryProcessor<K,V,T> processor)	Construct a conditional processor for a specified filter and the processor.
<R> CompletableFuture<R>	ConverterCollections.ConverterAsyncNamedCache.invoke(TK key, InvocableMap.EntryProcessor<TK,TV,R> processor)
<R> R	ConverterCollections.ConverterInvocableMap.invoke(TK key, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> R	ConverterCollections.ConverterNamedCache.invoke(TK key, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> R	InvocableMap.invoke(K key, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
<R> CompletableFuture<Map<TK,R>>	ConverterCollections.ConverterAsyncNamedCache.invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<TK,TV,R> processor)
<R> CompletableFuture<Void>	ConverterCollections.ConverterAsyncNamedCache.invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<TK,TV,R> processor, Consumer<? super Map.Entry<? extends TK, ? extends R>> callback)
<R> CompletableFuture<Map<TK,R>>	ConverterCollections.ConverterAsyncNamedCache.invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> processor)
<R> CompletableFuture<Void>	ConverterCollections.ConverterAsyncNamedCache.invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> processor, Consumer<? super Map.Entry<? extends TK, ? extends R>> callback)
<R> Map<TK,R>	ConverterCollections.ConverterInvocableMap.invokeAll(Filter filter, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
<R> Map<TK,R>	ConverterCollections.ConverterInvocableMap.invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
<R> Map<TK,R>	ConverterCollections.ConverterNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
<R> Map<TK,R>	ConverterCollections.ConverterNamedCache.invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> agent)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
<R> Map<K,R>	InvocableMap.invokeAll(Filter filter, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter, returning the result of the invocation for each.
default <R> Map<K,R>	InvocableMap.invokeAll(InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against all the entries, returning the result of the invocation for each.
<R> Map<K,R>	InvocableMap.invokeAll(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> processor)	Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
static <K,V,R> CompletableFuture<Map<K,R>>	InvocableMapHelper.invokeAllAsync(NamedCache<K,V> cache, Collection<? extends K> setKey, int nOrderId, InvocableMap.EntryProcessor<K,V,R> proc, Executor executor, BiConsumer<? super Map<? extends K, ? extends R>, ? super Throwable>... continuations)	Invoke the specified EntryProcessor asynchronously.
static <K,V,R> CompletableFuture<Map<K,R>>	InvocableMapHelper.invokeAllAsync(NamedCache<K,V> cache, Collection<? extends K> setKey, ToIntFunction<K> funcOrder, InvocableMap.EntryProcessor<K,V,R> proc, Executor executor, BiConsumer<? super Map<? extends K, ? extends R>, ? super Throwable>... continuations)	Invoke the specified EntryProcessor asynchronously.
static <K,V,R> CompletableFuture<Map<K,R>>	InvocableMapHelper.invokeAllAsync(NamedCache<K,V> cache, Collection<? extends K> setKey, ToIntFunction<K> funcOrder, InvocableMap.EntryProcessor<K,V,R> proc, BiConsumer<? super Map<? extends K, ? extends R>, ? super Throwable>... continuations)	Invoke the specified EntryProcessor asynchronously.
static <K,V,R> Map<K,R>	InvocableMapHelper.invokeAllLocked(ConcurrentMap<K,V> map, Set<? extends InvocableMap.Entry<K,V>> setEntries, InvocableMap.EntryProcessor<K,V,R> agent)	Invoke the passed EntryProcessor against the entries specified by the passed map and entries.
static <K,V,R> CompletableFuture<R>	InvocableMapHelper.invokeAsync(NamedCache<K,V> cache, K key, int nOrderId, InvocableMap.EntryProcessor<K,V,R> proc, Executor executor, BiConsumer<? super R, ? super Throwable>... continuations)	Invoke the specified EntryProcessor asynchronously.
static <K,V,R> CompletableFuture<R>	InvocableMapHelper.invokeAsync(NamedCache<K,V> cache, K key, int nOrderId, InvocableMap.EntryProcessor<K,V,R> proc, BiConsumer<? super R, ? super Throwable>... continuations)	Invoke the specified EntryProcessor asynchronously.
static <K,V,R> CompletableFuture<R>	InvocableMapHelper.invokeAsync(NamedCache<K,V> cache, K key, InvocableMap.EntryProcessor<K,V,R> proc)	Deprecated. As of Coherence 14.1.1, use enhanced InvocableMapHelper.invokeAsync(NamedCache, Object, int, InvocableMap.EntryProcessor, BiConsumer[]).
static <K,V,R> R	InvocableMapHelper.invokeLocked(ConcurrentMap<K,V> map, InvocableMap.Entry<K,V> entry, InvocableMap.EntryProcessor<K,V,R> agent)	Invoke the passed EntryProcessor against the specified Entry.
static <K,V,R> PriorityProcessor<K,V,R>	Processors.priority(InvocableMap.EntryProcessor<K,V,R> processor)	Construct a priority processor for a given processor.
static <K,V,R> SingleEntryAsynchronousProcessor<K,V,R>	Processors.singleEntryAsynchronous(InvocableMap.EntryProcessor<K,V,R> processor)	Construct a single entry asynchronous processor for a given processor.
static <K,V,R> SingleEntryAsynchronousProcessor<K,V,R>	Processors.singleEntryAsynchronous(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)	Construct a single entry asynchronous for a given processor with unit-of-order id.
static <K,V,R> StreamingAsynchronousProcessor<K,V,R>	Processors.streamingAsynchronous(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial)	Construct a streaming asynchronous processor for a given processor and one or more callbacks.
static <K,V,R> StreamingAsynchronousProcessor<K,V,R>	Processors.streamingAsynchronous(InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial)	Construct a streaming asynchronous processor for a given processor and one or more callbacks.

Uses of InvocableMap.EntryProcessor in com.tangosol.util.processor

Classes in com.tangosol.util.processor that implement InvocableMap.EntryProcessor

Modifier and Type	Class	Description
class	AbstractAsynchronousProcessor<K,V,R,T>	Abstract base class for asynchronous entry processors.
class	AbstractEvolvableProcessor<K,V,R>	An Evolvable AbstractProcessor that is a partial EntryProcessor implementation that provides the default implementation of the AbstractEvolvableProcessor.processAll(java.util.Set<? extends com.tangosol.util.InvocableMap.Entry<K, V>>) method.
class	AbstractProcessor<K,V,R>	An AbstractProcessor is a partial EntryProcessor implementation that provides the default implementation of the AbstractProcessor.processAll(java.util.Set<? extends com.tangosol.util.InvocableMap.Entry<K, V>>) method.
class	AsynchronousProcessor<K,V,R>	An EntryProcessor wrapper class that allows for an asynchronous invocation of the underlying processor.
class	CompositeProcessor<K,V>	The CompositeProcessor represents a collection of entry processors that are invoked sequentially against the same Entry.
class	ConditionalProcessor<K,V,T>	Conditional entry processor represents a processor that is invoked conditionally based on the result of an entry evaluation.
class	ConditionalPut<K,V>	ConditionalPut is an EntryProcessor that performs an Entry.setValue operation if the specified condition is satisfied.
class	ConditionalPutAll<K,V>	ConditionalPutAll is an EntryProcessor that performs a Entry.setValue operation for multiple entries that satisfy the specified condition.
class	ConditionalRemove<K,V>	ConditionalRemove is an EntryProcessor that performs an Entry.remove operation if the specified condition is satisfied.
class	ExtractorProcessor<K,V,T,E>	ExtractorProcessor is an EntryProcessor implementations that extracts a value from an object cached in an InvocableMap.
class	MethodInvocationProcessor<K,V,R>	An entry processor that invokes specified method on a value of a cache entry and optionally updates the entry with a modified value.
class	NumberIncrementor<K, V, N extends Number>	The NumberIncrementor entry processor is used to increment a property value of a Number type.
class	NumberMultiplier<K, V, N extends Number>	The NumberMultiplier entry processor is used to multiply a property value of a Number type.
class	PreloadRequest<K,V>	PreloadRequest is a simple EntryProcessor that performs a Entry.getValue call.
class	PriorityProcessor<K,V,T>	PriorityProcessor is used to explicitly control the scheduling priority and timeouts for execution of EntryProcessor-based methods.
class	PropertyProcessor<K,V,R>	PropertyProcessor is a base class for EntryProcessor implementations that depend on a ValueManipulator.
class	ScriptProcessor<K,V,R>	ScriptProcessor is an InvocableMap.EntryProcessor that wraps a script written in one of the languages supported by Graal VM.
class	SingleEntryAsynchronousProcessor<K,V,R>	An EntryProcessor wrapper class that allows for an asynchronous invocation of the underlying processor against a single cache entry.
class	StreamingAsynchronousProcessor<K,V,R>	An EntryProcessor wrapper class that allows for an asynchronous invocation of the underlying processor.
class	TouchProcessor<K,V,R>	Touches an entry (if present) in order to trigger interceptor re-evaluation and possibly increment expiry time.
class	UpdaterProcessor<K,V,T>	UpdaterProcessor is an EntryProcessor implementations that updates an attribute of an object cached in an InvocableMap.
class	VersionedPut<K, V extends Versionable>	VersionedPut is an EntryProcessor that assumes that entry values implement Versionable interface and performs an Entry.setValue operation if and only if the version of the specified value matches to the version of the current value.
class	VersionedPutAll<K, V extends Versionable>	VersionedPutAll is an EntryProcessor that assumes that entry values implement Versionable interface and performs an Entry.setValue operation only for entries whose versions match to versions of the corresponding current values.

Fields in com.tangosol.util.processor declared as InvocableMap.EntryProcessor

Modifier and Type	Field	Description
protected final InvocableMap.EntryProcessor<K,V,R>	AbstractAsynchronousProcessor.f_processor	The underlying entry processor.
protected InvocableMap.EntryProcessor<K,V,?>[]	CompositeProcessor.m_aProcessor	The underlying entry processor array.
protected InvocableMap.EntryProcessor<K,V,T>	ConditionalProcessor.m_processor	The underlying entry processor.

Methods in com.tangosol.util.processor that return InvocableMap.EntryProcessor

Modifier and Type	Method	Description
InvocableMap.EntryProcessor<K,V,R>	AbstractAsynchronousProcessor.getProcessor()	Obtain the underlying entry processor.
InvocableMap.EntryProcessor<K,V,T>	PriorityProcessor.getProcessor()	Obtain the underlying processor.

Constructors in com.tangosol.util.processor with parameters of type InvocableMap.EntryProcessor

Modifier	Constructor	Description
protected	AbstractAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)	Construct AbstractAsynchronousProcessor instance.
protected	AbstractAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Executor executor)	Construct AbstractAsynchronousProcessor instance.
	AsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor)	Construct an AsynchronousProcessor for a given processor.
	AsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)	Construct an AsynchronousProcessor for a given processor.
	AsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Executor executor)	Construct an AsynchronousProcessor for a given processor.
	AsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, Executor executor)	Construct an AsynchronousProcessor for a given processor.
	CompositeProcessor(InvocableMap.EntryProcessor<K,V,?>[] aProcessor)	Construct a CompositeProcessor for the specified array of individual entry processors.
	ConditionalProcessor(Filter<V> filter, InvocableMap.EntryProcessor<K,V,T> processor)	Construct a ConditionalProcessor for the specified filter and the processor.
	PriorityProcessor(InvocableMap.EntryProcessor<K,V,T> processor)	Construct a PriorityProcessor.
	SingleEntryAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor)	Construct a SingleEntryAsynchronousProcessor for a given processor.
	SingleEntryAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)	Construct a SingleEntryAsynchronousProcessor for a given processor.
	SingleEntryAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Executor executor)	Construct a SingleEntryAsynchronousProcessor for a given processor.
	SingleEntryAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, Executor executor)	Construct a SingleEntryAsynchronousProcessor for a given processor.
	StreamingAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial)	Construct a StreamingAsynchronousProcessor for a given processor and one or more callbacks.
	StreamingAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial, Executor executor)	Construct a StreamingAsynchronousProcessor for a given processor and one or more callbacks.
	StreamingAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial)	Construct a StreamingAsynchronousProcessor for a given processor and one or more callbacks.
	StreamingAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, Consumer<? super Map.Entry<? extends K, ? extends R>> onPartial, Executor executor)	Construct a StreamingAsynchronousProcessor for a given processor and one or more callbacks.