| Package | Description |
|---|---|
| com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
| com.bigdata.rdf.sail.webapp | |
| com.bigdata.rdf.sparql.ast.ssets | |
| com.bigdata.rwstore | |
| com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TestReadCommittedTx<S extends Journal>
Test suite for transactions reading from a start time corresponding to the
last commit time on the database.
|
class |
TestReadOnlyTx<S extends Journal>
Test suite for fully isolated read-only transactions reading from a caller
specified start time.
|
| Modifier and Type | Field and Description |
|---|---|
protected Journal |
CompactTask.CopyIndexTask.newJournal
The new journal.
|
protected Journal |
CompactTask.oldJournal
The source
Journal. |
| Modifier and Type | Method and Description |
|---|---|
Journal |
CompactTask.call()
Compact the
CompactTask.oldJournal journal onto the CompactTask.outFile
file. |
protected Journal |
CompactTask.createJournal()
Create the output journal.
|
protected Journal |
TestWORMStrategy.TestMROW.getStore() |
protected Journal |
AbstractJournalTestCase.getStore(Properties properties) |
protected Journal |
AbstractJournalTestCase.reopenStore(Journal store)
Re-open the same backing store.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Journal> |
Journal.compact(File outFile)
Compacts the named indices found on this journal as of the most recent
commit point, writing their view onto a new Journal.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
CompactTask.copyIndices(Journal newJournal)
Copy all named indices from the
CompactTask.oldJournal to the new
journal. |
static com.bigdata.testutil.ExperimentDriver.Result |
StressTestConcurrentTx.doConcurrentClientTest(Journal journal,
long timeout,
int nclients,
int ntrials,
int keyLen,
int nops,
double abortRate)
A stress test with a pool of concurrent clients.
|
static com.bigdata.testutil.ExperimentDriver.Result |
StressTestConcurrentUnisolatedIndices.doConcurrentClientTest(Journal journal,
long timeout,
int nresources,
int minLocks,
int maxLocks,
int ntrials,
int keyLen,
int nops,
double failureRate)
A stress test of concurrent writers on one or more named indices.
|
static com.bigdata.testutil.ExperimentDriver.Result |
StressTestUnisolatedReadWriteIndex.doConcurrentClientTest(Journal journal,
long timeout,
int nresources,
int minLocks,
int maxLocks,
int ntrials,
int keyLen,
int nops,
double failureRate,
double commitRate)
A stress test of concurrent writers on one or more named indices.
|
BTree |
TestCommitList.getBTree(int branchingFactor,
Journal journal)
Return a btree backed by a journal with the indicated branching factor.
|
BTree |
TestRestartSafe.getBTree(int branchingFactor,
Journal journal)
Return a btree backed by a journal with the indicated branching factor.
|
protected Journal |
AbstractJournalTestCase.reopenStore(Journal store)
Re-open the same backing store.
|
void |
QueueStatsPlugIn.startService(Journal indexManager)
Start the service.
|
void |
HttpPlugin.startService(Journal indexManager)
Start the service.
|
void |
PlatformStatsPlugIn.startService(Journal indexManager)
Start the service.
|
void |
GangliaPlugIn.startService(Journal journal)
Start the service.
|
protected long |
AbstractBufferStrategyTestCase.writeRandomData(Journal store,
long nbytesToWrite,
boolean allowChecksum)
Write random bytes on the store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractJournalTestCase.setUp(ProxyTestCase<Journal> testCase)
Invoked from
TestCase.setUp() for each test in the suite. |
void |
AbstractJournalTestCase.tearDown(ProxyTestCase<Journal> testCase)
Invoked from
TestCase.tearDown() for each test in the suite. |
| Constructor and Description |
|---|
CompactTask.CopyIndexTask(Journal newJournal,
String name) |
CompactTask(Journal src,
File outFile,
long commitTime)
The task reads the state of each named index as of the given
commitTime and writes the index data in order on the output journal.
|
DumpJournal(Journal journal) |
JournalTransactionService(Properties properties,
Journal journal) |
SnapshotTask(Journal journal,
ISnapshotFactory snapshotFactory) |
StressTestConcurrentTx.Task(Journal journal,
String name,
int trial,
int keyLen,
int nops,
double abortRate) |
StressTestUnisolatedReadWriteIndex.WriteTask(Journal journal,
String[] resource,
int trial,
int keyLen,
int nops,
double failureRate,
double commitRate,
org.eclipse.jetty.util.ConcurrentHashSet<Thread> threads) |
WarmUpTask(Journal journal,
List<String> namespaces,
long timestamp,
int nparallel,
boolean visitLeaves) |
| Modifier and Type | Field and Description |
|---|---|
protected Journal |
TestServiceWhiteList.m_indexManager |
protected Journal |
TestNanoSparqlServer.m_indexManager |
| Modifier and Type | Field and Description |
|---|---|
protected Journal |
TestSolutionSetManager.journal |
| Modifier and Type | Method and Description |
|---|---|
protected Journal |
TestRWJournal.TestRawStore.getStore(long retentionMillis) |
| Modifier and Type | Field and Description |
|---|---|
protected Journal |
LoadBalancerService.eventStore
Used to persist the logged events.
|
| Modifier and Type | Method and Description |
|---|---|
protected Journal |
TestJournal.reopenStore(Journal store)
Extends the basic behavior to force a commit of the
Journal. |
| Modifier and Type | Method and Description |
|---|---|
protected Journal |
TestJournal.reopenStore(Journal store)
Extends the basic behavior to force a commit of the
Journal. |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.