| 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 |
NoopQueueConfigurer
A
QueueConfigurer that does nothing. |
| Modifier and Type | Method and Description |
|---|---|
QueueConfigurer |
QueueAdmin.getQueueConfigurer(QueueName queueName)
Returns a
QueueConfigurer for configuring the queue. |
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseConsumerStateStore
Class for persisting consumer state per queue consumer.
|
| Modifier and Type | Method and Description |
|---|---|
QueueConfigurer |
HBaseQueueAdmin.getQueueConfigurer(QueueName queueName) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfigurer |
InMemoryQueueAdmin.getQueueConfigurer(QueueName queueName) |
| Modifier and Type | Method and Description |
|---|---|
QueueConfigurer |
LevelDBQueueAdmin.getQueueConfigurer(QueueName queueName) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.