Package com.oracle.coherence.concurrent.executor

Class ClusteredTaskManager.UpdateCollectedResultProcessor<T>

java.lang.Object

com.tangosol.util.Base

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

com.oracle.coherence.concurrent.executor.PortableAbstractProcessor<String,ClusteredTaskManager,Void>

com.oracle.coherence.concurrent.executor.ClusteredTaskManager.UpdateCollectedResultProcessor<T>

Type Parameters:

T - the result type

All Implemented Interfaces:

PortableObject, InvocableMap.EntryProcessor<String,ClusteredTaskManager,Void>, Serializable

Enclosing class:

ClusteredTaskManager<T,A,R>

public static class ClusteredTaskManager.UpdateCollectedResultProcessor<T>
extends PortableAbstractProcessor<String,ClusteredTaskManager,Void>

An PortableAbstractProcessor to update the collected result for a Task.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	m_fCompleted	Flag indicating completion status.
protected long	m_lProcessedResultMapGeneration	The processed generation count of the result map.
protected Result<T>	m_newResult	The new Result.

Fields inherited from class com.tangosol.util.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
UpdateCollectedResultProcessor()	Constructs an ClusteredTaskManager.UpdateCollectedResultProcessor (required for serialization).
UpdateCollectedResultProcessor(Result<T> newResult, long lProcessedResultMapGeneration, boolean fCompleted)	Constructs an ClusteredTaskManager.UpdateCollectedResultProcessor.

Method Summary

Modifier and Type	Method	Description
Void	process(InvocableMap.Entry<String,ClusteredTaskManager> entry)	Process a Map.Entry object.
void	readExternal(PofReader in)	Restore the contents of a user type instance by reading its state using the specified PofReader 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

Methods inherited from class com.tangosol.util.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 java.lang.Object

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

Field Detail

m_newResult

protected Result<T> m_newResult

The new Result.

m_lProcessedResultMapGeneration

protected long m_lProcessedResultMapGeneration

The processed generation count of the result map.

m_fCompleted

protected boolean m_fCompleted

Flag indicating completion status.

Constructor Detail

UpdateCollectedResultProcessor

public UpdateCollectedResultProcessor()

Constructs an ClusteredTaskManager.UpdateCollectedResultProcessor (required for serialization).

UpdateCollectedResultProcessor

public UpdateCollectedResultProcessor(Result<T> newResult,
                                      long lProcessedResultMapGeneration,
                                      boolean fCompleted)

Constructs an ClusteredTaskManager.UpdateCollectedResultProcessor.

Parameters:

newResult - the new result

lProcessedResultMapGeneration - the processed generation count of the result map

fCompleted - a boolean to indicate if the task is completed

Method Detail

process

public Void process(InvocableMap.Entry<String,ClusteredTaskManager> entry)

Description copied from interface: InvocableMap.EntryProcessor

Process a Map.Entry object.

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.

Parameters:

entry - the Entry to process

Returns:

the result of the processing, if any

readExternal

public void readExternal(PofReader in)
                  throws IOException

Description copied from interface: PortableObject

Restore the contents of a user type instance by reading its state using the specified PofReader object.

Specified by:

readExternal in interface PortableObject

Overrides:

readExternal in class PortableAbstractProcessor<String,ClusteredTaskManager,Void>

Parameters:

in - the PofReader from which to read the object's state

Throws:

IOException - if an I/O error occurs

writeExternal

public void writeExternal(PofWriter out)
                   throws IOException

Description copied from interface: PortableObject

Save the contents of a POF user type instance by writing its state using the specified PofWriter object.

Specified by:

writeExternal in interface PortableObject

Overrides:

writeExternal in class PortableAbstractProcessor<String,ClusteredTaskManager,Void>

Parameters:

out - the PofWriter to which to write the object's state

Throws:

IOException - if an I/O error occurs