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.grpc.proxy The Coherence gRPC server implementation.com.tangosol.coherence.dslquery.statement This package containsStatementBuilder
implementations.com.tangosol.coherence.rest.util.processor Contains classes related to REST-based entry processing.com.tangosol.coherence.servlet Contains classes related to the HTTP Session Replication Module.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 concreteInvocableMap.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.Class<? extends InvocableMap.EntryProcessor>
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 aProcessor.Literal
. -
Uses of InvocableMap.EntryProcessor in com.oracle.coherence.grpc.proxy
Methods in com.oracle.coherence.grpc.proxy that return InvocableMap.EntryProcessor Modifier and Type Method Description protected InvocableMap.EntryProcessor<Binary,Binary,Binary>
NamedCacheServiceImpl. castProcessor(InvocableMap.EntryProcessor<Binary,Binary,?> ep)
Methods in com.oracle.coherence.grpc.proxy with parameters of type InvocableMap.EntryProcessor Modifier and Type Method Description protected InvocableMap.EntryProcessor<Binary,Binary,Binary>
NamedCacheServiceImpl. castProcessor(InvocableMap.EntryProcessor<Binary,Binary,?> ep)
-
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 InvocableMap.EntryProcessor
UpdateStatementBuilder.UpdateStatement. f_processor
TheInvocableMap.EntryProcessor
that will perform the "update" command.Constructors in com.tangosol.coherence.dslquery.statement with parameters of type InvocableMap.EntryProcessor 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.coherence.servlet
Classes in com.tangosol.coherence.servlet that implement InvocableMap.EntryProcessor Modifier and Type Class Description class
GetElasticMaxValueSizeProcessor
An EntryProcessor that returns the configured Elastic Data maximum value size if the cache is backed by Elastic Data; 0 otherwise. -
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 aCompletableFuture
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 anAsynchronousProcessor
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 anyAsynchronousProcessor
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 anyAsynchronousProcessor
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 theInvocableMap.EntryProcessor
associated with thisEntryProcessorEvent
. -
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 <K,V,R>
InvocableMap.EntryProcessor<K,V,R>Processors. asynchronous(InvocableMap.EntryProcessor<K,V,R> processor)
Construct an asynchronous processor for a given processor.static <K,V,R>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<K,V,Object>Processors. composite(InvocableMap.EntryProcessor<K,V,?>[] aProcessor)
Construct a composite processor for the specified array of individual entry processors.static <K,V,T>
InvocableMap.EntryProcessor<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.static <K,V,T,R>
InvocableMap.EntryProcessor<K,V,R>Processors. extract(ValueExtractor<? super T,? extends R> extractor)
Construct an extract processor based on the specifiedValueExtractor
.static <K,V,R>
InvocableMap.EntryProcessor<K,V,R>Processors. extract(String sName)
Construct an extract processor for a given property or method name.static InvocableMap.EntryProcessor
NullImplementation. getEntryProcessor()
Factory method: Obtain a null implementation of an EntryProcessor.static <K,V,N extends Number>
InvocableMap.EntryProcessor<K,V,N>Processors. increment(PropertyManipulator manipulator, N numInc, boolean fPostIncrement)
Construct an increment processor that will increment a property value by a specified amount, returning either the old or the new value as specified.static <K,V,N extends Number>
InvocableMap.EntryProcessor<K,V,N>Processors. increment(String sName, N numInc, boolean fPostIncrement)
Construct an increment processor that will increment a property value by a specified amount, returning either the old or the new value as specified.static <K,V,N extends Number>
InvocableMap.EntryProcessor<K,V,N>Processors. multiply(PropertyManipulator<V,N> manipulator, N numFactor, boolean fPostFactor)
Construct a multiply processor that will multiply a property value by a specified factor, returning either the old or the new value as specified.static <K,V,N extends Number>
InvocableMap.EntryProcessor<K,V,N>Processors. multiply(String sName, N numFactor, boolean fPostFactor)
Construct a multiply processor that will multiply a property value by a specified factor, returning either the old or the new value as specified.static <K,V>
InvocableMap.EntryProcessor<K,V,V>Processors. preload()
Construct the preload request processor.static <K,V,T>
InvocableMap.EntryProcessor<K,V,T>Processors. priority(InvocableMap.EntryProcessor<K,V,T> processor)
Construct a priority processor for a given processor.static <K,V>
InvocableMap.EntryProcessor<K,V,V>Processors. put(Filter filter, V value)
Construct a put processor that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.static <K,V>
InvocableMap.EntryProcessor<K,V,V>Processors. put(Filter filter, V value, boolean fReturn)
Construct a put processor that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.static <K,V>
InvocableMap.EntryProcessor<K,V,V>Processors. putAll(Filter filter, Map<? extends K,? extends V> map)
Construct a putAll processor that updates an entry with a new value if and only if the filter applied to the entry evaluates to true.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,V>Processors. remove(Filter filter)
Construct a remove processor that removes an InvocableMap entry if and only if the filter applied to the entry evaluates to true.static <K,V>
InvocableMap.EntryProcessor<K,V,V>Processors. remove(Filter filter, boolean fReturn)
Construct a remove processor that removes an InvocableMap entry if and only if the filter applied to the entry evaluates to true.static <K,V,R>
InvocableMap.EntryProcessor<K,V,R>Processors. script(String sLanguage, String sName, Object... aoArgs)
Construct an EntryProcessor that is implemented in a script using the specified language.static <K,V,R>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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.static <K,V>
InvocableMap.EntryProcessor<K,V,Void>Processors. touch()
Construct a touch processor.static <K,V,T>
InvocableMap.EntryProcessor<K,V,Boolean>Processors. update(ValueUpdater<V,T> updater, T value)
Construct an update processor based on the specifiedValueUpdater
.static <K,V,T>
InvocableMap.EntryProcessor<K,V,Boolean>Processors. update(String sMethod, T value)
Construct an update processor for a given method name.static <K,V extends Versionable>
InvocableMap.EntryProcessor<K,V,V>Processors. versionedPut(V oValue)
Construct a versioned put processor that updates an entry with a new value if and only if the version of the new value matches to the version of the current entry's value (which must exist).static <K,V extends Versionable>
InvocableMap.EntryProcessor<K,V,V>Processors. versionedPut(V oValue, boolean fAllowInsert, boolean fReturn)
Construct a versioned put processor that updates an entry with a new value if and only if the version of the new value matches to the version of the current entry's value.static <K,V extends Versionable>
InvocableMap.EntryProcessor<K,V,V>Processors. versionedPutAll(Map<? extends K,? extends V> map)
Construct a versioned putAll processor that updates an entry with a new value if and only if the version of the new value matches to the version of the current entry's value (which must exist).static <K,V extends Versionable>
InvocableMap.EntryProcessor<K,V,V>Processors. versionedPutAll(Map<? extends K,? extends V> map, boolean fAllowInsert, boolean fReturn)
Construct a versioned putAll processor that updates an entry with a new value if and only if the version of the new value matches to the version of the current entry's value (which must exist).Methods in com.tangosol.util with parameters of type InvocableMap.EntryProcessor Modifier and Type Method Description static <K,V,R>
InvocableMap.EntryProcessor<K,V,R>Processors. asynchronous(InvocableMap.EntryProcessor<K,V,R> processor)
Construct an asynchronous processor for a given processor.static <K,V,R>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<K,V,Object>Processors. composite(InvocableMap.EntryProcessor<K,V,?>[] aProcessor)
Construct a composite processor for the specified array of individual entry processors.static <K,V,T>
InvocableMap.EntryProcessor<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> 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> 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, 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, 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 enhancedInvocableMapHelper.invokeAsync(NamedCache, Object, int, EntryProcessor, BiConsumer[])
.static <K,V,R>
RInvocableMapHelper. 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,T>
InvocableMap.EntryProcessor<K,V,T>Processors. priority(InvocableMap.EntryProcessor<K,V,T> processor)
Construct a priority processor for a given processor.static <K,V,R>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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>
InvocableMap.EntryProcessor<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 theAbstractEvolvableProcessor.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 theAbstractProcessor.processAll(java.util.Set<? extends com.tangosol.util.InvocableMap.Entry<K, V>>)
method.class
AsynchronousProcessor<K,V,R>
AnEntryProcessor
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 anEntry.setValue
operation if the specified condition is satisfied.class
ConditionalPutAll<K,V>
ConditionalPutAll is an EntryProcessor that performs aEntry.setValue
operation for multiple entries that satisfy the specified condition.class
ConditionalRemove<K,V>
ConditionalRemove is an EntryProcessor that performs anEntry.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 aNumber
type.class
NumberMultiplier<K,V,N extends Number>
The NumberMultiplier entry processor is used to multiply a property value of aNumber
type.class
PreloadRequest<K,V>
PreloadRequest is a simple EntryProcessor that performs aEntry.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 anInvocableMap.EntryProcessor
that wraps a script written in one of the languages supported by Graal VM.class
SingleEntryAsynchronousProcessor<K,V,R>
AnEntryProcessor
wrapper class that allows for an asynchronous invocation of the underlying processor against a single cache entry.class
StreamingAsynchronousProcessor<K,V,R>
AnEntryProcessor
wrapper class that allows for an asynchronous invocation of the underlying processor.class
TouchProcessor
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 implementVersionable
interface and performs anEntry.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 implementVersionable
interface and performs anEntry.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 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 Constructor Description AbstractAsynchronousProcessor(InvocableMap.EntryProcessor<K,V,R> processor, int iUnitOrderId)
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.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.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, Consumer<? super Map.Entry<? extends K,? extends R>> onPartial)
Construct a StreamingAsynchronousProcessor for a given processor and one or more callbacks.
-