Class AbstractProcessor<K,V,R>

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.processor.AbstractProcessor<K,V,R>

Type Parameters:

K - the type of the Map entry key

V - the type of the Map entry value

R - the type of the EntryProcessor return value

All Implemented Interfaces:

InvocableMap.EntryProcessor<K,V,R>, Serializable

Direct Known Subclasses:

CompositeProcessor, ConditionalProcessor, ConditionalPut, ConditionalPutAll, ConditionalRemove, ExtractorProcessor, NullImplementation.NullEntryProcessor, PortableAbstractProcessor, PreloadRequest, PropertyProcessor, UpdaterProcessor, VersionedPut, VersionedPutAll

public abstract class AbstractProcessor<K,V,R>
extends Base
implements InvocableMap.EntryProcessor<K,V,R>

An AbstractProcessor is a partial EntryProcessor implementation that provides the default implementation of the processAll(Set) method.

Since:

Coherence 3.1

Author:

cp/jh 2005.07.19

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class Base

Base.LoggingWriter

Field Summary

Fields inherited from class Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Constructor	Description
AbstractProcessor()

Method Summary

Modifier and Type	Method	Description
Map<K,R>	processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)	Process a Set of InvocableMap.Entry objects.

Methods inherited from class Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface InvocableMap.EntryProcessor

process

Constructor Details

AbstractProcessor

public AbstractProcessor()

Method Details

processAll

public Map<K,R> processAll(Set<? extends InvocableMap.Entry<K,V>> setEntries)

Process a Set of InvocableMap.Entry objects. This method is semantically equivalent to:

  Map mapResults = new ListMap();
  for (Iterator iter = setEntries.iterator(); iter.hasNext(); )
      {
      Entry entry = (Entry) iter.next();
      mapResults.put(entry.getKey(), process(entry));
      }
  return mapResults;

Note: if processAll() call throws an exception, only the entries that were removed from the setEntries would be considered successfully processed and the corresponding changes made to the underlying Map; changes made to the remaining entries or any other entries obtained from BackingMapContext.getBackingMapEntry(Object) will not be processed. Note: As of Coherence 12.2.1, this method simply delegates to the default processAll implementation in InvocableMap.EntryProcessor.

Specified by:

processAll in interface InvocableMap.EntryProcessor<K,V,R>

Parameters:

setEntries - a Set of InvocableMap.Entry objects to process

Returns:

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