| 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.
|
| Class and Description |
|---|
| QueueMetrics |
| Class and Description |
|---|
| ConsumerEntryState
The state of a queue entry with respect to a consumer.
|
| QueueAdmin |
| QueueConfigurer
Provides methods to configure queue.
|
| QueueConstants.QueueType
whether a queue is a queue or a stream.
|
| QueueEntryRow.CanConsume
Defines if queue entry can be consumed
|
| QueueEvictor
For performing queue eviction action.
|
| QueueMetrics |
| QueueScanner
Interface for queue scan operation.
|
| Class and Description |
|---|
| AbstractQueueAdmin
Common implementation of table-based QueueAdmin
|
| AbstractQueueProducer
Abstract base class for
QueueProducer that emits enqueue metrics post commit. |
| QueueAdmin |
| QueueConfigurer
Provides methods to configure queue.
|
| QueueConstants.QueueType
whether a queue is a queue or a stream.
|
| QueueMetrics |
| QueueScanner
Interface for queue scan operation.
|
| Class and Description |
|---|
| AbstractQueueProducer
Abstract base class for
QueueProducer that emits enqueue metrics post commit. |
| QueueAdmin |
| QueueConfigurer
Provides methods to configure queue.
|
| QueueMetrics |
| Class and Description |
|---|
| AbstractQueueAdmin
Common implementation of table-based QueueAdmin
|
| AbstractQueueConsumer
Common queue consumer for persisting engines such as HBase and LevelDB.
|
| AbstractQueueProducer
Abstract base class for
QueueProducer that emits enqueue metrics post commit. |
| QueueAdmin |
| QueueConfigurer
Provides methods to configure queue.
|
| QueueConstants.QueueType
whether a queue is a queue or a stream.
|
| QueueEvictor
For performing queue eviction action.
|
| QueueMetrics |
| QueueScanner
Interface for queue scan operation.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.