Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis.internals | |
org.apache.flink.streaming.connectors.kinesis.proxy |
Modifier and Type | Method and Description |
---|---|
KinesisProxyInterface |
KinesisDataFetcher.FlinkKinesisProxyFactory.create(Properties configProps) |
Modifier and Type | Class and Description |
---|---|
class |
DynamoDBStreamsProxy
DynamoDB streams proxy: interface interacting with the DynamoDB streams.
|
class |
KinesisProxy
Kinesis proxy implementation - a utility class that is used as a proxy to make calls to AWS
Kinesis for several functions, such as getting a list of shards and fetching a batch of data
records starting from a specified record sequence number.
|
Modifier and Type | Method and Description |
---|---|
static KinesisProxyInterface |
KinesisProxy.create(Properties configProps)
Creates a Kinesis proxy.
|
static KinesisProxyInterface |
DynamoDBStreamsProxy.create(Properties configProps)
Creates a DynamoDB streams proxy.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.