org.apache.hadoop.hbase.master

Class ClusterSchemaServiceImpl

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.master.ClusterSchemaServiceImpl

All Implemented Interfaces:

ClusterSchema, ClusterSchemaService, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

@InterfaceAudience.Private
class ClusterSchemaServiceImpl
extends org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService
implements ClusterSchemaService

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
private static List<NamespaceDescriptor>	EMPTY_NAMESPACE_LIST
private MasterServices	masterServices
private TableNamespaceManager	tableNamespaceManager

Fields inherited from interface org.apache.hadoop.hbase.master.ClusterSchema

DEFAULT_HBASE_MASTER_CLUSTER_SCHEMA_OPERATION_TIMEOUT, HBASE_MASTER_CLUSTER_SCHEMA_OPERATION_TIMEOUT_KEY

Constructor Summary

Constructors

Constructor and Description
ClusterSchemaServiceImpl(MasterServices masterServices)

Method Summary

Modifier and Type	Method and Description
private void	checkIsRunning()
long	createNamespace(NamespaceDescriptor namespaceDescriptor, NonceKey nonceKey, ProcedurePrepareLatch latch) Create a new Namespace.
long	deleteNamespace(String name, NonceKey nonceKey, ProcedurePrepareLatch latch) Delete an existing Namespace.
protected void	doStart()
protected void	doStop()
NamespaceDescriptor	getNamespace(String name) Get a Namespace
List<NamespaceDescriptor>	getNamespaces() Get all Namespaces
TableNamespaceManager	getTableNamespaceManager() For internals use only.
long	modifyNamespace(NamespaceDescriptor namespaceDescriptor, NonceKey nonceKey, ProcedurePrepareLatch latch) Modify an existing Namespace.
private long	submitProcedure(Procedure<MasterProcedureEnv> procedure, NonceKey nonceKey)

Methods inherited from class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Field Detail

tableNamespaceManager

private final TableNamespaceManager tableNamespaceManager

masterServices

private final MasterServices masterServices

EMPTY_NAMESPACE_LIST

private static final List<NamespaceDescriptor> EMPTY_NAMESPACE_LIST

Constructor Detail

ClusterSchemaServiceImpl

ClusterSchemaServiceImpl(MasterServices masterServices)

Method Detail

checkIsRunning

private void checkIsRunning()
                     throws ServiceNotRunningException

Throws:

ServiceNotRunningException

doStart

protected void doStart()

Specified by:

doStart in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

getTableNamespaceManager

public TableNamespaceManager getTableNamespaceManager()

Description copied from interface: ClusterSchema

For internals use only. Do not use! Provisionally part of this Interface. Prefer the high-level APIs available elsewhere in this API.

Specified by:

getTableNamespaceManager in interface ClusterSchema

Returns:

Instance of TableNamespaceManager

submitProcedure

private long submitProcedure(Procedure<MasterProcedureEnv> procedure,
                             NonceKey nonceKey)
                      throws ServiceNotRunningException

Throws:

ServiceNotRunningException

createNamespace

public long createNamespace(NamespaceDescriptor namespaceDescriptor,
                            NonceKey nonceKey,
                            ProcedurePrepareLatch latch)
                     throws IOException

Description copied from interface: ClusterSchema

Create a new Namespace.

Specified by:

createNamespace in interface ClusterSchema

Parameters:

namespaceDescriptor - descriptor for new Namespace

nonceKey - A unique identifier for this operation from the client or process.

latch - A latch to block on for precondition validation

Returns:

procedure id

Throws:

IOException - if service is not running see ServiceNotRunningException

modifyNamespace

public long modifyNamespace(NamespaceDescriptor namespaceDescriptor,
                            NonceKey nonceKey,
                            ProcedurePrepareLatch latch)
                     throws IOException

Description copied from interface: ClusterSchema

Modify an existing Namespace.

Specified by:

modifyNamespace in interface ClusterSchema

nonceKey - A unique identifier for this operation from the client or process.

latch - A latch to block on for precondition validation

Returns:

procedure id

Throws:

IOException - if service is not running see ServiceNotRunningException

deleteNamespace

public long deleteNamespace(String name,
                            NonceKey nonceKey,
                            ProcedurePrepareLatch latch)
                     throws IOException

Description copied from interface: ClusterSchema

Delete an existing Namespace. Only empty Namespaces (no tables) can be removed.

Specified by:

deleteNamespace in interface ClusterSchema

nonceKey - A unique identifier for this operation from the client or process.

latch - A latch to block on for precondition validation

Returns:

procedure id

Throws:

IOException - if service is not running see ServiceNotRunningException

getNamespace

public NamespaceDescriptor getNamespace(String name)
                                 throws IOException

Description copied from interface: ClusterSchema

Get a Namespace

Specified by:

getNamespace in interface ClusterSchema

Parameters:

name - Name of the Namespace

Returns:

Namespace descriptor for name

Throws:

IOException - if namespace does not exist

getNamespaces

public List<NamespaceDescriptor> getNamespaces()
                                        throws IOException

Description copied from interface: ClusterSchema

Get all Namespaces

Specified by:

getNamespaces in interface ClusterSchema

Returns:

All Namespace descriptors

Throws:

IOException