Uses of Class
com.bigdata.journal.AbstractTask

Packages that use AbstractTask

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.

Uses of AbstractTask in com.bigdata.journal

Subclasses of AbstractTask in com.bigdata.journal

Modifier and Type	Class and Description
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).

Fields in com.bigdata.journal declared as AbstractTask

Modifier and Type	Field and Description
protected AbstractTask<T>	AbstractTask.DelegateTask.delegate

Methods in com.bigdata.journal with parameters of type AbstractTask

Modifier and Type	Method and Description
protected void	WriteExecutorService.afterTask(AbstractTask<?> r, Throwable t) This is executed after doTask().
protected void	WriteExecutorService.beforeTask(Thread t, AbstractTask<?> r) Executed before doTask()
<T> FutureTask<T>	IConcurrencyManager.submit(AbstractTask<T> task) Submit a task (asynchronous).
<T> FutureTask<T>	ConcurrencyManager.submit(AbstractTask<T> task) Submit a task (asynchronous).
<T> FutureTask<T>	Journal.submit(AbstractTask<T> task)

Method parameters in com.bigdata.journal with type arguments of type AbstractTask

Modifier and Type	Method and Description
<T> List<Future<T>>	IConcurrencyManager.invokeAll(Collection<? extends AbstractTask<T>> tasks) Executes the given tasks, returning a list of Futures holding their status and results when all complete.
<T> List<Future<T>>	ConcurrencyManager.invokeAll(Collection<? extends AbstractTask<T>> tasks) Executes the given tasks, returning a list of Futures holding their status and results when all complete.
<T> List<Future<T>>	Journal.invokeAll(Collection<? extends AbstractTask<T>> tasks)
<T> List<Future<T>>	IConcurrencyManager.invokeAll(Collection<? extends AbstractTask<T>> tasks, long timeout, TimeUnit unit) Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first.
<T> List<Future<T>>	ConcurrencyManager.invokeAll(Collection<? extends AbstractTask<T>> tasks, long timeout, TimeUnit unit) Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first.
<T> List<Future<T>>	Journal.invokeAll(Collection<? extends AbstractTask<T>> tasks, long timeout, TimeUnit unit)

Constructors in com.bigdata.journal with parameters of type AbstractTask

Constructor and Description
AbstractTask.DelegateTask(AbstractTask<T> delegate)

Uses of AbstractTask in com.bigdata.rdf.task

Subclasses of AbstractTask in com.bigdata.rdf.task

Modifier and Type	Class and Description
class	ApiTaskForJournal<T> Wrapper for a task to be executed on the IConcurrencyManager of a Journal.

Uses of AbstractTask in com.bigdata.resources

Subclasses of AbstractTask in com.bigdata.resources

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.

Methods in com.bigdata.resources that return types with arguments of type AbstractTask

Modifier and Type	Method and Description
protected List<AbstractTask>	AsynchronousOverflowTask.chooseJoins() Scans the registered named indices and decides which ones (if any) are undercapacity and should be joined.
protected List<AbstractTask>	AsynchronousOverflowTask.chooseScatterSplits() Choose index partitions for scatter split operations.
protected List<AbstractTask>	AsynchronousOverflowTask.chooseSplitBuildOrMerge(boolean compactingMerge) For each index (partition) that has not been handled, decide whether we will: Split the index partition. Compacting merge - build an IndexSegment the FusedView of the the index partition. Incremental build - build an IndexSegment from the writes absorbed by the mutable BTree on the old journal (this removes the dependency on the old journal as of its lastCommitTime); or Note: Compacting merges are decided in two passes.
protected List<AbstractTask>	AsynchronousOverflowTask.chooseTasks(boolean forceCompactingMerges) Examine each named index on the old journal and decide what, if anything, to do with that index.

Method parameters in com.bigdata.resources with type arguments of type AbstractTask

Modifier and Type	Method and Description
protected <T> void	AsynchronousOverflowTask.runTasks(List<AbstractTask<T>> tasks) Submit all tasks, awaiting their completion and check their futures for errors.
protected <T> void	AsynchronousOverflowTask.runTasksConcurrent(List<AbstractTask<T>> tasks) Runs the overflow tasks in parallel, cancelling any tasks which have not completed if we run out of time.
protected <T> void	AsynchronousOverflowTask.runTasksInSingleThread(List<AbstractTask<T>> tasks) Runs the overflow tasks one at a time, stopping when the journal needs to overflow again, when we run out of time, or when there are no more tasks to be executed.

Uses of AbstractTask in com.bigdata.service

Subclasses of AbstractTask in com.bigdata.service

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.