Package | Description |
---|---|
com.tangosol.coherence.config.builder |
Defines the typical runtime configuration builders for the Coherence
configuration object model.
|
com.tangosol.io |
Contains classes providing cache persistence of serialized objects.
|
com.tangosol.io.nio |
Contains classes related to J2SE 1.4 NIO functionality.
|
com.tangosol.io.pof |
Contains classes related to POF serialization and deserialization.
|
com.tangosol.io.pof.reflect |
Contains classes related to POF stream navigation and manipulation.
|
com.tangosol.persistence |
Contains classes and helpers for implementing various types of persistence.
|
com.tangosol.util |
Contains various generic utilities.
|
Modifier and Type | Field and Description |
---|---|
protected ParameterizedBuilder<com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>> |
PersistenceEnvironmentParamBuilder.m_bldr
A
ParameterizedBuilder that creates a PersistenceEnvironment . |
Modifier and Type | Method and Description |
---|---|
com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> |
PersistenceEnvironmentParamBuilder.realize(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
ParameterList listParameters) |
protected com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> |
PersistenceEnvironmentParamBuilder.wrap(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env)
Wrap a
PersistenceEnvironment with a SafePersistenceEnvironment. |
Modifier and Type | Method and Description |
---|---|
void |
PersistenceEnvironmentParamBuilder.setCustomEnvironment(ParameterizedBuilder<com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>> bldrPersistence)
Set a
builder to be used instantiate the
appropriate PersistenceEnvironment . |
protected com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> |
PersistenceEnvironmentParamBuilder.wrap(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env)
Wrap a
PersistenceEnvironment with a SafePersistenceEnvironment. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractByteArrayReadBuffer
The AbstractByteArrayReadBuffer abstract class is intended to serve as
a base class for the following:
the pre-existing Binary class
a new byte[] based class that does not attempt to add the immutability
aspect provided by the Binary class
a new ByteBuffer based class that will work with Java NIO
This implementation is not intended to be thread safe.
|
class |
AbstractReadBuffer
Abstract base implementation of the ReadBuffer interface.
|
class |
ByteArrayReadBuffer
A ReadBuffer on top of a byte array.
|
class |
MultiBufferReadBuffer
The MultiBufferReadBuffer is a ReadBuffer implementation that presents a
view across any number of underlying ReadBuffer objects, as if they were
appended end-to-end into a single ReadBuffer.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
DecorationOnlyDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
DecoratedBinaryDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
BinaryDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
DeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
protected ReadBuffer |
BinaryDeltaCompressor.createDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Actually create a delta in the binary delta format.
|
ReadBuffer |
DecorationOnlyDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
DecoratedBinaryDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
BinaryDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
DeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
WrapperBufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.
|
ReadBuffer |
ReadBuffer.BufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.
|
ReadBuffer |
AbstractReadBuffer.AbstractBufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.
|
protected ReadBuffer |
MultiBufferReadBuffer.getBuffer(int iBuffer)
Obtain the specified buffer.
|
ReadBuffer |
AbstractWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.
|
ReadBuffer |
WriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.
|
ReadBuffer |
DelegatingWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.
|
ReadBuffer |
MultiBufferWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.
|
ReadBuffer |
ReadBuffer.getReadBuffer(int of,
int cb)
Obtain a ReadBuffer for a portion of this ReadBuffer.
|
ReadBuffer |
AbstractReadBuffer.getReadBuffer(int of,
int cb)
Obtain a ReadBuffer for a portion of this ReadBuffer.
|
ReadBuffer |
ByteArrayWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
abstract ReadBuffer |
AbstractWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
ReadBuffer |
WriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
ReadBuffer |
DelegatingWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
ReadBuffer |
MultiBufferWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
protected ReadBuffer |
ByteArrayReadBuffer.instantiateReadBuffer(int of,
int cb)
Factory method: Instantiate a ReadBuffer for a portion of this
ReadBuffer.
|
protected abstract ReadBuffer |
AbstractReadBuffer.instantiateReadBuffer(int of,
int cb)
Factory method: Instantiate a ReadBuffer for a portion of this
ReadBuffer.
|
protected ReadBuffer |
MultiBufferReadBuffer.instantiateReadBuffer(int of,
int cb)
Factory method: Instantiate a ReadBuffer for a portion of this
ReadBuffer.
|
ReadBuffer |
WrapperBufferInput.readBuffer(int cb)
Read
cb bytes and return them as a ReadBuffer object. |
ReadBuffer |
ReadBuffer.BufferInput.readBuffer(int cb)
Read
cb bytes and return them as a ReadBuffer object. |
ReadBuffer |
AbstractReadBuffer.AbstractBufferInput.readBuffer(int cb)
Read
cb bytes and return them as a ReadBuffer object. |
ReadBuffer |
MultiBufferReadBuffer.MultiBufferInput.readBuffer(int cb)
Read
cb bytes and return them as a ReadBuffer object. |
protected ReadBuffer |
MultiBufferReadBuffer.releaseBuffer(int iBuffer)
Release the specified buffer.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
DecorationOnlyDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
DecoratedBinaryDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
BinaryDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
DeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
protected ReadBuffer |
BinaryDeltaCompressor.createDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Actually create a delta in the binary delta format.
|
ReadBuffer |
DecorationOnlyDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
DecoratedBinaryDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
BinaryDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
DeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
void |
AbstractWriteBuffer.write(int ofDest,
ReadBuffer bufSrc)
Store the contents of the specified ReadBuffer at the specified offset
within this buffer.
|
void |
WriteBuffer.write(int ofDest,
ReadBuffer bufSrc)
Store the contents of the specified ReadBuffer at the specified offset
within this buffer.
|
void |
ByteArrayWriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
void |
AbstractWriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
void |
WriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
void |
DelegatingWriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
void |
MultiBufferWriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
void |
WrapperBufferOutput.writeBuffer(ReadBuffer buf)
Write all the bytes from the passed ReadBuffer object.
|
void |
AbstractWriteBuffer.AbstractBufferOutput.writeBuffer(ReadBuffer buf)
Write all the bytes from the passed ReadBuffer object.
|
void |
WriteBuffer.BufferOutput.writeBuffer(ReadBuffer buf)
Write all the bytes from the passed ReadBuffer object.
|
void |
DelegatingWriteBuffer.DelegatingBufferOutput.writeBuffer(ReadBuffer buf)
Write all the bytes from the passed ReadBuffer object.
|
void |
MultiBufferWriteBuffer.MultiBufferOutput.writeBuffer(ReadBuffer buf)
Write all the bytes from the passed ReadBuffer object.
|
void |
SizeEstimatingBufferOutput.writeBuffer(ReadBuffer buf) |
void |
WrapperBufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb)
Write
cb bytes from the passed ReadBuffer object
starting at offset of within the passed ReadBuffer. |
void |
AbstractWriteBuffer.AbstractBufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb)
Write
cb bytes from the passed ReadBuffer object
starting at offset of within the passed ReadBuffer. |
void |
WriteBuffer.BufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb)
Write
cb bytes from the passed ReadBuffer object
starting at offset of within the passed ReadBuffer. |
void |
DelegatingWriteBuffer.DelegatingBufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb)
Write
cb bytes from the passed ReadBuffer object
starting at offset of within the passed ReadBuffer. |
void |
MultiBufferWriteBuffer.MultiBufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb)
Write
cb bytes from the passed ReadBuffer object
starting at offset of within the passed ReadBuffer. |
void |
SizeEstimatingBufferOutput.writeBuffer(ReadBuffer buf,
int of,
int cb) |
Constructor and Description |
---|
MultiBufferReadBuffer(ReadBuffer[] abuf)
Construct a MultiBufferReadBuffer from an array of underlying
ReadBuffer objects.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteBufferReadBuffer
A ReadBuffer implementation on top of a Java NIO ByteBuffer.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
ByteBufferWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.
|
ReadBuffer |
ByteBufferWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.
|
protected ReadBuffer |
ByteBufferReadBuffer.instantiateReadBuffer(int of,
int cb)
Factory method: Instantiate a ReadBuffer for a portion of this
ReadBuffer.
|
Modifier and Type | Method and Description |
---|---|
void |
ByteBufferWriteBuffer.write(int ofDest,
ReadBuffer bufSrc,
int ofSrc,
int cbSrc)
Store the specified portion of the contents of the specified ReadBuffer
at the specified offset within this buffer.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
PofDeltaCompressor.createDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Actually create a delta in the binary delta format.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
PofDeltaCompressor.createDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Actually create a delta in the binary delta format.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
AbstractPofValue.getChanges()
Return a buffer containing changes made to this PofValue in the format
defined by the
BinaryDeltaCompressor . |
ReadBuffer |
PofValue.getChanges()
Return a buffer containing changes made to this PofValue in the format
defined by the
BinaryDeltaCompressor . |
protected ReadBuffer |
AbstractPofValue.getOriginalBuffer()
Get the original buffer the changes should be applied to.
|
ReadBuffer |
AbstractPofValue.getSerializedValue()
Return this value's serialized form.
|
ReadBuffer |
PofSparseArray.NilPofValue.getSerializedValue()
Return this value's serialized form.
|
protected ReadBuffer |
AbstractPofValue.getValueBuffer()
Get the raw value buffer.
|
Modifier and Type | Method and Description |
---|---|
protected PofValue |
ComplexPofValue.extractChild(ReadBuffer buf,
int of,
int cb)
Extract child PofValue from a buffer.
|
protected static PofValue |
PofValueParser.instantiatePofValue(PofValue valueParent,
int nType,
ReadBuffer bufValue,
PofContext ctx,
int of,
ReadBuffer.BufferInput in)
Creates a PofValue instance.
|
static PofValue |
PofValueParser.parse(ReadBuffer buf,
PofContext ctx)
Parses POF-encoded binary and returns an instance of a
PofValue
wrapper for it. |
protected static PofValue |
PofValueParser.parseUniformValue(PofValue valueParent,
int nType,
ReadBuffer bufValue,
PofContext ctx,
int of)
Parses a uniform POF-encoded binary and returns an instance of a
PofValue wrapping the binary. |
protected static PofValue |
PofValueParser.parseValue(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of)
Parse a POF-encoded binary and return an instance of a
PofValue
wrapping the binary. |
protected void |
AbstractPofValue.setDecorations(long nDecoMask,
ReadBuffer bufDeco)
Set the decoration mask and decorations for the PofValue.
|
protected void |
AbstractPofValue.setOriginalBuffer(ReadBuffer bufValue)
Set the original buffer the changes should be applied to.
|
Constructor and Description |
---|
AbstractPofValue(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType)
Construct a PofValue instance wrapping the supplied buffer.
|
ComplexPofValue(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren)
Construct a PofValue instance wrapping the supplied buffer.
|
PofArray(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int cElements)
Construct a PofArray instance wrapping the supplied buffer.
|
PofCollection(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int cElements)
Construct a PofCollection instance wrapping the supplied buffer.
|
PofSparseArray(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren)
Construct a PofSparseArray instance wrapping the supplied buffer.
|
PofUniformArray(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int cElements,
int nElementType)
Construct a PofUniformArray instance wrapping the supplied buffer.
|
PofUniformCollection(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int cElements,
int nElementType)
Construct a PofUniformCollection instance wrapping the supplied buffer.
|
PofUniformSparseArray(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int nElementType)
Construct a PofUniformSparseArray instance wrapping the supplied buffer.
|
PofUserType(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType,
int ofChildren,
int nVersion)
Construct a PofUserType instance wrapping the supplied buffer.
|
SimplePofValue(PofValue valueParent,
ReadBuffer bufValue,
PofContext ctx,
int of,
int nType)
Construct a SimplePofValue instance wrapping the supplied buffer.
|
Modifier and Type | Field and Description |
---|---|
protected ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.Operation.f_bufKey
The target key of the operation.
|
protected ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.StoreOperation.f_bufValue
The value to store.
|
Modifier and Type | Field and Description |
---|---|
protected com.oracle.coherence.persistence.PersistentStore<ReadBuffer> |
AbstractPersistenceManager.AbstractPersistentStore.OpenTask.f_storeFrom
The
PersistentStore to open with. |
Modifier and Type | Method and Description |
---|---|
protected static ReadBuffer |
CachePersistenceHelper.createIndexRegistrationKey(long lCacheId,
Binary binExtractor)
Create a key representing an index registration.
|
protected static ReadBuffer |
CachePersistenceHelper.createListenerRegistrationKey(long lMemberId,
long lCacheId,
Binary binKey)
Create a key representing a cache listener registration.
|
protected static ReadBuffer |
CachePersistenceHelper.createLockRegistrationKey(long lHolderId,
long lHolderThreadId,
long lCacheId,
Binary binKey)
Create a key representing a cache entry lock.
|
protected static ReadBuffer |
CachePersistenceHelper.createTriggerRegistrationKey(long lCacheId,
Binary binTrigger)
Create a key representing an trigger registration.
|
ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.load(long lExtentId,
ReadBuffer bufKey)
Return the value associated with the specified key, or null if the key
does not have an associated value in the underlying store.
|
protected abstract ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.loadInternal(long lExtentId,
ReadBuffer bufKey)
Load and return the value associated with the specified key from
the underlying persistent storage.
|
Modifier and Type | Method and Description |
---|---|
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> |
AbstractPersistenceEnvironment.createSnapshot(String sSnapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager)
Create a PersistenceManager used to manage the snapshot with the
specified identifier.
|
protected com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> |
AbstractSnapshotArchiver.createTempEnvironment(File fileBaseDir,
String sStorageFormat)
Create a temporary PersistenceEnvironment to write archived snapshots to
in the given format.
|
static com.oracle.coherence.persistence.PersistentStore.Visitor<ReadBuffer> |
CachePersistenceHelper.instantiatePersistenceVisitor(CachePersistenceHelper.Visitor visitorCache)
Instantiate a
visitor for the PersistentStore
backed by the |
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> |
AbstractPersistenceManager.open(String sId,
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom)
Open or create a
PersistentStore associated with the specified
identifier and based on the provided store . |
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> |
AbstractPersistenceManager.open(String sId,
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom,
com.oracle.coherence.common.base.Collector<Object> collector)
Open or create a
PersistentStore associated with the specified
identifier and based on the provided store . |
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> |
AbstractPersistenceEnvironment.openActive()
Open and return the singleton active PersistenceManager.
|
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> |
AbstractPersistenceEnvironment.openSnapshot(String sSnapshot)
Open a PersistenceManager used to access the snapshot with the
specified identifier.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.erase(long lExtentId,
ReadBuffer bufKey)
Queue an erase operation.
|
void |
AbstractPersistenceManager.AbstractPersistentStore.erase(long lExtentId,
ReadBuffer bufKey,
Object oToken)
Remove the specified key from the underlying store if present.
|
protected abstract void |
AbstractPersistenceManager.AbstractPersistentStore.eraseInternal(long lExtentId,
ReadBuffer bufKey,
Object oToken)
Remove the specified key from the underlying persistent storage
if present.
|
ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.load(long lExtentId,
ReadBuffer bufKey)
Return the value associated with the specified key, or null if the key
does not have an associated value in the underlying store.
|
protected abstract ReadBuffer |
AbstractPersistenceManager.AbstractPersistentStore.loadInternal(long lExtentId,
ReadBuffer bufKey)
Load and return the value associated with the specified key from
the underlying persistent storage.
|
void |
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.store(long lExtentId,
ReadBuffer bufKey,
ReadBuffer bufValue)
Queue a store operation.
|
void |
AbstractPersistenceManager.AbstractPersistentStore.store(long lExtentId,
ReadBuffer bufKey,
ReadBuffer bufValue,
Object oToken)
Store the specified value under the specific key in the underlying
store.
|
protected abstract void |
AbstractPersistenceManager.AbstractPersistentStore.storeInternal(long lExtentId,
ReadBuffer bufKey,
ReadBuffer bufValue,
Object oToken)
Store the specified value under the specific key in the underlying
persistent storage.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractSnapshotArchiver.archive(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) |
void |
SnapshotArchiver.archive(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env)
Archive the specified snapshot.
|
protected void |
DirectorySnapshotArchiver.archiveInternal(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) |
protected abstract void |
AbstractSnapshotArchiver.archiveInternal(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr)
Internal implementation to Archive the specified snapshot.
|
protected void |
AbstractPersistenceManager.AbstractPersistentStore.copyAndOpenInternal(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom)
Copy the provided store to ensure both the contents are available
in the new store and it is open thus ready to receive requests.
|
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> |
AbstractPersistenceEnvironment.createSnapshot(String sSnapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager)
Create a PersistenceManager used to manage the snapshot with the
specified identifier.
|
protected abstract AbstractPersistenceManager |
AbstractPersistenceEnvironment.createSnapshotInternal(File fileSnapshot,
String sSnapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager)
Create a snapshot with the specified identifier.
|
static LongArray<String> |
CachePersistenceHelper.getCacheNames(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Return the cache names that have been
stored
in the specified store. |
static int |
CachePersistenceHelper.getPartitionCount(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Return the partition count that has been stored in the specified store.
|
static int |
CachePersistenceHelper.getPersistenceVersion(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Return the persistence version the provided store was written with.
|
static String |
CachePersistenceHelper.getServiceVersion(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Deprecated.
|
protected boolean |
AbstractSnapshotArchiver.hasLocalSnapshot(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env,
String sSnapshot)
Return true if the specified snapshot exists for the PersistenceEnvironment.
|
static boolean |
CachePersistenceHelper.isSealed(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Return true if the specified store has been sealed.
|
void |
AbstractPersistenceManager.AbstractPersistentStore.iterate(com.oracle.coherence.persistence.PersistentStore.Visitor<ReadBuffer> visitor)
Iterate the key-value pairs in the persistent store, applying the
specified visitor to each key-value pair.
|
protected abstract void |
AbstractPersistenceManager.AbstractPersistentStore.iterateInternal(com.oracle.coherence.persistence.PersistentStore.Visitor<ReadBuffer> visitor)
Iterate the key-value pairs in the underlying persistent storage,
applying the specified visitor to each key-value pair.
|
protected boolean |
AbstractPersistenceManager.AbstractPersistentStore.open(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom)
Open this persistent store.
|
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> |
AbstractPersistenceManager.open(String sId,
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom)
Open or create a
PersistentStore associated with the specified
identifier and based on the provided store . |
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> |
AbstractPersistenceManager.open(String sId,
com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom,
com.oracle.coherence.common.base.Collector<Object> collector)
Open or create a
PersistentStore associated with the specified
identifier and based on the provided store . |
static com.tangosol.net.internal.QuorumInfo |
CachePersistenceHelper.readQuorum(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Read the membership information from the "META" extent.
|
static Binary |
CachePersistenceHelper.readQuorumRaw(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Read the membership information in Binary format from the "META" extent.
|
static void |
CachePersistenceHelper.registerIndex(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binExtractor,
Binary binComparator,
Object oToken)
Store the index registration in the specified persistent store.
|
static void |
CachePersistenceHelper.registerListener(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binKey,
long lListenerId,
boolean fLite,
Object oToken)
Store the listener registration in the specified persistent store.
|
static void |
CachePersistenceHelper.registerLock(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binKey,
long lHolderId,
long lHolderThreadId,
Object oToken)
Store the cache entry lock in the specified persistent store.
|
static void |
CachePersistenceHelper.registerTrigger(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binTrigger,
Object oToken)
Store the trigger registration in the specified persistent store.
|
void |
AbstractSnapshotArchiver.retrieve(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) |
void |
SnapshotArchiver.retrieve(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env)
Retrieve the specified archived snapshot.
|
protected void |
DirectorySnapshotArchiver.retrieveInternal(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) |
protected abstract void |
AbstractSnapshotArchiver.retrieveInternal(Snapshot snapshot,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr)
Internal implementation to retrieve the specified snapshot.
|
static void |
CachePersistenceHelper.seal(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
PartitionedService service,
Object oToken)
Seal the specified PersistentStore on behalf of the specified service,
indicating that it is fully initialized and eligible to be recovered
from this point forward.
|
protected void |
AbstractPersistenceManager.AbstractPersistentStore.submitOpen(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom,
com.oracle.coherence.common.base.Collector<Object> collector)
Open this store either asynchronously, iff both a store to open
from and a collector have been provided, or synchronously.
|
static void |
CachePersistenceHelper.unregisterIndex(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binExtractor,
Object oToken)
Clear the index registration from the specified persistent store.
|
static void |
CachePersistenceHelper.unregisterIndices(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId)
Clear all index registrations for the specified cache from the specified
persistent store.
|
static void |
CachePersistenceHelper.unregisterListener(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binKey,
long lListenerId,
Object oToken)
Clear the listener registration from the specified persistent store.
|
static void |
CachePersistenceHelper.unregisterListeners(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId)
Clear all listener registrations for the specified cache from the
specified persistent store.
|
static void |
CachePersistenceHelper.unregisterLock(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binKey,
long lHolderId,
long lHolderThreadId,
Object oToken)
Clear the cache entry lock from the specified persistent store.
|
static void |
CachePersistenceHelper.unregisterLocks(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId)
Clear all cache entry locks for the specified cache from the specified
persistent store.
|
static void |
CachePersistenceHelper.unregisterTrigger(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId,
Binary binTrigger,
Object oToken)
Clear the trigger registration from the specified persistent store.
|
static void |
CachePersistenceHelper.unregisterTriggers(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
long lCacheId)
Clear all trigger registrations for the specified cache from the specified
persistent store.
|
static void |
CachePersistenceHelper.unseal(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Remove a seal from a PersistentStore.
|
protected void |
AbstractPersistenceManager.AbstractPersistenceSnapshotTools.validateStoreSealed(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
Validate the given store is sealed.
|
protected void |
AbstractSnapshotArchiver.writeMetadata(File fileDir,
com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr,
String sStore)
Write the metadata using given manager for a particular store to a destination directory.
|
static Binary |
CachePersistenceHelper.writeQuorum(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
PartitionedService service)
Write the current membership information to the "META" extent.
|
static void |
CachePersistenceHelper.writeQuorumRaw(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store,
Binary binInfo)
Write the current membership information in raw format to the "META" extent.
|
Constructor and Description |
---|
EraseOperation(long lExtentId,
ReadBuffer bufKey)
Create a new EraseOperation.
|
Operation(long lExtentId,
ReadBuffer bufKey)
Create a new Operation.
|
StoreOperation(long lExtentId,
ReadBuffer bufKey,
ReadBuffer bufValue)
Create a new StoreOperation.
|
Constructor and Description |
---|
OpenTask(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom,
com.oracle.coherence.common.base.Collector<Object> collector)
Construct an OpenTask.
|
Modifier and Type | Class and Description |
---|---|
class |
Binary
A thread-safe immutable binary object.
|
static class |
ExternalizableHelper.DecoratedMultiBufferReadBuffer
DecoratedMultiBufferReadBuffer is a MultiBufferWriteBuffer that
represents a binary "decorated" value, and allows a more
optimized
ExternalizableHelper.getUndecorated(ReadBuffer) operation. |
Modifier and Type | Field and Description |
---|---|
protected ReadBuffer |
ExternalizableHelper.DecoratedMultiBufferReadBuffer.m_bufValue
The undecorated value.
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
NullImplementation.NullDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
ExternalizableHelper.FormatAwareCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
static ReadBuffer |
ExternalizableHelper.decorate(ReadBuffer bufOrig,
int nId,
ReadBuffer bufDeco)
Decorate the passed value with the specified decoration and return the
resulting ReadBuffer.
|
static ReadBuffer |
ExternalizableHelper.decorate(ReadBuffer buf,
ReadBuffer[] abufDeco)
Decorate the passed Binary with the passed decorations.
|
static ReadBuffer |
ExternalizableHelper.decorateBinary(ReadBuffer bufValue,
int nDecoration)
Decorate the specified ReadBuffer with the specified integer decoration.
|
static ReadBuffer |
ExternalizableHelper.encodeExpiry(ReadBuffer buf,
long ldtExpiry)
Return a ReadBuffer whose contents represent the specified buffer with
the specified expiry encoded as a DECO_EXPIRY decoration.
|
ReadBuffer |
NullImplementation.NullDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
ExternalizableHelper.FormatAwareCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
static ReadBuffer |
ExternalizableHelper.getDecoration(ReadBuffer buf,
int nId)
Extract and return the specified decoration from the passed ReadBuffer.
|
static ReadBuffer[] |
ExternalizableHelper.getDecorations(ReadBuffer buf)
Return an array containing all of the decorations from the passed
ReadBuffer.
|
ReadBuffer |
ExternalizableHelper.DecoratedMultiBufferReadBuffer.getUndecorated()
Return the undecorated value.
|
static ReadBuffer |
ExternalizableHelper.getUndecorated(ReadBuffer buf)
If the passed ReadBuffer is decorated, extract the original contents
that the decorations were added to, otherwise return the passed Binary
value.
|
protected ReadBuffer |
Binary.instantiateReadBuffer(int of,
int cb)
Factory method: Instantiate a ReadBuffer for a portion of this
ReadBuffer.
|
static ReadBuffer |
ExternalizableHelper.removeIntDecoration(ReadBuffer buf)
Remove a decoration value from the specified ReadBuffer that contains
a representation of an IntDecoratedObject.
|
static ReadBuffer |
ExternalizableHelper.undecorate(ReadBuffer buf,
int nId)
Remove the specified decoration from the passed ReadBuffer and return the
resulting contents (which may be undecorated, or contain the remaining
decorations).
|
Modifier and Type | Method and Description |
---|---|
ReadBuffer |
NullImplementation.NullDeltaCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
ReadBuffer |
ExternalizableHelper.FormatAwareCompressor.applyDelta(ReadBuffer bufOld,
ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.
|
static Binary |
ExternalizableHelper.asBinary(ReadBuffer buf)
Return a Binary representing the contents of the specified ReadBuffer, or
null if the buffer is null.
|
static long |
ExternalizableHelper.decodeExpiry(ReadBuffer buf)
Decode the expiry time from the specified ReadBuffer.
|
static ReadBuffer |
ExternalizableHelper.decorate(ReadBuffer bufOrig,
int nId,
ReadBuffer bufDeco)
Decorate the passed value with the specified decoration and return the
resulting ReadBuffer.
|
static ReadBuffer |
ExternalizableHelper.decorate(ReadBuffer buf,
ReadBuffer[] abufDeco)
Decorate the passed Binary with the passed decorations.
|
static ReadBuffer |
ExternalizableHelper.decorate(ReadBuffer buf,
ReadBuffer[] abufDeco)
Decorate the passed Binary with the passed decorations.
|
static ReadBuffer |
ExternalizableHelper.decorateBinary(ReadBuffer bufValue,
int nDecoration)
Decorate the specified ReadBuffer with the specified integer decoration.
|
static ReadBuffer |
ExternalizableHelper.encodeExpiry(ReadBuffer buf,
long ldtExpiry)
Return a ReadBuffer whose contents represent the specified buffer with
the specified expiry encoded as a DECO_EXPIRY decoration.
|
ReadBuffer |
NullImplementation.NullDeltaCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
ReadBuffer |
ExternalizableHelper.FormatAwareCompressor.extractDelta(ReadBuffer bufOld,
ReadBuffer bufNew)
Compare an old value to a new value and generate a delta that represents
the changes that must be made to the old value in order to transform it
into the new value.
|
static int |
ExternalizableHelper.extractIntDecoration(ReadBuffer buf)
Extract a decoration value from the specified ReadBuffer that contains a
representation of an IntDecoratedObject.
|
static ReadBuffer |
ExternalizableHelper.getDecoration(ReadBuffer buf,
int nId)
Extract and return the specified decoration from the passed ReadBuffer.
|
static ReadBuffer[] |
ExternalizableHelper.getDecorations(ReadBuffer buf)
Return an array containing all of the decorations from the passed
ReadBuffer.
|
static ReadBuffer |
ExternalizableHelper.getUndecorated(ReadBuffer buf)
If the passed ReadBuffer is decorated, extract the original contents
that the decorations were added to, otherwise return the passed Binary
value.
|
static boolean |
ExternalizableHelper.isDecorated(ReadBuffer buf)
If the ReadBuffer is the result of serialization by ExternalizableHelper,
determine if the buffer contains decorations.
|
static boolean |
ExternalizableHelper.isDecorated(ReadBuffer buf,
int nId)
If the ReadBuffer is the result of serialization by ExternalizableHelper,
determine if the buffer contains the specified decoration.
|
static boolean |
ExternalizableHelper.isIntDecorated(ReadBuffer buf)
Deprecated.
|
static ReadBuffer |
ExternalizableHelper.removeIntDecoration(ReadBuffer buf)
Remove a decoration value from the specified ReadBuffer that contains
a representation of an IntDecoratedObject.
|
static ReadBuffer |
ExternalizableHelper.undecorate(ReadBuffer buf,
int nId)
Remove the specified decoration from the passed ReadBuffer and return the
resulting contents (which may be undecorated, or contain the remaining
decorations).
|
static void |
Binary.writeExternal(DataOutput out,
ReadBuffer buf)
Write the contents of the specified ReadBuffer to the specified DataOutput
stream in a format that can be restored as a Binary via
Binary.readExternal(java.io.ObjectInput) |
Constructor and Description |
---|
DecoratedMultiBufferReadBuffer(ReadBuffer bufValue,
ReadBuffer[] abuf)
Construct a DecoratedMultiBufferReadBuffer for the specified value.
|
DecoratedMultiBufferReadBuffer(ReadBuffer bufValue,
ReadBuffer[] abuf)
Construct a DecoratedMultiBufferReadBuffer for the specified value.
|