com.bigdata.resources

Class AbstractAtomicUpdateTask<T>

java.lang.Object

com.bigdata.journal.AbstractTask<T>

com.bigdata.resources.AbstractResourceManagerTask<T>

com.bigdata.resources.AbstractAtomicUpdateTask<T>

All Implemented Interfaces:

ITask<T>, Callable<T>

Direct Known Subclasses:

CompactingMergeTask.AtomicUpdateCompactingMergeTask, IncrementalBuildTask.AtomicUpdateIncrementalBuildTask, JoinIndexPartitionTask.AtomicUpdateJoinIndexPartition, MoveTask.AtomicUpdate, SplitIndexPartitionTask.AtomicUpdateSplitIndexPartitionTask

public abstract class AbstractAtomicUpdateTask<T>
extends AbstractResourceManagerTask<T>

Abstract base class for tasks responsible for the atomic update of the view of an index partition.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.journal.AbstractTask

AbstractTask.DelegateTask<T>, AbstractTask.InnerReadWriteTxServiceCallable<T>, AbstractTask.InnerWriteServiceCallable<T>, AbstractTask.ResubmitException

Field Summary

Fields inherited from class com.bigdata.resources.AbstractResourceManagerTask

DEBUG, INFO, log, resourceManager

Fields inherited from class com.bigdata.journal.AbstractTask

checkpointNanoTime, concurrencyManager, isReadWriteTx, nanoTime_assignedWorker, nanoTime_beginWork, nanoTime_finishedWork, nanoTime_submitTask, readOnly, taskCounters, timestamp, transactionManager, tx

Constructor Summary

Constructors

Constructor and Description
AbstractAtomicUpdateTask(ResourceManager resourceManager, long timestamp, String resource)
AbstractAtomicUpdateTask(ResourceManager resourceManager, long timestamp, String[] resource)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	assertSameIndex(UUID expectedIndexUUID, BTree view) Verifies that the view is a view of the expected scale-out index.

Methods inherited from class com.bigdata.resources.AbstractResourceManagerTask

toString

Methods inherited from class com.bigdata.journal.AbstractTask

assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, doTask, dropIndex, getCommitTime, getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, getTaskName, getTimestamp, isResource, registerIndex, setupLoggingContext, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AbstractAtomicUpdateTask

public AbstractAtomicUpdateTask(ResourceManager resourceManager,
                        long timestamp,
                        String[] resource)

Parameters:

resourceManager -

timestamp -

resource -

AbstractAtomicUpdateTask

public AbstractAtomicUpdateTask(ResourceManager resourceManager,
                        long timestamp,
                        String resource)

Parameters:

resourceManager -

timestamp -

resource -

indexUUID - The UUID associated with the scale-out index.

Method Detail

assertSameIndex

protected void assertSameIndex(UUID expectedIndexUUID,
                   BTree view)

Verifies that the view is a view of the expected scale-out index.

This is used to detect drop/add sequences where a scale-out index exists with the same name but a different index UUID. Atomic update tasks check for this and disallow the update in order to prevent incorporation of the old index state into the new index.

Parameters:

expectedIndexUUID - The expected index UUID.

view - BTree whose view will be re-defined (must be part of the same scale-out index).

Throws:

IllegalStateException - if the index UUID does not agree. FIXME make sure that everyone tests this.