Package | Description |
---|---|
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
Modifier and Type | Class and Description |
---|---|
class |
CommitRecord
A read-only view of an
ICommitRecord . |
Modifier and Type | Field and Description |
---|---|
protected ICommitRecord |
CompactTask.commitRecord
The
ICommitRecord corresponding to the caller specified commit
time. |
Modifier and Type | Method and Description |
---|---|
ICommitRecord |
CommitRecordSerializer.deserialize(ByteBuffer buf) |
ICommitRecord |
CommitRecordIndex.fetchCommitRecord(CommitRecordIndex.Entry entry)
Materialize a commit record, from cache if possible.
|
ICommitRecord |
CommitRecordIndex.find(long timestamp)
Return the
ICommitRecord having the largest timestamp that is
less than or equal to the given timestamp. |
ICommitRecord |
CommitRecordIndex.findNext(long timestamp)
Find the first commit record strictly greater than the timestamp.
|
ICommitRecord |
CommitRecordIndex.get(long commitTime)
Return the
ICommitRecord with the given timestamp (exact match). |
ICommitRecord |
AbstractJournal.getCommitRecord()
Returns a read-only view of the most recently committed
ICommitRecord containing the root addresses. |
ICommitRecord |
JournalDelegate.getCommitRecord(long timestamp) |
ICommitRecord |
AbstractJournal.getCommitRecord(long commitTime)
Return the
ICommitRecord for the most recent committed state
whose commit timestamp is less than or equal to timestamp. |
ICommitRecord |
IAtomicStore.getCommitRecord(long timestamp)
Return the
ICommitRecord for the most recent committed state
whose commit timestamp is less than or equal to timestamp. |
ICommitRecord |
AbstractJournal.getCommitRecordStrictlyGreaterThan(long commitTime)
Return the first commit record whose timestamp is strictly greater than
the given commitTime.
|
protected ICommitRecord |
AbstractJournal.getEarliestVisibleCommitRecordForHA(long releaseTime)
Resolve the
ICommitRecord for the earliest visible commit point
based on the caller's releaseTime. |
ICommitRecord |
AbstractCommitRecordTestCase.getRandomCommitRecord() |
protected ICommitRecord |
CommitRecordIndex.loadCommitRecord(IRawStore store,
long addr)
Re-load a commit record from the store.
|
Modifier and Type | Method and Description |
---|---|
void |
CommitRecordIndex.add(long commitRecordAddr,
ICommitRecord commitRecord)
Add an entry for a commit record.
|
void |
AbstractCommitRecordTestCase.assertEquals(ICommitRecord expected,
ICommitRecord actual)
Compare two
ICommitRecord s for equality in their data. |
void |
TestCommitHistory.assertEquals(ICommitRecord expected,
ICommitRecord actual)
Compare two
ICommitRecord s for equality in their data. |
void |
TestCommitRecordSerializer.doRoundTripTest(ICommitRecord roots) |
ICheckpointProtocol |
AbstractJournal.getIndexWithCommitRecord(String name,
ICommitRecord commitRecord)
Returns a read-only named index loaded from a
ICommitRecord . |
byte[] |
CommitRecordSerializer.serialize(ICommitRecord commitRecord) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.