Package com.tangosol.net.cache

Class AbstractEntryBundler

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.AbstractBundler

com.tangosol.net.cache.AbstractEntryBundler

Direct Known Subclasses:

BundlingNamedCache.PutBundler

public abstract class AbstractEntryBundler
extends AbstractBundler

An abstract entry-based bundler serves as a base for NamedCache.put() and CacheStore.store() operation bundling.

Since:

Coherence 3.3

Author:

gg 2007.01.28

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AbstractEntryBundler.Bundle

Nested classes/interfaces inherited from class com.tangosol.net.cache.AbstractBundler

AbstractBundler.Statistics

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

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.net.cache.AbstractBundler

ADJUSTMENT_FREQUENCY, m_countThreads, m_dPreviousSizeThreshold, m_listBundle

Fields inherited from class com.tangosol.util.Base

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
AbstractEntryBundler()

Method Summary

Modifier and Type	Method	Description
protected abstract void	bundle(Map mapEntries)	The bundle operation to be performed against a collected map of entries by the concrete AbstractEntryBundler implementations.
protected AbstractBundler.Bundle	instantiateBundle()	Instantiate a new Bundle object.
protected void	process(Object oKey, Object oValue)	Process the specified entry in a most optimal way according to the bundle settings.
protected void	processAll(Map map)	Process a colllection of entries in a most optimal way according to the bundle settings.

Methods inherited from class com.tangosol.net.cache.AbstractBundler

adjust, getDelayMillis, getOpenBundle, getSizeThreshold, getThreadThreshold, isAllowAutoAdjust, resetStatistics, setAllowAutoAdjust, setDelayMillis, setSizeThreshold, setThreadThreshold, toString, updateStatistics

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, 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, wait, wait, wait

Constructor Detail

AbstractEntryBundler

public AbstractEntryBundler()

Method Detail

process

protected void process(Object oKey,
                       Object oValue)

Process the specified entry in a most optimal way according to the bundle settings.

Parameters:

oKey - the entry key

oValue - the entry value

processAll

protected void processAll(Map map)

Process a colllection of entries in a most optimal way according to the bundle settings.

Parameters:

map - the collection of entries to process

bundle

protected abstract void bundle(Map mapEntries)

The bundle operation to be performed against a collected map of entries by the concrete AbstractEntryBundler implementations. If an exception occurs during bundle operation, it will be repeated using singleton maps.

Parameters:

mapEntries - a map to perform the bundled operation for

instantiateBundle

protected AbstractBundler.Bundle instantiateBundle()

Instantiate a new Bundle object.

Specified by:

instantiateBundle in class AbstractBundler

Returns:

a new Bundle object