| 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.inmemory | |
| 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 |
AbstractStreamFileConsumer
A
StreamConsumer that read events from stream file and uses a table to store consumer states. |
class |
ForwardingStreamConsumer
A
StreamConsumer that forwards every methods to another StreamConsumer. |
class |
QueueToStreamConsumer
An adapter from Queue2Consumer to StreamConsumer.
|
| Modifier and Type | Method and Description |
|---|---|
StreamConsumer |
StreamConsumerFactory.create(Id.Stream streamId,
String namespace,
ConsumerConfig consumerConfig)
Creates a
StreamConsumer. |
StreamConsumer |
AbstractStreamFileConsumerFactory.create(Id.Stream streamId,
String namespace,
ConsumerConfig consumerConfig) |
protected abstract StreamConsumer |
AbstractStreamFileConsumerFactory.create(TableId tableId,
StreamConfig streamConfig,
ConsumerConfig consumerConfig,
StreamConsumerStateStore stateStore,
StreamConsumerState beginConsumerState,
FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
ReadFilter extraFilter)
Creates a
StreamConsumer. |
| Constructor and Description |
|---|
ForwardingStreamConsumer(StreamConsumer delegate) |
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseStreamFileConsumer
A
StreamConsumer that uses HTable to store consuming states. |
| Modifier and Type | Method and Description |
|---|---|
protected StreamConsumer |
HBaseStreamFileConsumerFactory.create(TableId tableId,
StreamConfig streamConfig,
ConsumerConfig consumerConfig,
StreamConsumerStateStore stateStore,
StreamConsumerState beginConsumerState,
FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
ReadFilter extraFilter) |
| Modifier and Type | Method and Description |
|---|---|
StreamConsumer |
InMemoryStreamConsumerFactory.create(Id.Stream streamId,
String namespace,
ConsumerConfig consumerConfig) |
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBStreamFileConsumer |
| Modifier and Type | Method and Description |
|---|---|
protected StreamConsumer |
LevelDBStreamFileConsumerFactory.create(TableId tableId,
StreamConfig streamConfig,
ConsumerConfig consumerConfig,
StreamConsumerStateStore stateStore,
StreamConsumerState beginConsumerState,
FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
ReadFilter extraFilter) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.