| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.queue.leveldb |
This package contains levelDB implementation of queues.
|
| co.cask.cdap.data2.transaction.stream.leveldb |
This package contains class for stream consumer implementation that uses LevelDB as state store.
|
| Constructor and Description |
|---|
LevelDBQueueEvictor(LevelDBTableCore core,
QueueName queueName,
int numGroups,
Executor executor) |
LevelDBQueueProducer(LevelDBTableCore tableCore,
QueueName queueName,
QueueMetrics queueMetrics) |
| Constructor and Description |
|---|
LevelDBStreamConsumerStateStore(StreamConfig streamConfig,
LevelDBTableCore tableCore) |
LevelDBStreamFileConsumer(CConfiguration cConf,
StreamConfig streamConfig,
ConsumerConfig consumerConfig,
FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
StreamConsumerStateStore stateStore,
StreamConsumerState beginConsumerState,
ReadFilter extraFilter,
LevelDBTableCore tableCore,
Object dbLock) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.