Package com.tangosol.net.cache

Class AbstractBinaryEntryBundler

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.AbstractBundler

com.tangosol.net.cache.AbstractBinaryEntryBundler

public abstract class AbstractBinaryEntryBundler
extends AbstractBundler

An abstract BinaryEntry-based bundler that serves as a base for BinaryEntryStore operation bundling.

Since:

Coherence 3.7

Author:

tb 2011.01.06

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AbstractBinaryEntryBundler.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
AbstractBinaryEntryBundler()

Method Summary

Modifier and Type	Method	Description
protected abstract void	bundle(Set setEntries)	The bundle operation to be performed against a collected set of binary entries by the concrete AbstractEntryBundler implementations.
protected AbstractBundler.Bundle	instantiateBundle()	Instantiate a new Bundle object.
protected void	process(BinaryEntry binEntry)	Process the specified binary entry in a most optimal way according to the bundle settings.
protected void	processAll(Set set)	Process a collection of binary entries in a most optimal way according to the bundle settings.
protected abstract void	unbundle(BinaryEntry binEntry)	Un-bundle bundled operation.

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 Details

AbstractBinaryEntryBundler

public AbstractBinaryEntryBundler()

Method Details

process

protected void process(BinaryEntry binEntry)

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

Parameters:

binEntry - the binary entry

processAll

protected void processAll(Set set)

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

Parameters:

set - the set of binary entries to process

bundle

protected abstract void bundle(Set setEntries)

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

Parameters:

setEntries - a set of binary entries to perform the bundled operation for

unbundle

protected abstract void unbundle(BinaryEntry binEntry)

Un-bundle bundled operation. This opeartion would be used if an exception occurs during bundle operation or if the number of active threads is below the ThreadThreshold value.

Parameters:

binEntry - a binary entry to perform the un-bundled operation for

instantiateBundle

protected AbstractBundler.Bundle instantiateBundle()

Instantiate a new Bundle object.

Specified by:

instantiateBundle in class AbstractBundler

Returns:

a new Bundle object