Show / Hide Table of Contents

Class AbstractProcessor

An AbstractProcessor is a partial IEntryProcessor implementation that provides the default implementation of the ProcessAll(ICollection) method.

Inheritance
object
AbstractProcessor
AbstractClusterProcessor
CompositeProcessor
ConditionalProcessor
ConditionalPut
ConditionalPutAll
ConditionalRemove
ExtractorProcessor
PreloadRequest
PropertyProcessor
UpdaterProcessor
VersionedPut
VersionedPutAll
ResetSessionTimeoutProcessor
SaveSessionProcessor
Implements
IEntryProcessor
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: Tangosol.Util.Processor
Assembly: Coherence.dll
Syntax
public abstract class AbstractProcessor : IEntryProcessor
Remarks

For EntryProcessors which only run within the Coherence cluster (most common case), the .NET Process and ProcessAll methods can be left unimplemented.

Methods

Process(IInvocableCacheEntry)

Process an IInvocableCacheEntry.

Declaration
public virtual object Process(IInvocableCacheEntry entry)
Parameters
Type Name Description
IInvocableCacheEntry entry

The IInvocableCacheEntry to process.

Returns
Type Description
object

The result of the processing, if any.

Remarks

This implementation throws a NotSupportedException.

ProcessAll(ICollection)

Process a collection of IInvocableCacheEntry objects.

Declaration
public virtual IDictionary ProcessAll(ICollection entries)
Parameters
Type Name Description
ICollection entries

A read-only collection of IInvocableCacheEntry objects to process.

Returns
Type Description
IDictionary

A dictionary containing the results of the processing, up to one entry for each IInvocableCacheEntry that was processed, keyed by the keys of the dictionary that were processed, with a corresponding value being the result of the processing for each key.

Remarks

This method is semantically equivalent to:

IDictionary results = new Hashtable();
foreach (IInvocableCacheEntry entry in entries)
{
    results[entry.Key] = Process(entry);
}
return results;

Implements

IEntryProcessor
In this article
Back to top Copyright © 2000, 2024, Oracle and/or its affiliates.