|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.util.Base
com.tangosol.util.processor.AbstractProcessor
com.tangosol.util.processor.UpdaterProcessor
public class UpdaterProcessor
UpdaterProcessor is an EntryProcessor implementations that updates an attribute of an object cached in an InvocableMap. A common usage pattern is:
cache.invoke(oKey, new UpdaterProcessor(updater, oValue));
which is functionally equivalent to the following operation:
Object oTarget = cache.get(oKey); updater.update(oTarget, oValue); cache.put(oKey, oTarget);
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.
Field Summary | |
---|---|
protected java.lang.Object |
m_oValue A value to update the entry's value with. |
protected ValueUpdater |
m_updater The underlying ValueUpdater. |
Constructor Summary | |
---|---|
UpdaterProcessor() Default constructor (necessary for the ExternalizableLite interface). |
|
UpdaterProcessor(java.lang.String sMethod, java.lang.Object oValue) Construct an UpdaterProcessor for a given method name. |
|
UpdaterProcessor(ValueUpdater updater, java.lang.Object oValue) Construct an UpdaterProcessor based on the specified ValueUpdater. |
Method Summary | |
---|---|
boolean |
equals(java.lang.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. |
java.lang.Object |
process(InvocableMap.Entry entry) Process a Map.Entry object. |
void |
readExternal(java.io.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. |
java.lang.String |
toString() Return a human-readable description for this UpdaterProcessor. |
void |
writeExternal(java.io.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. |
Methods inherited from class com.tangosol.util.processor.AbstractProcessor |
---|
processAll |
Field Detail |
---|
protected ValueUpdater m_updater
protected java.lang.Object m_oValue
Constructor Detail |
---|
public UpdaterProcessor()
public UpdaterProcessor(ValueUpdater updater, java.lang.Object oValue)
updater
- a ValueUpdater object; passing null will simpy replace the entry's value with the specified one instead of updating itoValue
- the value to update the target entry withpublic UpdaterProcessor(java.lang.String sMethod, java.lang.Object oValue)
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 CompositeUpdater
oValue
- the value to update the target entry withMethod Detail |
---|
public java.lang.Object process(InvocableMap.Entry entry)
process
in interface InvocableMap.EntryProcessor
entry
- the Entry to process 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.public boolean equals(java.lang.Object o)
public int hashCode()
Object.hashCode()
contract.public java.lang.String toString()
public void readExternal(java.io.DataInput in) throws java.io.IOException
readExternal
in interface ExternalizableLite
in
- the DataInput stream to read data from in order to restore the state of this objectjava.io.IOException
- if an I/O exception occursjava.io.NotActiveException
- if the object is not in its initial state, and therefore cannot be deserialized intopublic void writeExternal(java.io.DataOutput out) throws java.io.IOException
writeExternal
in interface ExternalizableLite
out
- the DataOutput stream to write the state of this object tojava.io.IOException
- if an I/O exception occurspublic void readExternal(PofReader in) throws java.io.IOException
readExternal
in interface PortableObject
in
- the PofReader from which to read the object's statejava.io.IOException
- if an I/O error occurspublic void writeExternal(PofWriter out) throws java.io.IOException
writeExternal
in interface PortableObject
out
- the PofWriter to which to write the object's statejava.io.IOException
- if an I/O error occurs
|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |