| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.stream.hbase |
This package contains class for stream consumer implementation that uses HBase as state store.
|
| co.cask.cdap.data2.transaction.stream.leveldb |
This package contains class for stream consumer implementation that uses LevelDB as state store.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseStreamFileConsumerFactory
A
StreamConsumerFactory that reads from stream file
and uses HBase as the store for consumer process states. |
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBStreamFileConsumerFactory
A
StreamConsumerFactory that reads from stream file
and uses LevelDB as the store for consumer process states. |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.