Class LongMax<T>

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.BitHelper

com.tangosol.util.ExternalizableHelper

com.tangosol.util.aggregator.AbstractAggregator<Object,Object,T,Number,Long>

com.tangosol.util.aggregator.AbstractLongAggregator<T>

com.tangosol.util.aggregator.LongMax<T>

Type Parameters:

T - the type of the value to extract from

All Implemented Interfaces:

com.tangosol.internal.net.ContinuousAggregationBound, ExternalizableLite, PortableObject, InvocableMap.EntryAggregator<Object,Object,Long>, InvocableMap.StreamingAggregator<Object,Object,Object,Long>, Serializable, Cloneable

public class LongMax<T>
extends AbstractLongAggregator<T>
implements com.tangosol.internal.net.ContinuousAggregationBound

Calculates a maximum of numeric values extracted from a set of entries in a Map. All the extracted Number objects will be treated as Java long values.

Since:

Coherence 3.1

Author:

gg 2005.09.05

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class ExternalizableHelper

ExternalizableHelper.DecoratedMultiBufferReadBuffer, ExternalizableHelper.DecorationAware, ExternalizableHelper.DefaultObjectStreamFactory, ExternalizableHelper.FormatAwareCompressor, ExternalizableHelper.IntDecoratedObject, ExternalizableHelper.Shielded, ExternalizableHelper.ShieldedDataOutputStream, ExternalizableHelper.ShieldedInputStream, ExternalizableHelper.ShieldedObjectOutputStream, ExternalizableHelper.ShieldedOutputStream, ExternalizableHelper.SimpleXmlBeanClassCache, ExternalizableHelper.Stats, ExternalizableHelper.XmlBeanClassCache

Nested classes/interfaces inherited from class Base

Base.LoggingWriter

Nested classes/interfaces inherited from interface InvocableMap.StreamingAggregator

InvocableMap.StreamingAggregator.RetractionResult

Field Summary

Fields

Modifier and Type	Field	Description
protected int	m_cSupport	The number of current entries equal to the retained maximum.

Fields inherited from class AbstractLongAggregator

m_count, m_lResult

Fields inherited from class AbstractAggregator

m_fParallel

Fields inherited from class ExternalizableHelper

BINARY_SIZE, CHUNK_SIZE, CHUNK_THRESHOLD, CONVERTER_FROM_BINARY, CONVERTER_STRIP_INTDECO, CONVERTER_TO_BINARY, DECO_APP_1, DECO_APP_2, DECO_APP_3, DECO_BACKUP, DECO_CUSTOM, DECO_EXPIRY, DECO_ID_MAX, DECO_ID_MIN, DECO_JCACHE, DECO_JCACHE_SYNTHETIC, DECO_MEMCACHED, DECO_PUSHREP, DECO_RSVD_1, DECO_STORE, DECO_TOPLINK, DECO_TX, DECO_VALUE, DECO_VECTOR, DECO_WLS, EMPTY_BINARY_ARRAY, FMT_B_ARRAY, FMT_BIN_DECO, FMT_BIN_EXT_DECO, FMT_BINARY, FMT_BOOLEAN, FMT_BYTE, FMT_DECIMAL, FMT_DOUBLE, FMT_EXT, FMT_FLOAT, FMT_IDO, FMT_INT, FMT_INTEGER, FMT_LONG, FMT_NONE, FMT_NULL, FMT_OBJ_EXT, FMT_OBJ_SER, FMT_OPT, FMT_OPT_DOUBLE, FMT_OPT_INT, FMT_OPT_LONG, FMT_SHORT, FMT_STRING, FMT_UNKNOWN, FMT_XML_BEAN, FMT_XML_SER, FORCE_RESOLVING_STREAMS, LAMBDA_SERIALIZATION, MAX_DECO_HEADER_BYTES, MAX_MEMCACHED_PASS_THROUGH_FORMAT_DEPTH, PACKED_INT_SIZE, PACKED_LONG_SIZE, PROPERTY_CONFIG, s_streamfactory, s_tloInEHDeserialize, TRINT_DOMAIN_SPAN, TRINT_MAX_VALUE, TRINT_MAX_VARIANCE, USE_POF_STREAMS, USE_XMLBEAN_CLASS_CACHE, XMLBEAN_CLASS_CACHE

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

