Package | Description |
---|---|
org.apache.flink.connector.kinesis.sink | |
org.apache.flink.connector.kinesis.table | |
org.apache.flink.streaming.connectors.kinesis |
Class and Description |
---|
KinesisStreamsSink
A Kinesis Data Streams (KDS) Sink that performs async requests against a destination stream using
the buffering protocol specified in
AsyncSinkBase . |
KinesisStreamsSinkBuilder
Builder to construct
KinesisStreamsSink . |
KinesisStreamsSinkElementConverter
An implementation of the
ElementConverter that uses the AWS Kinesis SDK v2. |
KinesisStreamsSinkElementConverter.Builder
A builder for the KinesisStreamsSinkElementConverter.
|
PartitionKeyGenerator
This is a serializable function whose
accept() method specifies how to convert from an
input element to the partition key, a string. |
Class and Description |
---|
PartitionKeyGenerator
This is a serializable function whose
accept() method specifies how to convert from an
input element to the partition key, a string. |
Class and Description |
---|
PartitionKeyGenerator
This is a serializable function whose
accept() method specifies how to convert from an
input element to the partition key, a string. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.