Class and Description |
---|
KinesisDataFetcher
A KinesisDataFetcher is responsible for fetching data from multiple Kinesis shards.
|
Class and Description |
---|
KinesisDataFetcher
A KinesisDataFetcher is responsible for fetching data from multiple Kinesis shards.
|
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.
|
ShardConsumer
Thread that subscribes to the given
RecordPublisher . |
Class and Description |
---|
KinesisDataFetcher.FlinkKinesisProxyFactory
Factory to create Kinesis proxy instances used by a fetcher.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.