| Package | Description |
|---|---|
| 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.
|
| co.cask.cdap.data2.transaction.stream.inmemory |
| Class and Description |
|---|
| InMemoryQueue.ConsumerState
The state of a single consumer, gets modified.
|
| InMemoryQueue.Key
Used as the key of each queue item, composed of a transaction id and a sequence number within the transaction.
|
| InMemoryQueueAdmin
admin for queues in memory.
|
| InMemoryQueueService
Maintains all in-memory queues in the system.
|
| Class and Description |
|---|
| InMemoryQueueClientFactory |
| Class and Description |
|---|
| InMemoryQueueService
Maintains all in-memory queues in the system.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.