See: Description
| Interface | Description |
|---|---|
| QueueAdmin | |
| QueueConfigurer |
Provides methods to configure queue.
|
| QueueEvictor |
For performing queue eviction action.
|
| QueueMetrics | |
| QueueScanner |
Interface for queue scan operation.
|
| Class | 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. |
| NoopQueueConfigurer |
A
QueueConfigurer that does nothing. |
| QueueConstants |
Constants for queue implementation in HBase.
|
| QueueConstants.ConfigKeys |
Configuration keys for queues in HBase.
|
| QueueEntryRow |
Holds logic of how queue entry row is constructed
|
| SimpleQueueEntry |
Representing a queue entry fetched from persisted storage.
|
| Enum | Description |
|---|---|
| ConsumerEntryState |
The state of a queue entry with respect to a consumer.
|
| QueueConstants.QueueType |
whether a queue is a queue or a stream.
|
| QueueEntryRow.CanConsume |
Defines if queue entry can be consumed
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.