Package | Description |
---|---|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.ha.pipeline |
This package provides services for sending and receiving low-level write cache
blocks among the members of a highly available quorum.
|
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 | Method and Description |
---|---|
long |
HAGlue.awaitHAReady(long timeout,
TimeUnit unit)
Await the service being ready to partitipate in an HA quorum.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPipelineChangeException
A quorum related exception dealing with the write replication pipeline.
|
class |
AbstractPipelineException
A quorum related exception dealing with the write replication pipeline.
|
class |
NestedPipelineException
An exception that is used to wrap and rethrow a cause whose root cause is
another
AbstractPipelineException . |
class |
PipelineDownstreamChange
Exception thrown when the downstream service is changed by a pipeline
reconfiguration.
|
class |
PipelineImmediateDownstreamReplicationException
Exception thrown when there is a problem with write replication from a
service to its downstream service, including a problem with RMI to the
downstream service or socket level write replication to the downstream
service.
|
class |
PipelineUpstreamChange
Exception thrown when the upstream service is changed by a pipeline
reconfiguration.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournal.assertHAReady(long token)
Assert that the
AbstractJournal.getHAReady() token has the specified value. |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousQuorumCloseException
An instance of this class is thrown when the caller is awaiting a quorum
event and the quorum is asynchronously closed.
|
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.