| 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.
|
| Constructor and Description |
|---|
AbstractStreamFileConsumerFactory(CConfiguration cConf,
StreamAdmin streamAdmin,
StreamConsumerStateStoreFactory stateStoreFactory) |
FileStreamAdmin(NamespacedLocationFactory namespacedLocationFactory,
CConfiguration cConf,
StreamCoordinatorClient streamCoordinatorClient,
StreamConsumerStateStoreFactory stateStoreFactory,
NotificationFeedManager notificationFeedManager,
UsageRegistry usageRegistry,
LineageWriter lineageWriter,
StreamMetaStore streamMetaStore,
ExploreTableNaming tableNaming,
MetadataStore metadataStore,
ViewAdmin viewAdmin) |
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseStreamConsumerStateStoreFactory
Factory for creating
StreamConsumerStateStore in HBase. |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryStreamConsumerStateStoreFactory
Factory for creating
StreamConsumerStateStore in memory. |
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBStreamConsumerStateStoreFactory
Factory for creating
StreamConsumerStateStore in level db. |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.