Package | Description |
---|---|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.quorum |
This package defines interfaces and implementations for a quorum of highly
available services.
|
com.bigdata.rwstore |
Modifier and Type | Class and Description |
---|---|
class |
QuorumServiceBase<S extends HAGlue,L extends AbstractJournal>
Abstract implementation provides the logic for distributing messages for the
quorum 2-phase commit protocol, failover reads, etc.
|
Constructor and Description |
---|
FutureTaskInvariantMon(Callable<T> callable,
Quorum<HAGlue,QuorumService<HAGlue>> quorum) |
FutureTaskInvariantMon(Runnable runnable,
T result,
Quorum<HAGlue,QuorumService<HAGlue>> quorum) |
JoinedAndNonJoinedServices(Quorum<HAGlue,QuorumService<HAGlue>> quorum) |
Modifier and Type | Method and Description |
---|---|
Quorum<HAGlue,QuorumService<HAGlue>> |
JournalDelegate.getQuorum() |
Quorum<HAGlue,QuorumService<HAGlue>> |
AbstractJournal.getQuorum() |
Quorum<HAGlue,QuorumService<HAGlue>> |
IJournal.getQuorum()
The
Quorum for this service -or- null if the service
is not running with a quorum. |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractJournal.doLocalCommit(QuorumService<HAGlue> localService,
IRootBlockView rootBlock)
Local commit protocol (HA).
|
Modifier and Type | Method and Description |
---|---|
void |
WORMStrategy.writeOnStream(OutputStream os,
AbstractJournal.ISnapshotData snapshotData,
Quorum<HAGlue,QuorumService<HAGlue>> quorum,
long token) |
void |
IHABufferStrategy.writeOnStream(OutputStream os,
AbstractJournal.ISnapshotData coreData,
Quorum<HAGlue,QuorumService<HAGlue>> quorum,
long token)
Write a consistent snapshot of the committed state of the backing store.
|
void |
RWStrategy.writeOnStream(OutputStream os,
AbstractJournal.ISnapshotData snapshotData,
Quorum<HAGlue,QuorumService<HAGlue>> quorum,
long token) |
Constructor and Description |
---|
AbstractJournal.BasicHA.VoteNoTask(QuorumService<HAGlue> localService) |
Constructor and Description |
---|
AbstractJournal(Properties properties,
Quorum<HAGlue,QuorumService<HAGlue>> quorum)
Create or re-open a journal as part of a highly available
Quorum . |
Journal(Properties properties,
Quorum<HAGlue,QuorumService<HAGlue>> quorum) |
Constructor and Description |
---|
QuorumTokenTransitions(long currentQuorumToken,
long newQuorumToken,
QuorumService<HAGlue> service,
long haReady) |
Modifier and Type | Method and Description |
---|---|
void |
RWStore.writeOnStream(OutputStream os,
AbstractJournal.ISnapshotData snapshotData,
Quorum<HAGlue,QuorumService<HAGlue>> quorum,
long token) |
void |
RWStore.writeOnStream2(OutputStream os,
Set<Map.Entry<Long,byte[]>> snapshotData,
Quorum<HAGlue,QuorumService<HAGlue>> quorum,
long token) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.