Uses of Class
com.tangosol.util.processor.AbstractProcessor
Packages that use AbstractProcessor
Package
Description
Classes to allow submission of tasks to the grid for execution.
EntryProcessors used by the Coherence Executor Service.
Contains various generic utilities.
Contains concrete
InvocableMap.EntryProcessor
implementations.-
Uses of AbstractProcessor in com.oracle.coherence.concurrent.executor
Subclasses of AbstractProcessor in com.oracle.coherence.concurrent.executorModifier and TypeClassDescriptionstatic class
AnInvocableMap.EntryProcessor
which updates an assignment due to an assignmentExecutionPlan.Action
.static class
AnInvocableMap.EntryProcessor
to compare and set the state of aClusteredAssignment
, returning the previous state.static class
AnInvocableMap.EntryProcessor
to compare and set the state of aClusteredExecutorInfo
, returning the previous state.static class
AnInvocableMap.EntryProcessor
to update the last update timestamp of aClusteredExecutorInfo
.static class
AnInvocableMap.EntryProcessor
to update the state of anTaskExecutorService.ExecutorInfo
.static class
ClusteredProperties.SetPropertyValueProcessor<K extends Serializable, V extends Serializable>
AnInvocableMap.EntryProcessor
for inserting/updatingClusteredProperties.PropertyKey
/ClusteredProperties.PropertyValue
mappings.static class
AnInvocableMap.EntryProcessor
to terminate a runningTask
.static class
AClusteredTaskManager.ChainedProcessor
executes zero or more containedInvocableMap.EntryProcessor
s in sequence against a singleInvocableMap.Entry
as a single transaction.static class
AnInvocableMap.EntryProcessor
to notify theTask
that an event has occurred which requires theExecutionStrategy
to be re-evaluated.static class
static class
Handles updating theClusteredTaskManager
appropriately if the task is being retained after execution.static class
AnInvocableMap.EntryProcessor
to compare and set the action of aExecutionPlan
for a givenExecutor
.static class
AnPortableAbstractProcessor
to update the collected result for aTask
.static class
AnInvocableMap.EntryProcessor
to update a contributedResult
for a specificExecutor
, returningtrue
if the update was successful,false
otherwise.static class
AnInvocableMap.EntryProcessor
to update theExecutionPlan
for aTask
after theExecutionStrategy
has been evaluated.class
PortableAbstractProcessor<K,
V, R> A portableAbstractProcessor
. a convenience interface for implementations having no properties to serialize. -
Uses of AbstractProcessor in com.oracle.coherence.concurrent.executor.processors
Subclasses of AbstractProcessor in com.oracle.coherence.concurrent.executor.processorsModifier and TypeClassDescriptionclass
LocalOnlyProcessor<K,
V, R> AnInvocableMap.EntryProcessor
that invokes anotherInvocableMap.EntryProcessor
only onMap.Entry
s that are located in the process that created theLocalOnlyProcessor
. -
Uses of AbstractProcessor in com.tangosol.util
Subclasses of AbstractProcessor in com.tangosol.utilModifier and TypeClassDescriptionstatic class
An implementation of an EntryProcessor that does nothing and returns Boolean.TRUE as a result of execution. -
Uses of AbstractProcessor in com.tangosol.util.processor
Subclasses of AbstractProcessor in com.tangosol.util.processorModifier and TypeClassDescriptionclass
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
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
PropertyProcessor<K,
V, R> PropertyProcessor is a base class for EntryProcessor implementations that depend on a ValueManipulator.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.