| Package | Description |
|---|---|
| co.cask.cdap.data2.queue |
API definition for queue for the txds2 system.
|
| 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 | Method and Description |
|---|---|
QueueProducer |
QueueClientFactory.createProducer(QueueName queueName,
QueueMetrics queueMetrics) |
| Modifier and Type | Field and Description |
|---|---|
static QueueMetrics |
QueueMetrics.NOOP_QUEUE_METRICS |
| Constructor and Description |
|---|
AbstractQueueProducer(QueueMetrics queueMetrics,
QueueName queueName) |
| Modifier and Type | Method and Description |
|---|---|
QueueProducer |
HBaseQueueClientFactory.createProducer(QueueName queueName,
QueueMetrics queueMetrics) |
| Constructor and Description |
|---|
HBaseQueueProducer(org.apache.hadoop.hbase.client.HTable hTable,
QueueName queueName,
QueueMetrics queueMetrics,
HBaseQueueStrategy queueStrategy,
Iterable<? extends ConsumerGroupConfig> consumerGroupConfigs) |
| Modifier and Type | Method and Description |
|---|---|
QueueProducer |
InMemoryQueueClientFactory.createProducer(QueueName queueName,
QueueMetrics queueMetrics) |
| Constructor and Description |
|---|
InMemoryQueueProducer(QueueName queueName,
InMemoryQueueService queueService,
QueueMetrics queueMetrics) |
| Modifier and Type | Method and Description |
|---|---|
QueueProducer |
LevelDBQueueClientFactory.createProducer(QueueName queueName,
QueueMetrics queueMetrics) |
QueueProducer |
LevelDBAndInMemoryQueueClientFactory.createProducer(QueueName queueName,
QueueMetrics queueMetrics) |
| Constructor and Description |
|---|
LevelDBQueueProducer(LevelDBTableCore tableCore,
QueueName queueName,
QueueMetrics queueMetrics) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.