public class BundlingNamedCache extends WrapperNamedCache
AbstractBundler| Modifier and Type | Class and Description |
|---|---|
protected class |
BundlingNamedCache.GetBundler |
protected class |
BundlingNamedCache.PutBundler |
protected class |
BundlingNamedCache.RemoveBundler |
WrapperConcurrentMap.LockWrapperObservableMap.InternalListenerAbstractKeySetBasedMap.EntrySet, AbstractKeySetBasedMap.KeyIterator, AbstractKeySetBasedMap.KeySet, AbstractKeySetBasedMap.ValuesCollectionAbstractKeyBasedMap.DeferredCacheEvent<K,V>Base.LoggingWriter, Base.StackFrameNamedCache.OptionQueryMap.Entry<K,V>InvocableMap.Entry<K,V>, InvocableMap.EntryAggregator<K,V,R>, InvocableMap.EntryProcessor<K,V,R>, InvocableMap.ParallelAwareAggregator<K,V,P,R>, InvocableMap.StreamingAggregator<K,V,P,R>m_service, m_sNamem_cWaitMillis, m_fEnforceLocking, m_gateMap, m_mapLockm_fDeferredEvent, m_fTranslateEvents, m_listenerInternal, m_listenerSupport, m_map, m_statsLOG_ALWAYS, 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_USEXPIRY_DEFAULT, EXPIRY_NEVERLOCK_ALL| Constructor and Description |
|---|
BundlingNamedCache(NamedCache cache)
Construct a BundlingNamedCache based on the specified NamedCache.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractBundler |
ensureGetBundler(int cBundleThreshold)
Configure the bundler for the "get" operations.
|
AbstractBundler |
ensurePutBundler(int cBundleThreshold)
Configure the bundler for the "put" operations.
|
AbstractBundler |
ensureRemoveBundler(int cBundleThreshold)
Configure the bundler for the "remove" operations.
|
Object |
get(Object oKey)
Returns the value to which this map maps the specified key.
|
Map |
getAll(Collection colKeys)
Get all the specified keys, if they are in the Map.
|
AbstractBundler |
getGetBundler()
Obtain the bundler for the "get" operations.
|
AbstractBundler |
getPutBundler()
Obtain the bundler for the "put" operations.
|
AbstractBundler |
getRemoveBundler()
Obtain the bundler for the "remove" operations.
|
Object |
put(Object oKey,
Object oValue)
Associates the specified value with the specified key in this map.
|
void |
putAll(Map map)
Copies all of the mappings from the specified map to this map.
|
Object |
remove(Object oKey)
Removes the mapping for this key from this map if present.
|
addIndex, aggregate, aggregate, destroy, entrySet, entrySet, getCacheName, getCacheService, invoke, invokeAll, invokeAll, isActive, isDestroyed, isReleased, keySet, put, release, removeIndex, truncateclear, getDescription, getLockDescription, getWaitMillis, instantiateLock, isInternalKeySetIteratorMutable, isLockingEnforced, lock, lock, removeBlind, setLockingEnforced, setWaitMillis, toString, unlockaddMapListener, addMapListener, addMapListener, containsValue, dispatchEvent, dispatchPendingEvent, ensureInternalListener, ensureMapListenerSupport, equals, getCacheStatistics, getInternalKeySet, getMap, getMapListenerSupport, hashCode, hasListeners, instantiateInternalListener, isCollectStats, isEventFabricator, isSynthetic, isTranslateEvents, removeMapListener, removeMapListener, removeMapListener, setCollectStats, setTranslateEventscontainsKey, instantiateEntrySet, instantiateKeyIterator, instantiateKeySet, instantiateValues, isEmpty, iterateKeys, sizeclone, entrySet, keySet, valuesazzert, 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, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, 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, waitfinalize, getClass, notify, notifyAll, wait, wait, waitas, async, async, clear, getName, getService, viewcloseaddMapListener, addMapListener, addMapListener, removeMapListener, removeMapListener, removeMapListenercompute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, getOrDefault, hashCode, isEmpty, keySet, merge, putIfAbsent, remove, replace, replace, replaceAll, size, valuescontainsKey, containsValue, isEmpty, lock, lock, size, unlockaggregate, compute, compute, computeIfAbsent, computeIfAbsent, computeIfPresent, computeIfPresent, getOrDefault, invokeAll, merge, merge, putIfAbsent, remove, replace, replace, replaceAll, replaceAll, replaceAll, replaceAll, stream, stream, stream, stream, stream, streampublic BundlingNamedCache(NamedCache cache)
cache - the NamedCache that will be wrapped by this BundlingNamedCachepublic AbstractBundler ensureGetBundler(int cBundleThreshold)
cBundleThreshold - the bundle size threshold; pass zero to disable
"get" operation bundlingpublic AbstractBundler ensurePutBundler(int cBundleThreshold)
cBundleThreshold - the bundle size threshold; pass zero to disable
"put" operation bundlingpublic AbstractBundler ensureRemoveBundler(int cBundleThreshold)
cBundleThreshold - the bundle size threshold; pass zero to disable
"remove" operation bundlingpublic AbstractBundler getGetBundler()
public AbstractBundler getPutBundler()
public AbstractBundler getRemoveBundler()
public Object get(Object oKey)
get in interface ConcurrentMapget in interface Mapget in class WrapperObservableMapoKey - the key objectConcurrentMap.containsKey(Object)public Map getAll(Collection colKeys)
getAll in interface CacheMapgetAll in class WrapperNamedCachecolKeys - a collection of keys that may be in the named cachepublic Object put(Object oKey, Object oValue)
Note: this method always returns null.
put in interface CacheMapput in interface ConcurrentMapput in interface Mapput in class WrapperConcurrentMapoKey - key with which the specified value is to be associatedoValue - value to be associated with the specified keypublic void putAll(Map map)
AbstractKeyBasedMap.put(K, V)
on this map once for each mapping in the passed map. The behavior of
this operation is unspecified if the passed map is modified while the
operation is in progress.putAll in interface ConcurrentMapputAll in interface MapputAll in class WrapperConcurrentMapmap - the Map containing the key/value pairings to put into this
Mappublic Object remove(Object oKey)
Note: this method always returns null.
remove in interface ConcurrentMapremove in interface Mapremove in class WrapperConcurrentMapoKey - key whose mapping is to be removed from the map