Interface | Description |
---|---|
KinesisDataFetcher.FlinkKinesisProxyFactory |
Factory to create Kinesis proxy instances used by a fetcher.
|
KinesisDataFetcher.FlinkKinesisProxyV2Factory |
Factory to create Kinesis proxy V@ instances used by a fetcher.
|
Class | Description |
---|---|
DynamoDBStreamsDataFetcher<T> |
Dynamodb streams data fetcher.
|
KinesisDataFetcher<T> |
A KinesisDataFetcher is responsible for fetching data from multiple Kinesis shards.
|
ShardConsumer<T> |
Thread that subscribes to the given
RecordPublisher . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.