Fields inherited from interface InvocableMap.StreamingAggregator

ALLOW_INCONSISTENCIES, BY_MEMBER, BY_PARTITION, CONTINUOUS, PARALLEL, PRESENT_ONLY, RETAINS_ENTRIES, SERIAL, STATE_CHECKPOINTABLE

Constructor Summary

Constructors

Constructor	Description
LongMax()	Default constructor (necessary for the ExternalizableLite interface).
LongMax(ValueExtractor<? super T, ? extends Number> extractor)	Construct a LongMax aggregator.
LongMax(String sMethod)	Construct a LongMax aggregator.

Method Summary

Modifier and Type	Method	Description
int	characteristics()	A bit mask representing the set of characteristics of this aggregator.
int	compareContinuousAggregationBounds(Object left, Object right)	Compare two bounds in the order they should be considered.
Object	getContinuousAggregationBound()	Return the retained bound in the aggregator's partial-result format.
InvocableMap.StreamingAggregator.RetractionResult	getMaintenanceStatus()	Return the current maintenance status of this aggregator.
protected void	init(boolean fFinal)	Initialize the aggregation result.
boolean	isContinuousAggregationBoundDominated(Object bound, Object exactPartial)	Return whether an exact partial result dominates the specified bound.
protected void	process(Object o, boolean fFinal)	Incorporate one aggregatable value into the result.
protected InvocableMap.StreamingAggregator.RetractionResult	remove(Object o)	Remove one extracted value from the aggregation result.
void	restoreState(Object state)	Restore a maintenance-state snapshot into this empty supplied instance.
Object	snapshotState()	Return a detached, serializer-compatible snapshot of the state required to continue incremental maintenance.
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	supply()	Create a new instance of this aggregator.

Methods inherited from class AbstractLongAggregator

finalizeResult

Methods inherited from class AbstractAggregator

accumulate, accumulate, combine, ensureInitialized, equals, finalizeResult, getPartialResult, getValueExtractor, hashCode, isReplacementRequired, processEntry, readExternal, readExternal, replace, retract, toString, update, writeExternal, writeExternal

Methods inherited from class ExternalizableHelper

asBinary, calculatePackedLength, calculatePackedLength, checkObjectInputFilter, checkObjectInputFilter, checkObjectInputFilter, convertUTF, decodeExpiry, decorate, decorate, decorate, decorate, decorate, decorateBinary, encodeExpiry, ensureSerializer, extractIntDecoration, fromBinary, fromBinary, fromBinary, fromBinary, fromBinary, fromBinary, fromByteArray, fromByteArray, getClass, getConfigSerialFilter, getConfigSerialFilterFactory, getDecoration, getDecoration, getDecorations, getDeltaCompressor, getInputStream, getNewObjectInput, getObjectInput, getObjectInputFilter, getObjectOutput, getObjectStreamFactory, getOutputStream, getShieldedOutputStream, getStreamFormat, getUndecorated, getUndecorated, isDecorated, isDecorated, isIntDecorated, isIntDecorated, isPatchCompatible, isPatchCompatible, isResolving, isSerializable, isSerializerCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, isVersionCompatible, loadClass, loadResource, main, makeTrint, newFilteredObjectInputStream, newFilteredObjectInputStream, readBigDecimal, readBigInteger, readBooleanArray, readBooleanArray, readByteArray, readCharArray, readCharArray, readCollection, readDate, readDoubleArray, readDoubleArray, readExternalizableLite, readExternalizableLite, readFloatArray, readFloatArray, readInt, readInt, readIntArray, readIntArray, readIntArray2d, readLargeBooleanArray, readLargeByteArray, readLargeCharArray, readLargeDoubleArray, readLargeFloatArray, readLargeIntArray, readLargeLongArray, readLargeObjectArray, readLargeStringArray, readLong, readLong, readLongArray, readLongArray, readMap, readMap, readObject, readObject, readObjectArray, readObjectArray, readSafeUTF, readSafeUTF, readSerializable, readSerializable, readStringArray, readStringArray, readTime, readTimestamp, readTrint, readUnsignedTrint, readUTF, readXmlBean, readXmlSerializable, readXmlSerializable, realize, removeIntDecoration, removeIntDecoration, replace, reportIncompatibleSerializers, reportIncompatibleSerializers, reportIncompatibleSerializers, reportIncompatibleSerializers, setObjectStreamFactory, toBinary, toBinary, toBinary, toByteArray, toByteArray, toByteArray, toLiteBinary, toLong, undecorate, undecorate, validateBufferSize, validateLoadArray, validateLoadClass, validateMemcachedPassThroughValue, validateMemcachedPassThroughValue, validateMemcachedPassThroughValue, validateMemcachedPassThroughValue, writeBigDecimal, writeBigInteger, writeBooleanArray, writeByteArray, writeCollection, writeDate, writeDoubleArray, writeExternalizableLite, writeFloatArray, writeInt, writeInt, writeIntArray, writeIntArray2d, writeLong, writeLong, writeLongArray, writeMap, writeObject, writeSafeUTF, writeSafeUTF, writeSerializable, writeStringArray, writeTime, writeTimestamp, writeTrint, writeTrint, writeUTF, writeXmlBean, writeXmlSerializable

