Uses of Class
org.apache.flink.streaming.connectors.kinesis.table.RowDataKinesisDeserializationSchema.Metadata

Packages that use RowDataKinesisDeserializationSchema.Metadata

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

Uses of RowDataKinesisDeserializationSchema.Metadata in org.apache.flink.streaming.connectors.kinesis.table

Methods in org.apache.flink.streaming.connectors.kinesis.table that return RowDataKinesisDeserializationSchema.Metadata

Modifier and Type	Method and Description
static RowDataKinesisDeserializationSchema.Metadata	RowDataKinesisDeserializationSchema.Metadata.of(String fieldName)
static RowDataKinesisDeserializationSchema.Metadata	RowDataKinesisDeserializationSchema.Metadata.valueOf(String name) Returns the enum constant of this type with the specified name.
static RowDataKinesisDeserializationSchema.Metadata[]	RowDataKinesisDeserializationSchema.Metadata.values() Returns an array containing the constants of this enum type, in the order they are declared.

Constructor parameters in org.apache.flink.streaming.connectors.kinesis.table with type arguments of type RowDataKinesisDeserializationSchema.Metadata

Constructor and Description
KinesisDynamicSource(DataType physicalDataType, String stream, Properties consumerProperties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType, List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields)
RowDataKinesisDeserializationSchema(DeserializationSchema<RowData> physicalDeserializer, TypeInformation<RowData> producedTypeInfo, List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields)