Class | Description |
---|---|
KinesisConnectorOptions |
Options for the Kinesis connector.
|
KinesisDynamicSink |
Kinesis-backed
DynamicTableSink . |
KinesisDynamicSource |
Kinesis-backed
ScanTableSource . |
KinesisDynamicTableFactory |
Factory for creating
KinesisDynamicSource and KinesisDynamicSink instances. |
RowDataFieldsKinesisPartitioner |
A
KinesisPartitioner of RowData elements that constructs the partition key from a
list of field names. |
RowDataKinesisDeserializationSchema |
A
KinesisDeserializationSchema adaptor for RowData records that delegates
physical data deserialization to an inner DeserializationSchema and appends requested
metadata to the end of the deserialized RowData record. |
Enum | Description |
---|---|
RowDataKinesisDeserializationSchema.Metadata |
Internal type for enumerating available metadata.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.