| 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.inmemory |
This package contains in memory implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.leveldb |
This package contains levelDB implementation of queues.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractQueueAdmin
Common implementation of table-based QueueAdmin
|
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseQueueAdmin
admin for queues in hbase.
|
| Constructor and Description |
|---|
HBaseQueueClientFactory(CConfiguration cConf,
Configuration hConf,
HBaseTableUtil hBaseTableUtil,
QueueAdmin queueAdmin,
co.cask.tephra.TransactionExecutorFactory txExecutorFactory) |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryQueueAdmin
admin for queues in memory.
|
class |
InMemoryStreamAdmin
admin for queues in memory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBQueueAdmin
admin for queues in leveldb.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.