| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.stream |
This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ConsumerStateStore<S extends ConsumerState<T>,T>
Represents storage for
ConsumerState. |
| Modifier and Type | Class and Description |
|---|---|
class |
StreamConsumerState
Represents the consumer state of a
StreamConsumer. |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.