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.task |
Abstraction layer for task-based concurrency at the triple store layer.
|
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.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTask<T>
Abstract base class for tasks that may be submitted to the
ConcurrencyManager . |
protected static class |
AbstractTask.DelegateTask<T>
Delegates various behaviors visible to the application code using the
ITask interface to the AbstractTask object. |
protected static class |
AbstractTask.InnerReadWriteTxServiceCallable<T>
Inner class used to wrap up the call to
AbstractTask.doTask() for
read-write transactions. |
protected static class |
AbstractTask.InnerWriteServiceCallable<T>
An instance of this class is used as the delegate to coordinate the acquisition of locks
with the
NonBlockingLockManager before the task can execute and to release
locks after the task has completed (whether it succeeds or fails). |
class |
DropIndexTask
Drop a named index (unisolated write operation).
|
class |
IndexProcedureTask<T>
Class provides an adaptor allowing a
IIndexProcedure to be executed
on an IConcurrencyManager . |
static class |
JournalTransactionService.SinglePhaseCommit
This task is an UNISOLATED operation that validates and commits a
transaction known to have non-empty write sets.
|
static class |
JournalTransactionService.ValidateWriteSetTask
This task is an UNISOLATED operation that validates a transaction known to
have non-empty write sets.
|
class |
RegisterIndexTask
Register a named index (unisolated write operation).
|
static class |
StressTestConcurrentUnisolatedIndices.WriteTask
A task that writes on named unisolated index(s).
|
Modifier and Type | Class and Description |
---|---|
class |
ApiTaskForJournal<T>
Wrapper for a task to be executed on the
IConcurrencyManager of a
Journal . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAtomicUpdateTask<T>
Abstract base class for tasks responsible for the atomic update of the view
of an index partition.
|
class |
AbstractPrepareTask<T>
Base class for the prepare phase which reads on the old journal.
|
class |
AbstractResourceManagerTask<T>
Abstract base class for tasks run during post-processing of a journal by the
ResourceManager . |
class |
CompactingMergeTask
Task builds an
IndexSegment from the fused view of an index partition
as of some historical timestamp and then atomically updates the view (aka a
compacting merge). |
protected static class |
CompactingMergeTask.AtomicUpdateCompactingMergeTask
The source view is pre-overflow (the last writes are on the old journal)
while the current view is post-overflow (reflects writes made since
overflow).
|
class |
IncrementalBuildTask
Task builds an
IndexSegment from the mutable BTree and zero
or more additional sources in the index partition view and then atomically
updates the view (aka an incremental build). |
protected static class |
IncrementalBuildTask.AtomicUpdateIncrementalBuildTask
The source is an
IndexSegment that was built from the mutable
BTree associated with the lastCommitTime on old journal of some
index partition. |
class |
JoinIndexPartitionTask
Task joins one or more index partitions and should be invoked when their is
strong evidence that the index partitions have shrunk enough to warrant their
being combined into a single index partition.
|
protected static class |
JoinIndexPartitionTask.AtomicUpdateJoinIndexPartition
Task performs an atomic update of the index partition view definitions on
the live journal and the
MetadataIndex , thereby putting into
effect the changes made by a JoinIndexPartitionTask . |
class |
MoveTask
Task moves an index partition to another
IDataService . |
protected static class |
MoveTask.AtomicUpdate
Moves an index partition from this data service to another data service.
|
class |
ScatterSplitTask
Task splits an index partition into N equal sized index partitions and
scatters those index partitions across data services in the federation.
|
class |
SplitIndexPartitionTask
Task splits an index partition which is a compact view (no more than one
journal and one index segment) and should be invoked when the size of the
index segment on the disk exceeds the nominal size of an index partition.
|
protected static class |
SplitIndexPartitionTask.AtomicUpdateSplitIndexPartitionTask
An
ITx.UNISOLATED operation that splits the live index using the
same Split points, generating new index partitions with new
partition identifiers. |
class |
SplitTailTask
Splits the tail of an index partition and optionally submits a task to move
the tail to a target data service specified by the caller.
|
protected static class |
SplitUtility.BuildIndexSegmentSplitTask
Task used to build an
IndexSegment from a restricted key-range of
an index during a SplitIndexPartitionTask . |
Modifier and Type | Class and Description |
---|---|
static class |
DataService.GetIndexMetadataTask
Retrieves the
IndexMetadata for the named index as of the
specified timestamp. |
protected static class |
DataService.RangeIteratorTask
Task for running a rangeIterator operation.
|
static class |
MetadataService.DropScaleOutIndexTask
Drops a scale-out index.
|
protected static class |
MetadataService.JoinIndexPartitionTask
Updates the
MetadataIndex to reflect the join of 2 or more index
partitions. |
protected static class |
MetadataService.MoveIndexPartitionTask
Updates the
MetadataIndex to reflect the move of an index
partition. |
protected static class |
MetadataService.NextPartitionIdTask
Task assigns the next partition identifier for a registered scale-out
index in a restart-safe manner.
|
protected static class |
MetadataService.RegisterScaleOutIndexTask
Registers a metadata index for a named scale-out index and statically
partition the index using the given separator keys and data services.
|
protected static class |
MetadataService.SplitIndexPartitionTask
Atomic operation removes the pre-existing entry for specified index
partition and replaces it with N new entries giving the locators for the
N new index partitions created when that index partition was split.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.