Interface | Description |
---|---|
KinesisDataFetcher.FlinkKinesisProxyFactory |
Factory to create Kinesis proxy 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 does the actual data pulling from AWS Kinesis shards.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.