public class DeserializationAccelerator extends AbstractExtractor implements IndexAwareExtractor, ExternalizableLite, PortableObject
IndexAwareExtractor implementation that
is used to create a ForwardOnlyMapIndex, which in turn is used for
deserialization optimization.
Below is an example how to use this feature to optimize deserialization for
BinaryEntry.getValue() calls:
NamedCache cache = ...;
cache.addIndex(new DeserializationAccelerator(
IdentityExtractor.INSTANCE), false, null);
There are two ways the DeserializationAccelerator could be used: pro-active
(default) and on-demand. In the pro-active mode, the underlying
ForwardOnlyMapIndex is populated every time the index is rebuilt or
updated. In the on-demand mode, the ForwardOnlyMapIndex stores the
values only when they are requested.ExternalizableHelper.DecoratedMultiBufferReadBuffer, ExternalizableHelper.DefaultObjectStreamFactory, ExternalizableHelper.FormatAwareCompressor, ExternalizableHelper.IntDecoratedObject, ExternalizableHelper.Shielded, ExternalizableHelper.ShieldedDataOutputStream, ExternalizableHelper.ShieldedInputStream, ExternalizableHelper.ShieldedObjectOutputStream, ExternalizableHelper.ShieldedOutputStream, ExternalizableHelper.SimpleXmlBeanClassCache, ExternalizableHelper.Stats, ExternalizableHelper.XmlBeanClassCacheBase.LoggingWriter, Base.StackFrame| Modifier and Type | Field and Description |
|---|---|
protected ValueExtractor |
m_extractor
The underlying extractor.
|
protected boolean |
m_fLazy
The "lazy" flag.
|
KEY, m_nTarget, m_sNameCanon, VALUECONVERTER_FROM_BINARY, CONVERTER_STRIP_INTDECO, CONVERTER_TO_BINARY, DECO_APP_1, DECO_APP_2, DECO_APP_3, DECO_CUSTOM, DECO_EXPIRY, DECO_ID_MAX, DECO_ID_MIN, DECO_JCACHE, DECO_JCACHE_SYNTHETIC, DECO_MEMCACHED, DECO_PUSHREP, DECO_QUEUE_METADATA, DECO_RSVD_1, DECO_RSVD_2, DECO_STORE, DECO_TX, DECO_VALUE, 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, MAX_DECO_HEADER_BYTES, PROPERTY_CONFIG, s_streamfactory, TRINT_DOMAIN_SPAN, TRINT_MAX_VALUE, TRINT_MAX_VARIANCE, USE_POF_STREAMS, USE_XMLBEAN_CLASS_CACHE, XMLBEAN_CLASS_CACHE| Constructor and Description |
|---|
DeserializationAccelerator()
Construct the DeserializationAccelerator.
|
DeserializationAccelerator(ValueExtractor extractor)
Construct the DeserializationAccelerator.
|
DeserializationAccelerator(ValueExtractor extractor,
boolean fOnDemand)
Construct the DeserializationAccelerator.
|
| Modifier and Type | Method and Description |
|---|---|
MapIndex |
createIndex(boolean fOrdered,
Comparator comparator,
Map mapIndex,
BackingMapContext ctx)
Create an index and associate it with the corresponding extractor.
|
MapIndex |
destroyIndex(Map mapIndex)
Destroy an existing index and remove it from the given map of indexes.
|
boolean |
equals(Object o)
Equivalence by canonical name and target.
|
Object |
extract(Object oTarget)
Using a DeserializationAccelerator to extract values in not supported.
|
int |
hashCode()
HashCode value is hashCode of non-null
canonical name;
otherwise, it is the identity hashCode value. |
void |
readExternal(DataInput in)
Restore the contents of this object by loading the object's state from
the passed DataInput object.
|
void |
readExternal(PofReader in)
Restore the contents of a user type instance by reading its state using
the specified PofReader object.
|
String |
toString()
Return a human-readable description for this DeserializationAccelerator.
|
void |
writeExternal(DataOutput out)
Save the contents of this object by storing the object's state into
the passed DataOutput object.
|
void |
writeExternal(PofWriter out)
Save the contents of a POF user type instance by writing its state using
the specified PofWriter object.
|
compare, compareEntries, extractFromEntry, extractOriginalFromEntry, getCanonicalName, getTarget, isCanonicallyEquatableasBinary, calculatePackedLength, calculatePackedLength, checkObjectInputFilter, convertUTF, decodeExpiry, decorate, decorate, decorate, decorate, decorate, decorateBinary, encodeExpiry, ensureSerializer, extractIntDecoration, fromBinary, fromBinary, fromBinary, fromBinary, fromBinary, fromBinary, fromByteArray, fromByteArray, getClass, getDecoration, getDecoration, getDecorations, getDeltaCompressor, getInputStream, getNewObjectInput, getObjectInput, getObjectOutput, getObjectStreamFactory, getOutputStream, getShieldedOutputStream, getStreamFormat, getUndecorated, getUndecorated, isDecorated, isDecorated, isIntDecorated, isIntDecorated, isResolving, isSerializable, isSerializerCompatible, isVersionCompatible, isVersionCompatible, loadClass, loadResource, main, makeTrint, readBigDecimal, readBigInteger, readBooleanArray, readByteArray, readCollection, readDate, readDoubleArray, readExternalizableLite, readExternalizableLite, readFloatArray, readInt, readInt, readIntArray2d, readLong, readLong, readMap, readMap, readObject, readObject, readSafeUTF, readSafeUTF, readSerializable, readSerializable, readStringArray, readTime, readTimestamp, readTrint, readUnsignedTrint, readUTF, readXmlBean, readXmlSerializable, readXmlSerializable, realize, removeIntDecoration, removeIntDecoration, replace, reportIncompatibleSerializers, setObjectStreamFactory, toBinary, toBinary, toByteArray, toByteArray, toByteArray, toLiteBinary, toLong, undecorate, undecorate, validateBufferSize, writeBigDecimal, writeBigInteger, writeBooleanArray, writeByteArray, writeCollection, writeDate, writeDoubleArray, writeExternalizableLite, writeFloatArray, writeInt, writeInt, writeIntArray2d, writeLong, writeLong, writeMap, writeObject, writeSafeUTF, writeSafeUTF, writeSerializable, writeStringArray, writeTime, writeTimestamp, writeTrint, writeTrint, writeUTF, writeXmlBean, writeXmlSerializablecountBits, countBits, countBits, indexOfLSB, indexOfLSB, indexOfLSB, indexOfMSB, indexOfMSB, indexOfMSB, rotateLeft, rotateLeft, rotateLeft, rotateRight, rotateRight, rotateRight, toBitString, toBitString, toBitString, toBytes, toBytes, toBytes, toBytes, toInt, toInt, toLongazzert, 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, waitclone, finalize, getClass, notify, notifyAll, wait, wait, waitgetExtractorandThen, apply, applyAsDouble, applyAsInt, applyAsLong, compose, fromKey, getCanonicalName, getTarget, identity, identityCast, ofandThen, composecomparing, comparing, comparingDouble, comparingInt, comparingLong, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLongprotected ValueExtractor m_extractor
protected boolean m_fLazy
public DeserializationAccelerator()
public DeserializationAccelerator(ValueExtractor extractor)
extractor - the extractor used by this extractor to create a
ForwardOnlyMapIndex; note that the created index
will be associated with this extractor in the given
index map; passing null is equivalent to using the
IdentityExtractorpublic DeserializationAccelerator(ValueExtractor extractor, boolean fOnDemand)
extractor - the extractor used by this extractor to create a
ForwardOnlyMapIndex; note that the created index
will be associated with this extractor in the given
index map; passing null is equivalent to using the
IdentityExtractorfOnDemand - if true, the forward index will be created "on-demand"
as the values are attempted to be accessed; otherwise
the forward index is populated proactively (default)public MapIndex createIndex(boolean fOrdered, Comparator comparator, Map mapIndex, BackingMapContext ctx)
createIndex in interface IndexAwareExtractorfOrdered - true iff the contents of the indexed information
should be ordered; false otherwisecomparator - the Comparator object which imposes an ordering
of entries in the index contents; or null
if the entries' values natural ordering should be
usedmapIndex - Map<ValueExtractor, MapIndex> to be updated with the
created indexctx - The context the index is
associate with.public MapIndex destroyIndex(Map mapIndex)
destroyIndex in interface IndexAwareExtractormapIndex - map<ValueExtractor, MapIndex> to be updated by
removing the index being destroyedpublic Object extract(Object oTarget)
extract in interface ValueExtractorextract in class AbstractExtractoroTarget - the object to extract the value fromUnsupportedOperationException - alwayspublic void readExternal(DataInput in) throws IOException
readExternal in interface ExternalizableLitein - the DataInput stream to read data from in order to restore
the state of this objectIOException - if an I/O exception occursNotActiveException - if the object is not in its initial
state, and therefore cannot be deserialized intopublic void writeExternal(DataOutput out) throws IOException
writeExternal in interface ExternalizableLiteout - the DataOutput stream to write the state of this object toIOException - if an I/O exception occurspublic void readExternal(PofReader in) throws IOException
readExternal in interface PortableObjectin - the PofReader from which to read the object's stateIOException - if an I/O error occurspublic void writeExternal(PofWriter out) throws IOException
writeExternal in interface PortableObjectout - the PofWriter to which to write the object's stateIOException - if an I/O error occurspublic boolean equals(Object o)
When precondition AbstractExtractor.isCanonicallyEquatable(Object) is false,
fall back to implementation specific equals implementation.
equals in interface ValueExtractorequals in interface Comparatorequals in class AbstractExtractoro - the reference object with which to comparetrue if canonical name match and no target mismatchpublic int hashCode()
canonical name;
otherwise, it is the identity hashCode value.
Subclass computes hashCode when canonical name is null.
hashCode in interface ValueExtractorhashCode in class AbstractExtractor