public class UpdaterProcessor<K,V,T> extends AbstractProcessor<K,V,Boolean> implements ExternalizableLite, PortableObject
cache.invoke(oKey, new UpdaterProcessor(updater, value));which is functionally equivalent to the following operation:
V target = cache.get(key); updater.update(target, value); cache.put(key, target);The major difference is that for clustered caches using the UpdaterProcessor allows avoiding explicit concurrency control and could significantly reduce the amount of network traffic.
Base.LoggingWriter, Base.StackFrame| Modifier and Type | Field and Description |
|---|---|
protected ValueUpdater<V,T> |
m_updater
The underlying ValueUpdater.
|
protected T |
m_value
A value to update the entry's value with.
|
| Constructor and Description |
|---|
UpdaterProcessor()
Default constructor (necessary for the ExternalizableLite interface).
|
UpdaterProcessor(String sMethod,
T value)
Construct an UpdaterProcessor for a given method name.
|
UpdaterProcessor(ValueUpdater<V,T> updater,
T value)
Construct an UpdaterProcessor based on the specified ValueUpdater.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object o)
Compare the UpdaterProcessor with another object to determine equality.
|
int |
hashCode()
Determine a hash value for the UpdaterProcessor object according to the
general
Object.hashCode() contract. |
Boolean |
process(InvocableMap.Entry<K,V> entry)
Process a Map.Entry object.
|
void |
readExternal(DataInput in)
Restore the contents of this object by loading the object's state from
the passed DataInput object.
|
void |
readExternal(PofReader in)
Restore the contents of a user type instance by reading its state using
the specified PofReader object.
|
String |
toString()
Return a human-readable description for this UpdaterProcessor.
|
void |
writeExternal(DataOutput out)
Save the contents of this object by storing the object's state into
the passed DataOutput object.
|
void |
writeExternal(PofWriter out)
Save the contents of a POF user type instance by writing its state using
the specified PofWriter object.
|
processAllazzert, 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, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, 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, waitprotected ValueUpdater<V,T> m_updater
protected T m_value
public UpdaterProcessor()
public UpdaterProcessor(ValueUpdater<V,T> updater, T value)
updater - a ValueUpdater object; passing null will simpy replace
the entry's value with the specified one instead of
updating itvalue - the value to update the target entry withpublic UpdaterProcessor(String sMethod, T value)
sMethod - a method name to make a
ReflectionUpdater
for; this parameter can also be a dot-delimited sequence
of method names which would result in using a
CompositeUpdatervalue - the value to update the target entry withpublic Boolean process(InvocableMap.Entry<K,V> entry)
Note: if this method throws an exception, all modifications to the supplied
entry or any other entries retrieved via the BackingMapContext.getBackingMapEntry(java.lang.Object)
API will be rolled back leaving all underlying values unchanged.
process in interface InvocableMap.EntryProcessor<K,V,Boolean>entry - the Entry to processpublic boolean equals(Object o)
public int hashCode()
Object.hashCode() contract.public String toString()
public void readExternal(DataInput in) throws IOException
readExternal in interface ExternalizableLitein - the DataInput stream to read data from in order to restore
the state of this objectIOException - if an I/O exception occursNotActiveException - if the object is not in its initial
state, and therefore cannot be deserialized intopublic void writeExternal(DataOutput out) throws IOException
writeExternal in interface ExternalizableLiteout - the DataOutput stream to write the state of this object toIOException - if an I/O exception occurspublic void readExternal(PofReader in) throws IOException
readExternal in interface PortableObjectin - the PofReader from which to read the object's stateIOException - if an I/O error occurspublic void writeExternal(PofWriter out) throws IOException
writeExternal in interface PortableObjectout - the PofWriter to which to write the object's stateIOException - if an I/O error occurs