co.cask.cdap.data2.transaction.queue

Class AbstractQueueAdmin

java.lang.Object

co.cask.cdap.data2.transaction.queue.AbstractQueueAdmin

All Implemented Interfaces:

QueueAdmin

Direct Known Subclasses:

HBaseQueueAdmin, LevelDBQueueAdmin

public abstract class AbstractQueueAdmin
extends Object
implements QueueAdmin

Common implementation of table-based QueueAdmin

Field Summary

Fields

Modifier and Type	Field and Description
protected QueueConstants.QueueType	type
protected String	unqualifiedTableNamePrefix

Constructor Summary

Constructors

Constructor and Description
AbstractQueueAdmin(QueueConstants.QueueType type)

Method Summary

Methods

Modifier and Type	Method and Description
static String	getApplicationName(String queueTableName)
TableId	getDataTableId(Id.Flow flowId)
TableId	getDataTableId(QueueName queueName) This determines the actual TableId from the table name prefix and the name of the queue.
static String	getFlowName(String queueTableName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.data2.transaction.queue.QueueAdmin

clearAllForFlow, create, create, dropAllForFlow, dropAllInNamespace, exists, getQueueConfigurer, truncate, upgrade

Field Detail

type

protected final QueueConstants.QueueType type

unqualifiedTableNamePrefix

protected final String unqualifiedTableNamePrefix

Constructor Detail

AbstractQueueAdmin

public AbstractQueueAdmin(QueueConstants.QueueType type)

Method Detail

getApplicationName

public static String getApplicationName(String queueTableName)

Parameters:

queueTableName - actual queue table name

Returns:

app name this queue belongs to

getFlowName

public static String getFlowName(String queueTableName)

Parameters:

queueTableName - actual queue table name

Returns:

flow name this queue belongs to

getDataTableId

public TableId getDataTableId(QueueName queueName)

This determines the actual TableId from the table name prefix and the name of the queue.

Parameters:

queueName - The name of the queue.

Returns:

the full name of the table that holds this queue.

getDataTableId

public TableId getDataTableId(Id.Flow flowId)