com.bigdata.service

Class MetadataService.RegisterScaleOutIndexTask

java.lang.Object

com.bigdata.journal.AbstractTask

com.bigdata.service.MetadataService.RegisterScaleOutIndexTask

All Implemented Interfaces:

ITask, Callable

Enclosing class:

MetadataService

protected static class MetadataService.RegisterScaleOutIndexTask
extends AbstractTask

Registers a metadata index for a named scale-out index and statically partition the index using the given separator keys and data services.

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.journal.AbstractTask

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

Constructor Summary

Constructors

Constructor and Description
MetadataService.RegisterScaleOutIndexTask(IBigdataFederation fed, ConcurrencyManager concurrencyManager, IResourceManager resourceManager, String metadataIndexName, IndexMetadata metadata, byte[][] separatorKeys, UUID[] dataServiceUUIDs) Create and statically partition a scale-out index.

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	doTask() Create and statically partition the scale-out index.

Methods inherited from class com.bigdata.journal.AbstractTask

assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, 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

MetadataService.RegisterScaleOutIndexTask

public MetadataService.RegisterScaleOutIndexTask(IBigdataFederation fed,
                                         ConcurrencyManager concurrencyManager,
                                         IResourceManager resourceManager,
                                         String metadataIndexName,
                                         IndexMetadata metadata,
                                         byte[][] separatorKeys,
                                         UUID[] dataServiceUUIDs)

Create and statically partition a scale-out index.

Parameters:

metadataIndexName - The name of the metadata index (the resource on which the task must have a lock).

separatorKeys - The array of separator keys. Each separator key is interpreted as an unsigned byte[]. The first entry MUST be an empty byte[]. The entries MUST be in sorted order.

dataServiceUUIDs - The array of data services onto which each partition defined by a separator key will be mapped (optional). The #of entries in this array MUST agree with the #of entries in the separatorKeys array. When null, the index paritions will be auto-assigned to data services.

Method Detail

doTask

protected Object doTask()
                 throws Exception

Create and statically partition the scale-out index.

Specified by:

doTask in class AbstractTask

Returns:

The UUID assigned to the managed index.

Throws:

Exception - The exception that will be thrown by AbstractTask.call() iff the operation fails.

InterruptedException - This exception SHOULD be thrown if Thread.interrupted() becomes true during execution.