| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.queue.inmemory |
This package contains in memory implementation of queues.
|
| co.cask.cdap.data2.transaction.stream.inmemory |
| Modifier and Type | Field and Description |
|---|---|
protected InMemoryQueueService |
InMemoryQueueAdmin.queueService |
| Constructor and Description |
|---|
InMemoryQueueAdmin(InMemoryQueueService queueService) |
InMemoryQueueClientFactory(InMemoryQueueService queueService) |
InMemoryQueueConsumer(QueueName queueName,
ConsumerConfig config,
int numGroups,
InMemoryQueueService queueService) |
InMemoryQueueProducer(QueueName queueName,
InMemoryQueueService queueService,
QueueMetrics queueMetrics) |
InMemoryStreamAdmin(InMemoryQueueService queueService,
UsageRegistry usageRegistry,
LineageWriter lineageWriter,
StreamMetaStore streamMetaStore,
MetadataStore metadataStore,
ViewAdmin viewAdmin) |
| Constructor and Description |
|---|
InMemoryStreamConsumerFactory(QueueClientFactory queueClientFactory,
InMemoryQueueService queueService) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.