Package org.apache.flink.streaming.connectors.kinesis.table

Class Summary

Class	Description
KinesisDynamicSink	Kinesis-backed DynamicTableSink.
KinesisDynamicSource	Kinesis-backed ScanTableSource.
KinesisDynamicTableFactory	Factory for creating KinesisDynamicSource and KinesisDynamicSink instances.
KinesisOptions	Options for Kinesis tables supported by the {@code CREATE TABLE ...
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 Summary

Enum	Description
RowDataKinesisDeserializationSchema.Metadata	Internal type for enumerating available metadata.