| Package | Description |
|---|---|
| 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 |
HBaseQueueProducer
A
QueueProducer that uses HBase as the storage for queue entries and consumers
states. |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryQueueProducer
Producer for an in-memory queue.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBQueueProducer
A queue producer for levelDB.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.