org.apache.flink.streaming.connectors.kinesis.table
Classes
KinesisConnectorOptions
KinesisDynamicSink
KinesisDynamicSource
KinesisDynamicTableFactory
RowDataFieldsKinesisPartitioner
RowDataKinesisDeserializationSchema
Enums
RowDataKinesisDeserializationSchema.Metadata