co.cask.cdap.data2.transaction.queue.leveldb

Class LevelDBQueueAdmin

java.lang.Object

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

co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueAdmin

All Implemented Interfaces:

QueueAdmin

public class LevelDBQueueAdmin
extends AbstractQueueAdmin

admin for queues in leveldb.

Field Summary

Fields inherited from class co.cask.cdap.data2.transaction.queue.AbstractQueueAdmin

type, unqualifiedTableNamePrefix

Constructor Summary

Constructors

Modifier	Constructor and Description
	LevelDBQueueAdmin(CConfiguration conf, LevelDBTableService service)
protected	LevelDBQueueAdmin(LevelDBTableService service, QueueConstants.QueueType type)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearAllForFlow(Id.Flow flowId) Clears all queues for a flow, for example if the flow is upgraded and old.
void	create(QueueName queueName) Creates queue if doesn't exist.
void	create(QueueName queueName, Properties props) Creates queue if doesn't exist.
boolean	doDropTable(QueueName queueName) This determines whether dropping a queue is supported (by dropping the queue's table).
boolean	doTruncateTable(QueueName queueName) This determines whether truncating a queue is supported (by truncating the queue's table).
void	dropAllForFlow(Id.Flow flowId) Deletes all queues for a flow, for example if the flow is deleted.
void	dropAllInNamespace(Id.Namespace namespaceId) Deletes all queues in a namespace
boolean	exists(QueueName queueName)
String	getActualTableName(QueueName queueName)
QueueConfigurer	getQueueConfigurer(QueueName queueName) Returns a QueueConfigurer for configuring the queue.
protected String	getTableNameForFlow(Id.Flow flowId)
void	truncate(QueueName queueName) Wipes out queue data.
void	upgrade() Performs upgrade action for all queues.

Methods inherited from class co.cask.cdap.data2.transaction.queue.AbstractQueueAdmin

getApplicationName, getDataTableId, getDataTableId, getFlowName

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBQueueAdmin

@Inject
public LevelDBQueueAdmin(CConfiguration conf,
                        LevelDBTableService service)

LevelDBQueueAdmin

protected LevelDBQueueAdmin(LevelDBTableService service,
                 QueueConstants.QueueType type)

Method Detail

doDropTable

public boolean doDropTable(QueueName queueName)

This determines whether dropping a queue is supported (by dropping the queue's table).

doTruncateTable

public boolean doTruncateTable(QueueName queueName)

This determines whether truncating a queue is supported (by truncating the queue's table).

exists

public boolean exists(QueueName queueName)

Parameters:

queueName - Name of the queue

Returns:

true if queue with given name exists, otherwise false

create

public void create(QueueName queueName)
            throws Exception

Description copied from interface: QueueAdmin

Creates queue if doesn't exist. If queue exists does nothing.

Parameters:

queueName - Name of the queue

Throws:

Exception - if creation fails

create

public void create(QueueName queueName,
          Properties props)
            throws Exception

Description copied from interface: QueueAdmin

Creates queue if doesn't exist. If queue exists does nothing.

Parameters:

queueName - Name of the queue

props - additional properties

Throws:

Exception - if creation fails

truncate

public void truncate(QueueName queueName)
              throws Exception

Description copied from interface: QueueAdmin

Wipes out queue data.

Parameters:

queueName - Name of the queue

Throws:

Exception - if cleanup fails

clearAllForFlow

public void clearAllForFlow(Id.Flow flowId)
                     throws Exception

Description copied from interface: QueueAdmin

Clears all queues for a flow, for example if the flow is upgraded and old. todo: make this independent of the concept of a flow

Throws:

Exception

getQueueConfigurer

public QueueConfigurer getQueueConfigurer(QueueName queueName)

Description copied from interface: QueueAdmin

Returns a QueueConfigurer for configuring the queue.

dropAllForFlow

public void dropAllForFlow(Id.Flow flowId)
                    throws Exception

Description copied from interface: QueueAdmin

Deletes all queues for a flow, for example if the flow is deleted. todo: make this independent of the concept of a flow

Throws:

Exception

dropAllInNamespace

public void dropAllInNamespace(Id.Namespace namespaceId)
                        throws Exception

Description copied from interface: QueueAdmin

Deletes all queues in a namespace

Parameters:

namespaceId - the namespace to delete flows in

Throws:

Exception

upgrade

public void upgrade()
             throws Exception

Description copied from interface: QueueAdmin

Performs upgrade action for all queues.

Throws:

Exception

getActualTableName

public String getActualTableName(QueueName queueName)

getTableNameForFlow

protected String getTableNameForFlow(Id.Flow flowId)