Package | Description |
---|---|
com.tangosol.coherence.dslquery.internal | |
com.tangosol.coherence.dslquery.statement |
This package contains
StatementBuilder implementations and com.tangosol.coherence.dslquery.CohQLStatement 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. |
Modifier and Type | Method and Description |
---|---|
InvocableMap.EntryProcessor |
UpdateSetListMaker.getResultAsEntryProcessor()
Turn the results of tree processing into an InvocableMap.EntryProcessor that will return the results of the update
|
InvocableMap.EntryProcessor |
SelectListMaker.getResultsAsEntryProcessor()
Turn the results of tree processing into an InvocableMap.EntryProcessor that will return the results of a query
|
InvocableMap.EntryProcessor |
UpdateSetListMaker.makeSetList()
Process the AST Tree using the already set AST Tree
|
InvocableMap.EntryProcessor |
UpdateSetListMaker.makeSetList(NodeTerm term)
Process the AST Tree using the given Term
|
Modifier and Type | Field and Description |
---|---|
protected InvocableMap.EntryProcessor |
UpdateStatementBuilder.UpdateStatement.f_processor
The
InvocableMap.EntryProcessor that will perform the "update" command. |
Constructor and Description |
---|
UpdateStatement(String sCache, Filter filter, InvocableMap.EntryProcessor processor)
Construct a UpdateStatement that will update the specified cache.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
<R> CompletableFuture<R> |
AsyncNamedCache.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>> |
AsyncNamedCache.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> |
AsyncNamedCache.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> |
AsyncNamedCache.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. |
<R> CompletableFuture<Map<K,R>> |
AsyncNamedCache.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> |
AsyncNamedCache.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> |
AsyncNamedCache.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>> |
AsyncNamedCache.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> |
AsyncNamedCache.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> |
AsyncNamedCache.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. |
Modifier and Type | Method and Description |
---|---|
<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(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(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(Collection<? extends K> collKeys, InvocableMap.EntryProcessor<K,V,R> agent)
Should not be called.
|
<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.
|
<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> |
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> |
ReadonlyNamedCache.invokeAll(Filter filter, 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.
|
Modifier and Type | Method and Description |
---|---|
InvocableMap.EntryProcessor |
EntryProcessorEvent.getProcessor()
Return the
InvocableMap.EntryProcessor associated with this EntryProcessorEvent . |
Modifier and Type | Class and Description |
---|---|
static class |
NullImplementation.NullEntryProcessor
An implementation of an EntryProcessor that does nothing and returns Boolean.TRUE as a result of execution.
|
Modifier and Type | Method and Description |
---|---|
static InvocableMap.EntryProcessor |
NullImplementation.getEntryProcessor()
Factory method: Obtain a null implementation of an EntryProcessor.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Object |
ConverterCollections.ConverterInvocableMap.invoke(Object oKey, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
|
Object |
ConverterCollections.ConverterNamedCache.invoke(Object oKey, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the Entry specified by the passed key, returning the result of the invocation.
|
<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.
|
Map |
ConverterCollections.ConverterInvocableMap.invokeAll(Collection collKeys, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
|
Map |
ConverterCollections.ConverterNamedCache.invokeAll(Collection collKeys, InvocableMap.EntryProcessor agent)
Invoke the passed EntryProcessor against the entries specified by the passed keys, returning the result of the invocation for each.
|
Map |
ConverterCollections.ConverterInvocableMap.invokeAll(Filter filter, InvocableMap.EntryProcessor 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.
|
Map |
ConverterCollections.ConverterNamedCache.invokeAll(Filter filter, InvocableMap.EntryProcessor 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> |
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.
|
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, InvocableMap.EntryProcessor<K,V,R> proc)
Invoke the specified EntryProcessor asynchronously.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsynchronousProcessor<K,V,R,T>
Abstract base class for asynchronous entry processors.
|
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 |
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
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. |
Modifier and Type | Field and 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.
|
Modifier and Type | Method and Description |
---|---|
InvocableMap.EntryProcessor<K,V,R> |
AbstractAsynchronousProcessor.getProcessor()
Obtain the underlying entry processor.
|
InvocableMap.EntryProcessor<K,V,T> |
PriorityProcessor.getProcessor()
Obtain the underlying processor.
|
Constructor and 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, 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)
Construct an for a given processor, and one or more callbacks.
|