Methods inherited from class BitHelper

countBits, countBits, countBits, indexOfLSB, indexOfLSB, indexOfLSB, indexOfMSB, indexOfMSB, indexOfMSB, rotateLeft, rotateLeft, rotateLeft, rotateRight, rotateRight, rotateRight, toBitString, toBitString, toBitString, toBytes, toBytes, toBytes, toBytes, toInt, toInt, toLong

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, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface InvocableMap.StreamingAggregator

aggregate, finalizeResult, isAllowInconsistencies, isByMember, isByPartition, isContinuous, isParallel, isPresentOnly, isRetainsEntries, isSerial, isStateCheckpointable

Field Details

m_cSupport

protected transient int m_cSupport

The number of current entries equal to the retained maximum.

Constructor Details

LongMax

public LongMax()

Default constructor (necessary for the ExternalizableLite interface).

LongMax

public LongMax(ValueExtractor<? super T, ? extends Number> extractor)

Construct a LongMax aggregator.

Parameters:

extractor - the extractor that provides a value in the form of any Java object that is a Number

LongMax

public LongMax(String sMethod)

Construct a LongMax aggregator.

Parameters:

sMethod - the name of the method that returns a value in the form of any Java object that is a Number

Method Details

supply

public InvocableMap.StreamingAggregator<Object,Object,Object,Long> supply()

Description copied from interface: InvocableMap.StreamingAggregator

Create a new instance of this aggregator.

Specified by:

supply in interface InvocableMap.StreamingAggregator<Object,Object,Object,Long>

Overrides:

supply in class AbstractAggregator<Object,Object,T,Number,Long>

Returns:

a StreamAggregator

characteristics

public int characteristics()

Description copied from interface: InvocableMap.StreamingAggregator

A bit mask representing the set of characteristics of this aggregator.

By default, characteristics are a combination of InvocableMap.StreamingAggregator.PARALLEL and InvocableMap.StreamingAggregator.RETAINS_ENTRIES, which is sub-optimal and should be overridden by the aggregator implementation if the aggregator does not need to retain entries (which is often the case).

Specified by:

characteristics in interface InvocableMap.StreamingAggregator<Object,Object,Object,Long>

Returns:

a bit mask representing the set of characteristics of this aggregator

See Also:

• InvocableMap.StreamingAggregator.ALLOW_INCONSISTENCIES
• InvocableMap.StreamingAggregator.BY_MEMBER
• InvocableMap.StreamingAggregator.BY_PARTITION
• InvocableMap.StreamingAggregator.CONTINUOUS
• InvocableMap.StreamingAggregator.STATE_CHECKPOINTABLE
• InvocableMap.StreamingAggregator.PARALLEL
• InvocableMap.StreamingAggregator.PRESENT_ONLY
• InvocableMap.StreamingAggregator.RETAINS_ENTRIES
• InvocableMap.StreamingAggregator.SERIAL

snapshotState

public Object snapshotState()

Description copied from interface: InvocableMap.StreamingAggregator

