|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.io.journal.JournalBinaryStore
public class JournalBinaryStore
A BinaryStore that writes to a Journal.
Nested Class Summary | |
---|---|
protected static class |
JournalBinaryStore.ClearListener The ClearListener is used to ensure that entries are removed from the journal when the corresponding keys are cleared from the ticket tree. |
Nested classes/interfaces inherited from interface com.tangosol.io.BinaryStore |
---|
BinaryStore.KeySetAware, BinaryStore.SizeAware |
Field Summary | |
---|---|
protected MultiBinaryLongMap |
f_mblm The MultiBinaryLongMap. |
protected BinaryLongMap |
m_blmTickets Mapping from Binary keys to journal "tickets". |
protected java.util.concurrent.atomic.AtomicLong |
m_cbTotal Number of bytes in the Journal currently "owned" by this BinaryStore. |
protected long |
m_cEvacuations The number of evacuations occurred on this Journal.JournalConsumer . |
protected Journal |
m_journal The journal manager for this BinaryStore. |
Constructor Summary | |
---|---|
JournalBinaryStore(Journal journal) Construct a JournalBinaryStore. |
|
JournalBinaryStore(Journal journal, MultiBinaryLongMap mblm) Construct a JournalBinaryStore. |
Method Summary | |
---|---|
protected BinaryLongMap |
configureTicketTree() Configure and return the BinaryLongMap to be used to store journal tickets. |
boolean |
containsKey(Binary binKey) Return true iff this BinaryStore contains a mapping for the specified key. |
void |
dedupe(byte[][] aab) This method may be invoked by the Journal implementation to request that any immutable byte arrays managed by the consumer be de-duplicated. |
void |
dispose() |
void |
erase(Binary binKey) Remove the specified key from the underlying store if present. |
void |
eraseAll() Remove all data from the underlying store. |
void |
evacuate(long lTicketMask, long lTicketValue) This method may be invoked by the Journal implementation to request that the consumer evacuate a particular journal file. |
long |
getByteCount() Calculate the total amount of data currently stored in the journal by this BinaryStore. |
java.lang.String |
getDescription() Format a String description of the Consumer. |
Journal |
getJournal() Obtain the underlying journaling system used by this BinaryStore. |
int |
getKeyCount() Determine the number of keys currently stored in the journal by this BinaryStore. |
MultiBinaryLongMap |
getMultiBinaryLongMap() Return the MultiBinaryLongMap used to store the underlying keys in this KeySetAware BinaryStore. |
protected BinaryLongMap |
getTicketTree() An internal accessor for the "tree of tickets"; this accessor is used only by client threads, and has a built-in check for if the journal has already been disposed of (which could occur on a different thread). |
java.util.Iterator |
keys() Iterate all keys in the underlying store. |
Binary |
load(Binary binKey) Return the value associated with the specified key, or null if the key does not have an associated value in the underlying store. |
int |
size() Determine the number of keys in the BinaryStore. |
void |
store(Binary binKey, Binary binValue) Store the specified value under the specific key in the underlying store. |
java.lang.String |
toString() |
Field Detail |
---|
protected volatile long m_cEvacuations
Journal.JournalConsumer
.protected Journal m_journal
protected BinaryLongMap m_blmTickets
protected final MultiBinaryLongMap f_mblm
protected final java.util.concurrent.atomic.AtomicLong m_cbTotal
Constructor Detail |
---|
public JournalBinaryStore(Journal journal)
journal
- the Journal to write to and read frompublic JournalBinaryStore(Journal journal, MultiBinaryLongMap mblm)
journal
- the Journal to write to and read frommblm
- the MultiBinaryLongMap used to store the keys and ticketsMethod Detail |
---|
public Binary load(Binary binKey)
load
in interface BinaryStore
binKey
- key whose associated value is to be returnedpublic void store(Binary binKey, Binary binValue)
store
in interface BinaryStore
binKey
- key to store the value underbinValue
- value to be storedpublic void erase(Binary binKey)
erase
in interface BinaryStore
binKey
- key whose mapping is to be removed from the mappublic void eraseAll()
eraseAll
in interface BinaryStore
public java.util.Iterator keys()
keys
in interface BinaryStore
public int size()
size
in interface BinaryStore.SizeAware
public boolean containsKey(Binary binKey)
containsKey
in interface BinaryStore.KeySetAware
binKey
- key whose presence in the BinaryStore is to be testedpublic MultiBinaryLongMap getMultiBinaryLongMap()
MultiBinaryLongMap
used to store the underlying keys in this KeySetAware BinaryStore.getMultiBinaryLongMap
in interface BinaryStore.KeySetAware
public void evacuate(long lTicketMask, long lTicketValue)
evacuate
in interface Journal.JournalConsumer
lTicketMask
- indicates which bits of the tickets to checklTicketValue
- indicates what bit pattern needs to be matched on the tickets in order to select them for evacuationpublic void dedupe(byte[][] aab)
dedupe
in interface Journal.JournalConsumer
aab
- an array of byte[] objects for intern-ing byte[] referencespublic java.lang.String getDescription()
getDescription
in interface Journal.JournalConsumer
public void dispose()
dispose
in interface com.oracle.common.base.Disposable
public java.lang.String toString()
public Journal getJournal()
public int getKeyCount()
public long getByteCount()
protected BinaryLongMap getTicketTree()
protected BinaryLongMap configureTicketTree()
|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |