Class | Description |
---|---|
KinesisConnectorOptionsUtil |
Class for handling kinesis table options, including key mapping and validations and property
extraction.
|
KinesisConsumerOptionsUtil |
Class for handling Kinesis Consumer specific table options.
|
KinesisDynamicSource |
Kinesis-backed
ScanTableSource . |
KinesisDynamicTableFactory |
Factory for creating
KinesisDynamicSource . |
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–2024 The Apache Software Foundation. All rights reserved.