Return a detached, serializer-compatible snapshot of the state required to continue incremental maintenance.

This method is used only when InvocableMap.StreamingAggregator.STATE_CHECKPOINTABLE is advertised. The default implementation does not support state checkpointing.

Specified by:

snapshotState in interface InvocableMap.StreamingAggregator<Object,Object,Object,Long>

Overrides:

snapshotState in class AbstractLongAggregator<T>

Returns:

a detached maintenance-state snapshot

restoreState

public void restoreState(Object state)

Description copied from interface: InvocableMap.StreamingAggregator

Restore a maintenance-state snapshot into this empty supplied instance.

This method is used only when InvocableMap.StreamingAggregator.STATE_CHECKPOINTABLE is advertised. The default implementation does not support state checkpointing.

Specified by:

restoreState in interface InvocableMap.StreamingAggregator<Object,Object,Object,Long>

Overrides:

restoreState in class AbstractLongAggregator<T>

Parameters:

state - the snapshot returned by InvocableMap.StreamingAggregator.snapshotState()

getMaintenanceStatus

public InvocableMap.StreamingAggregator.RetractionResult getMaintenanceStatus()

Description copied from interface: InvocableMap.StreamingAggregator

Return the current maintenance status of this aggregator.

This method is evaluated after an update has been fully applied, so an aggregator may report InvocableMap.StreamingAggregator.RetractionResult.STALE_BOUND from InvocableMap.StreamingAggregator.retract(Entry) and return InvocableMap.StreamingAggregator.RetractionResult.UPDATED here if accumulating the replacement value restored an exact result.

Specified by:

getMaintenanceStatus in interface InvocableMap.StreamingAggregator<Object,Object,Object,Long>

Returns:

the current maintenance status

getContinuousAggregationBound

public Object getContinuousAggregationBound()

Description copied from interface: com.tangosol.internal.net.ContinuousAggregationBound

Return the retained bound in the aggregator's partial-result format.

Specified by:

getContinuousAggregationBound in interface com.tangosol.internal.net.ContinuousAggregationBound

Returns:

the retained bound

compareContinuousAggregationBounds

public int compareContinuousAggregationBounds(Object left,
 Object right)

Description copied from interface: com.tangosol.internal.net.ContinuousAggregationBound

Compare two bounds in the order they should be considered. A negative result means that left can affect the result before right.

Specified by:

compareContinuousAggregationBounds in interface com.tangosol.internal.net.ContinuousAggregationBound

Parameters:

left - the first bound

right - the second bound

Returns:

a negative, zero, or positive value

isContinuousAggregationBoundDominated

public boolean isContinuousAggregationBoundDominated(Object bound,
 Object exactPartial)

Description copied from interface: com.tangosol.internal.net.ContinuousAggregationBound

Return whether an exact partial result dominates the specified bound.

Specified by:

isContinuousAggregationBoundDominated in interface com.tangosol.internal.net.ContinuousAggregationBound

Parameters:

bound - the stale partition bound

exactPartial - the exact partial result accumulated so far

Returns:

true if the stale partition cannot change the result

init

protected void init(boolean fFinal)

Initialize the aggregation result.

Overrides:

init in class AbstractLongAggregator<T>

Parameters:

fFinal - true is passed if the aggregation process that is being initialized must produce a final aggregation result; this will only be false if a parallel approach is being used and the initial (partial) aggregation process is being initialized

process

protected void process(Object o,
 boolean fFinal)

Incorporate one aggregatable value into the result.

If the fFinal parameter is true, the given object is a partial result (returned by an individual parallel aggregator) that should be incorporated into the final result; otherwise, the object is a value extracted from an InvocableMap.Entry.

Specified by:

process in class AbstractAggregator<Object,Object,T,Number,Long>

Parameters:

o - the value to incorporate into the aggregated result

fFinal - true to indicate that the given object is a partial result returned by a parallel aggregator

remove

protected InvocableMap.StreamingAggregator.RetractionResult remove(Object o)

Description copied from class: AbstractAggregator

Remove one extracted value from the aggregation result.

Overrides:

remove in class AbstractAggregator<Object,Object,T,Number,Long>

Parameters:

o - the extracted value to remove

Returns:

the state of the aggregation result after the removal