| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.stream |
This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
|
| 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 | Method and Description |
|---|---|
protected abstract AbstractStreamFileConsumer.StateScanner |
AbstractStreamFileConsumer.scanStates(byte[] startRow,
byte[] endRow) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractStreamFileConsumer.StateScanner |
HBaseStreamFileConsumer.scanStates(byte[] startRow,
byte[] stopRow) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractStreamFileConsumer.StateScanner |
LevelDBStreamFileConsumer.scanStates(byte[] startRow,
byte[] stopRow) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.