| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.queue |
Transaction aware queue implementation.
|
| co.cask.cdap.data2.transaction.queue.hbase |
This package contains an HBase implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.leveldb |
This package contains levelDB implementation of queues.
|
| Modifier and Type | Field and Description |
|---|---|
protected QueueConstants.QueueType |
AbstractQueueAdmin.type |
| Modifier and Type | Method and Description |
|---|---|
static QueueConstants.QueueType |
QueueConstants.QueueType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static QueueConstants.QueueType[] |
QueueConstants.QueueType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Constructor and Description |
|---|
AbstractQueueAdmin(QueueConstants.QueueType type) |
| Modifier and Type | Method and Description |
|---|---|
TableId |
HBaseQueueAdmin.getDataTableId(Id.Flow flowId,
QueueConstants.QueueType queueType) |
TableId |
HBaseQueueAdmin.getDataTableId(QueueName queueName,
QueueConstants.QueueType queueType) |
| Constructor and Description |
|---|
HBaseQueueAdmin(Configuration hConf,
CConfiguration cConf,
LocationFactory locationFactory,
HBaseTableUtil tableUtil,
DatasetFramework datasetFramework,
co.cask.tephra.TransactionExecutorFactory txExecutorFactory,
QueueConstants.QueueType type) |
| Constructor and Description |
|---|
LevelDBQueueAdmin(LevelDBTableService service,
QueueConstants.QueueType type) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.