Package com.oracle.coherence.hibernate.cache.v53.access.processor

Class ReadWritePutFromLoadProcessor

  • All Implemented Interfaces:
    com.tangosol.util.InvocableMap.EntryProcessor, Serializable
    public class ReadWritePutFromLoadProcessor
extends com.tangosol.util.processor.AbstractProcessor
implements Serializable
    A AbstractReadWriteCoherenceEntityDataAccess.PutFromLoadProcessor is an EntryProcessor responsible for putting a value in a second-level cache that was just loaded from database, and returning a boolean indicating whether it did so, consistent with the expected behavior of a cache access strategy's putFromLoad() method. We move this behavior into the grid for efficient concurrency control.
    Author:
    Randy Stafford
    See Also:
    Serialized Form

    • Nested Class Summary

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

        com.tangosol.util.Base.LoggingWriter

    • Field Summary

      • 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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Object process​(com.tangosol.util.InvocableMap.Entry entry)

      • Methods inherited from class com.tangosol.util.processor.AbstractProcessor

        processAll

      • 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

    • Constructor Detail

      • ReadWritePutFromLoadProcessor

        public ReadWritePutFromLoadProcessor​(boolean minimalPutsInEffect,
                                     long txTimestamp,
                                     CoherenceRegionValue replacementValue,
                                     Comparator versionComparator)
        Complete constructor.
        Parameters:
        minimalPutsInEffect - a flag indicating whether "minimal puts" is in effect for Hibernate
        txTimestamp - From Hibernate javadoc, "a timestamp prior to the transaction start time" [where "the transaction" loaded the potential replacement value from database]
        replacementValue - the replacement cache value in this ReadWritePutFromLoadProcessor
        versionComparator - a Comparator for comparing actual value versions

    • Method Detail

      • process

        public Object process​(com.tangosol.util.InvocableMap.Entry entry)
        Specified by:
        process in interface com.tangosol.util.InvocableMap.EntryProcessor