Package com.tangosol.net.cache

Class ReadWriteBackingMap.BinaryEntryStoreWrapper

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

com.tangosol.net.cache.ReadWriteBackingMap.BinaryEntryStoreWrapper

Enclosing class:

ReadWriteBackingMap

public class ReadWriteBackingMap.BinaryEntryStoreWrapper
extends ReadWriteBackingMap.StoreWrapper

A wrapper around the original BinaryEntryStore to allow operations to be overridden and extended.

Author:

tb 2011.01.11

Nested Class Summary

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

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

f_cLoadFailures, f_cLoadMillis, f_cLoadOps, f_cPendingAsyncStoreOps, f_cStoreEntries, f_cStoreFailures, f_cStoreMillis, f_cStoreOps, m_cEraseFailures, m_cEraseMillis, m_cEraseOps, m_eraseBundler, m_fEraseAllSupported, m_fEraseSupported, m_fStoreAllSupported, m_fStoreSupported, m_loadBundler, m_storeBundler

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
BinaryEntryStoreWrapper(BinaryEntryStore store)	Construct a BinaryEntryStoreWrapper.

Method Summary

Modifier and Type	Method	Description
protected void	eraseAllInternal(Set setBinEntries)	Remove the specified entries from the underlying store.
protected void	eraseInternal(ReadWriteBackingMap.Entry binEntry)	Remove the specified entry from the underlying store.
BinaryEntryStore	getBinaryEntryStore()	The wrapped BinaryEntryStore.
Object	getStore()	Return the cache store object to which this wrapper delegates.
AbstractBundler	instantiateEraseBundler()	Create the bundler for the erase operations.
AbstractBundler	instantiateLoadBundler()	Create the bundler for the load operations.
AbstractBundler	instantiateStoreBundler()	Create the bundler for the store operations.
protected Set	loadAllInternal(Set setBinKey)	Load the entries associated with each of the specified binary keys from the underlying store.
protected ReadWriteBackingMap.Entry	loadInternal(Object binKey)	Load the entry associated with the specified key from the underlying store.
protected void	storeAllInternal(Set setBinEntries)	Store the entries in the specified set in the underlying store.
protected void	storeInternal(ReadWriteBackingMap.Entry binEntry)	Store the specified entry in the underlying store.
String	toString()	Return a String representation of the BinaryEntryStoreWrapper object that will be used as a part of the write-behind thread name.

Methods inherited from class com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

calculateRequeueDelay, ensureEraseBundler, ensureLoadBundler, ensureStoreBundler, erase, eraseAll, formatKeys, getAverageBatchSize, getAverageEraseMillis, getAverageLoadMillis, getAverageStoreMillis, getEraseBundler, getEraseFailures, getEraseMillis, getEraseOps, getLoadBundler, getLoadFailures, getLoadMillis, getLoadOps, getPendingAsyncStoreOps, getStoreBundler, getStoreFailures, getStoreMillis, getStoreOps, isBlocking, isEraseAllSupported, isEraseSupported, isStoreAllSupported, isStoreSupported, load, loadAll, onEraseAllFailure, onEraseFailure, onLoadAllFailure, onLoadAllFailure, onLoadFailure, onLoadFailure, onStoreAllFailure, onStoreAllFailure, onStoreFailure, onStoreFailure, replace, reportUnsupported, requeue, resetStatistics, setEraseAllSupported, setEraseSupported, setStoreAllSupported, setStoreSupported, store, storeAll

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

BinaryEntryStoreWrapper

public BinaryEntryStoreWrapper(BinaryEntryStore store)

Construct a BinaryEntryStoreWrapper.

Parameters:

store - the BinaryEntryStore to wrap

Method Detail

instantiateLoadBundler

public AbstractBundler instantiateLoadBundler()

Create the bundler for the load operations.

Specified by:

instantiateLoadBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "load" bundler

instantiateStoreBundler

public AbstractBundler instantiateStoreBundler()

Create the bundler for the store operations.

Specified by:

instantiateStoreBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "store" bundler

instantiateEraseBundler

public AbstractBundler instantiateEraseBundler()

Create the bundler for the erase operations.

Specified by:

instantiateEraseBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "erase" bundler

loadInternal

protected ReadWriteBackingMap.Entry loadInternal(Object binKey)

Load the entry associated with the specified key from the underlying store.

Specified by:

loadInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binKey - binary key whose associated value is to be loaded

Returns:

the entry associated with the specified key, or null if no value is available for that key

loadAllInternal

protected Set loadAllInternal(Set setBinKey)

Load the entries associated with each of the specified binary keys from the underlying store.

Specified by:

loadAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinKey - a set of binary keys to load

Returns:

a Set of entries for the specified keys

storeInternal

protected void storeInternal(ReadWriteBackingMap.Entry binEntry)

Store the specified entry in the underlying store.

Specified by:

storeInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binEntry - the entry to be stored

storeAllInternal

protected void storeAllInternal(Set setBinEntries)

Store the entries in the specified set in the underlying store.

Specified by:

storeAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinEntries - the set of entries to be stored

eraseInternal

protected void eraseInternal(ReadWriteBackingMap.Entry binEntry)

Remove the specified entry from the underlying store.

Specified by:

eraseInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binEntry - the entry to be removed from the store

eraseAllInternal

protected void eraseAllInternal(Set setBinEntries)

Remove the specified entries from the underlying store.

Specified by:

eraseAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinEntries - the set entries to be removed from the store

getStore

public Object getStore()

Return the cache store object to which this wrapper delegates.

Specified by:

getStore in class ReadWriteBackingMap.StoreWrapper

Returns:

the cache store object to which this wrapper delegates

getBinaryEntryStore

public BinaryEntryStore getBinaryEntryStore()

The wrapped BinaryEntryStore.

Returns:

the underlying BinaryEntryStore this CacheStoreWrapper wraps

toString

public String toString()

Return a String representation of the BinaryEntryStoreWrapper object that will be used as a part of the write-behind thread name.

Overrides:

toString in class Object

Returns:

a String representation of the CacheStoreWrapper object