Package | Description |
---|---|
com.bigdata.bfs |
This package provides a scale-out content repository (aka distributed file
system) suitable as the backend for a REST-ful service using the bigdata
architecture.
|
com.bigdata.bop.join | |
com.bigdata.bop.solutions |
This package provides distinct, sort, and aggregation operators.
|
com.bigdata.btree |
The
BTree is a scalable B+-Tree with copy-on-write
semantics mapping variable length unsigned byte[] keys to variable
length byte[] values (null values are allowed). |
com.bigdata.counters.store |
This package provides a persistence mechanism for performance
counters.
|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.htree | |
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.mdi |
This package provides a metadata index and range partitioned indices
managed by that metadata index.
|
com.bigdata.rawstore |
A set of interfaces and some simple implementations for a read-write
store without atomic commit or transactions.
|
com.bigdata.rdf.internal.encoder | |
com.bigdata.rdf.sail |
This package contains the SAIL that allow bigdata to be used as a backend for
the Sesame 2.x platform.
|
com.bigdata.resources |
This package provides the logic to managed the live journal and the
historical journals and index segments for a
DataService . |
com.bigdata.rwstore | |
com.bigdata.rwstore.sector | |
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
com.bigdata.stream |
Modifier and Type | Method and Description |
---|---|
byte[] |
BlobOverflowHandler.handle(ITuple tuple,
IRawStore target) |
Modifier and Type | Method and Description |
---|---|
IRawStore |
HTreeHashJoinUtility.getStore()
The backing
IRawStore . |
Modifier and Type | Method and Description |
---|---|
static SolutionSetStream |
SolutionSetStream.create(IRawStore store,
Stream.StreamIndexMetadata metadata)
Create a stream for an ordered solution set.
|
Constructor and Description |
---|
SolutionSetStream(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Required constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
IndexSegmentStore
A read-only store backed by a file containing a single
IndexSegment . |
Modifier and Type | Field and Description |
---|---|
protected IRawStore |
AbstractBTree.store
The persistence store -or-
null iff the B+Tree is transient. |
Modifier and Type | Method and Description |
---|---|
IRawStore |
BTree.getStore() |
IRawStore |
UnisolatedReadWriteIndex.getStore()
Return the backing store for the index.
|
IRawStore |
ISimpleIndexAccess.getStore()
The backing store.
|
Modifier and Type | Method and Description |
---|---|
static BTree |
BTree.create(IRawStore store,
IndexMetadata metadata)
Create a new
BTree or derived class. |
static ICheckpointProtocol |
Checkpoint.create(IRawStore store,
IndexMetadata metadata)
Generic method to create a persistence capable data structure (GIST
compatible, core implementation).
|
byte[] |
IOverflowHandler.handle(ITuple tuple,
IRawStore target)
Invoked for each index entry.
|
static Checkpoint |
Checkpoint.load(IRawStore store,
long addrCheckpoint)
Read a
Checkpoint record from a store. |
static BTree |
BTree.load(IRawStore store,
long addrCheckpoint,
boolean readOnly)
Load an instance of a
BTree or derived class from the store. |
static ICheckpointProtocol |
Checkpoint.loadFromCheckpoint(IRawStore store,
long checkpointAddr,
boolean readOnly)
Utility method reads the
Checkpoint record and then loads and
returns a view of the associated read-only persistence capable data
structure. |
static BloomFilter |
BloomFilter.read(IRawStore store,
long addr)
Read a bloom filter record from the store.
|
static IndexMetadata |
IndexMetadata.read(IRawStore store,
long addr)
Read the metadata record from the store.
|
long |
BloomFilter.write(IRawStore store)
Writes the bloom filter on the store and clears the
BloomFilter.isDirty()
flag. |
void |
Checkpoint.write(IRawStore store)
Write the
Checkpoint record on the store, setting
Checkpoint.addrCheckpoint as a side effect. |
void |
IndexMetadata.write(IRawStore store)
Write out the metadata record for the btree on the store and return the
address.
|
Constructor and Description |
---|
AbstractBTree(IRawStore store,
INodeFactory nodeFactory,
boolean readOnly,
IndexMetadata metadata,
IRecordCompressorFactory<?> recordCompressorFactory) |
BTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Required constructor form for
BTree and any derived subclasses. |
Modifier and Type | Method and Description |
---|---|
static CounterSetBTree |
CounterSetBTree.create(IRawStore store)
Create a new instance.
|
Constructor and Description |
---|
CounterSetBTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly) |
Modifier and Type | Interface and Description |
---|---|
interface |
IHAJournal
Convenience interface created in BLZG-1370 to factor out bigdata-jini
artifact dependencies.
|
Modifier and Type | Field and Description |
---|---|
protected IRawStore |
AbstractHTree.store
The backing store.
|
Modifier and Type | Method and Description |
---|---|
IRawStore |
AbstractHTree.getStore() |
Modifier and Type | Method and Description |
---|---|
static HTree |
HTree.create(IRawStore store,
HTreeIndexMetadata metadata)
Create a new
HTree or derived class. |
HTree |
AbstractHTreeTestCase.getHTree(IRawStore store,
int addressBits)
Return a new
HTree backed by a simple transient store that will
NOT evict leaves or nodes onto the store. |
HTree |
AbstractHTreeTestCase.getHTree(IRawStore store,
int addressBits,
boolean rawRecords,
boolean persistent) |
HTree |
AbstractHTreeTestCase.getHTree(IRawStore store,
int addressBits,
boolean rawRecords,
boolean persistent,
ITupleSerializer tupleSer) |
protected HTree |
TestIncrementalWrite.getHTree(IRawStore store,
int addressBits,
int queueCapacity,
int queueScan) |
static HTree |
HTree.load(IRawStore store,
long addrCheckpoint,
boolean readOnly)
Load an instance of a
HTree or derived class from the store. |
Constructor and Description |
---|
AbstractHTree(IRawStore store,
INodeFactory nodeFactory,
boolean readOnly,
HTreeIndexMetadata metadata,
IRecordCompressorFactory<?> recordCompressorFactory) |
HTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Required constructor form for
HTree and any derived subclasses. |
Modifier and Type | Interface and Description |
---|---|
interface |
IAtomicStore
Interface for low-level operations on a store supporting an atomic commit.
|
interface |
IBufferStrategy
Interface for implementations of a buffer strategy as identified by a
BufferMode . |
interface |
IDiskBasedStrategy
An interface for implementations backed by a file on disk.
|
interface |
IHABufferStrategy
A highly available
IBufferStrategy . |
interface |
IJournal
An persistence capable data structure supporting atomic commit, scalable
named indices, and transactions.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBufferStrategy
Abstract base class for
IBufferStrategy implementation. |
class |
AbstractJournal
The journal is a persistence capable data structure supporting atomic commit,
named indices, and full transactions.
|
class |
BasicBufferStrategy
Implements logic to read from and write on a buffer.
|
class |
DirectBufferStrategy
Direct buffer strategy uses a direct
ByteBuffer as a write through
cache and writes through to disk for persistence. |
class |
DiskBackedBufferStrategy
Abstract base class for implementations that use a direct buffer as a write
through cache to an image on the disk.
|
class |
DiskOnlyStrategy
Deprecated.
This has been replaced by
WORMStrategy . |
class |
Journal
Concrete implementation suitable for a local and unpartitioned database.
|
class |
JournalDelegate
IJournal delegation pattern. |
class |
MappedBufferStrategy
Memory-mapped journal strategy (this mode is NOT recommended).
|
class |
RWStrategy
A highly scalable persistent
IBufferStrategy wrapping the
RWStore which may be used as the backing store for a Journal . |
class |
TemporaryRawStore
A non-restart-safe store for temporary data that buffers data in memory until
the write cache overflows (or is flushed to the disk) and then converts to a
disk-based store.
|
class |
TemporaryStore
A temporary store that supports named indices but no concurrency controls.
|
class |
TransientBufferStrategy
Transient buffer strategy uses a direct buffer but never writes on disk.
|
class |
WORMStrategy
Disk-based Write Once Read Many (WORM) journal strategy.
|
Modifier and Type | Field and Description |
---|---|
protected IRawStore |
AbstractMRMWTestCase.store |
Modifier and Type | Method and Description |
---|---|
protected IRawStore |
TestWORMStrategyNoCache.TestInterrupts.getStore() |
protected IRawStore |
TestWORMStrategyNoCache.TestMROW.getStore() |
protected IRawStore |
TestWORMStrategyNoCache.TestMRMW.getStore() |
protected IRawStore |
TestDiskJournal.TestInterrupts.getStore() |
protected IRawStore |
TestDiskJournal.TestMROW.getStore() |
protected IRawStore |
TestDiskJournal.TestMRMW.getStore() |
protected IRawStore |
AbstractBufferStrategyTestCase.getStore() |
protected IRawStore |
TestWORMStrategy.TestInterrupts.getStore() |
protected IRawStore |
TestWORMStrategy.TestMRMW.getStore() |
protected IRawStore |
TestTransientJournal.TestMROW.getStore() |
protected IRawStore |
TestTransientJournal.TestMRMW.getStore() |
protected IRawStore |
AbstractMRMWTestCase.StressTestMRMW.getStore() |
protected IRawStore |
TestTemporaryStore.getStore() |
protected IRawStore |
TestTemporaryStore.TestRawStore.getStore() |
protected IRawStore |
TestTemporaryStore.TestInterrupts.getStore() |
protected IRawStore |
TestTemporaryStore.TestMROW.getStore() |
protected IRawStore |
TestTemporaryStore.TestMRMW.getStore() |
protected IRawStore |
TestMappedJournal.TestInterrupts.getStore() |
protected IRawStore |
TestMappedJournal.TestMROW.getStore() |
protected IRawStore |
TestMappedJournal.TestMRMW.getStore() |
protected IRawStore |
TestWORMStrategyOneCacheBuffer.TestInterrupts.getStore() |
protected IRawStore |
TestWORMStrategyOneCacheBuffer.TestMROW.getStore() |
protected IRawStore |
TestWORMStrategyOneCacheBuffer.TestMRMW.getStore() |
protected IRawStore |
TestDirectJournal.TestInterrupts.getStore() |
protected IRawStore |
TestDirectJournal.TestMROW.getStore() |
protected IRawStore |
TestDirectJournal.TestMRMW.getStore() |
IRawStore |
IResourceManager.openStore(UUID uuid)
Opens an
IRawStore . |
IRawStore |
Journal.openStore(UUID uuid)
Note: This will only succeed if the uuid identifies this
journal.
|
protected IRawStore |
AbstractRestartSafeTestCase.reopenStore(IRawStore store)
Re-open the same backing store.
|
Modifier and Type | Method and Description |
---|---|
static CommitRecordIndex |
CommitRecordIndex.create(IRawStore store)
Create a new instance.
|
static Name2Addr |
Name2Addr.create(IRawStore store)
Create a new instance.
|
static com.bigdata.testutil.ExperimentDriver.Result |
AbstractMRMWTestCase.doMRMWTest(IRawStore store,
long timeout,
int ntrials,
int nclients,
double percentReaders,
double percentWriterWillFlush,
int reclen,
int nwritesPerTask,
int nreadsPerTask,
AtomicInteger nerr)
A correctness/stress/performance test with a pool of concurrent clients
designed to verify MRMW operations.
|
static void |
AbstractMROWTestCase.doMROWTest(IRawStore store,
long nwrites,
long writeDelayMillis,
long timeout,
int nclients,
long ntrials,
int reclen,
long nreads,
AtomicInteger nerr,
boolean readAll)
A correctness/stress/performance test with a pool of concurrent clients
designed to verify MROW operations.
|
protected ICommitRecord |
CommitRecordIndex.loadCommitRecord(IRawStore store,
long addr)
Re-load a commit record from the store.
|
protected IRawStore |
AbstractRestartSafeTestCase.reopenStore(IRawStore store)
Re-open the same backing store.
|
Constructor and Description |
---|
AbstractMRMWTestCase.ReaderTask(AbstractMRMWTestCase.GroundTruth groundTruth,
IRawStore store,
int nreads) |
AbstractMRMWTestCase.WriterTask(AbstractMRMWTestCase.GroundTruth groundTruth,
IRawStore store,
int reclen,
int nwrites,
boolean forceToDisk) |
AbstractMROWTestCase.ReaderTask(IRawStore store,
AbstractMROWTestCase.WriterTask writer,
long nreads) |
AbstractMROWTestCase.WriterTask(IRawStore store,
int reclen,
long nwrites2,
long writeDelayMillis) |
CommitRecordIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store.
|
Name2Addr(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store (de-serialization constructor).
|
TestRestartSafe.MyBTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly) |
Modifier and Type | Method and Description |
---|---|
static MetadataIndex |
MetadataIndex.create(IRawStore store,
UUID indexUUID,
IndexMetadata managedIndexMetadata)
Create a new
MetadataIndex . |
Constructor and Description |
---|
MetadataIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Required ctor.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRawStore
Abstract base class for
IRawStore implementations. |
class |
AbstractRawWormStore
An abstract base class for
IRawStore implementations that use an
append only (Write Once, Read Many) strategy. |
class |
RawStoreDelegate
Simple delegation pattern.
|
class |
SimpleFileRawStore
A simple persistent unbuffered implementation backed by a file.
|
class |
SimpleMemoryRawStore
A purely transient append-only implementation useful when data need to be
buffered in memory.
|
Modifier and Type | Field and Description |
---|---|
protected IRawStore |
RawStoreDelegate.delegate |
Modifier and Type | Method and Description |
---|---|
protected IRawStore |
TestSimpleMemoryRawStore.getStore() |
protected abstract IRawStore |
AbstractRawStoreTestCase.getStore()
Return a new store that will serve as the fixture for the test.
|
protected IRawStore |
TestSimpleFileRawStore.getStore() |
IRawStore |
IStoreObjectOutputStream.getStore() |
IRawStore |
IStoreObjectInputStream.getStore() |
Constructor and Description |
---|
RawStoreDelegate(IRawStore delegate) |
Constructor and Description |
---|
IVBindingSetEncoderWithIVCache(IRawStore store,
boolean filter,
BOp op)
Deprecated.
|
Constructor and Description |
---|
TestMROWTransactions.MyBTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly) |
Modifier and Type | Class and Description |
---|---|
class |
StoreManager.ManagedJournal
The
StoreManager.ManagedJournal provides the backing store used to absorb
writes and retain history for the scale-out architecture. |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentWeakValueCacheWithTimeout<UUID,IRawStore> |
StoreManager.storeCache
A cache that is used by the to automatically close out unused
IndexSegmentStore s. |
Modifier and Type | Method and Description |
---|---|
IRawStore |
StoreManager.openStore(UUID uuid)
Opens an
IRawStore . |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractResourceManagerTestCase.assertSameResources(IRawStore[] expected,
Set<UUID> actual)
Test helper.
|
AbstractBTree |
IndexManager.getIndexOnStore(String name,
long timestamp,
IRawStore store)
Return a reference to the named index as of the specified timestamp on
the identified resource.
|
Constructor and Description |
---|
IndexSegmentIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store.
|
JournalIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IRWStrategy
Defines a marker interface to be used to indicate strategies that share RW
semantics such as
RWStrategy and MemStrategy |
Modifier and Type | Method and Description |
---|---|
protected IRawStore |
TestRWJournal.TestRawStore.getSmallSlotStore() |
protected IRawStore |
TestRWJournal.TestRawStore.getSmallSlotStore(int slotSize) |
protected IRawStore |
TestRWJournal.TestRawStore.getSmallSlotStore(int slotSize,
int nWasteAllocators,
float maxWaste) |
protected IRawStore |
TestRWJournal.TestRawStore.getStore() |
protected IRawStore |
TestRWJournal.TestMROW.getStore() |
protected IRawStore |
TestRWJournal.TestMRMW.getStore() |
protected IRawStore |
TestRWJournal.TestInterrupts.getStore() |
Modifier and Type | Class and Description |
---|---|
class |
MemStore
An
IRawStore backed by an IMemoryManager . |
class |
MemStrategy
A buffer implementation backed by an
IMemoryManager . |
Modifier and Type | Method and Description |
---|---|
protected IRawStore |
TestMemStore.TestRawStore.getStore() |
protected IRawStore |
TestMemStore.TestMROW.getStore() |
protected IRawStore |
TestMemStore.TestMRMW.getStore() |
Modifier and Type | Method and Description |
---|---|
static EventReceiver.EventBTree |
EventReceiver.EventBTree.create(IRawStore store)
Create a new instance.
|
Constructor and Description |
---|
CommitTimeIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store.
|
EventReceiver.EventBTree(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly) |
TxId2CommitTimeIndex(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Load from the store.
|
Modifier and Type | Method and Description |
---|---|
IRawStore |
Stream.getStore() |
Modifier and Type | Method and Description |
---|---|
static SolutionSetStream |
Stream.create(IRawStore store,
Stream.StreamIndexMetadata metadata)
Create a new
SolutionSetStream or derived class. |
static SolutionSetStream |
Stream.load(IRawStore store,
long addrCheckpoint,
boolean readOnly)
Load an instance of a
HTree or derived class from the store. |
Constructor and Description |
---|
Stream(IRawStore store,
Checkpoint checkpoint,
IndexMetadata metadata,
boolean readOnly)
Required constructor.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.