pyflink.datastream.connectors.kinesis.KinesisDeserializationSchema

class KinesisDeserializationSchema(j_kinesis_deserialization_schema)

This is a deserialization schema specific for the Flink Kinesis Consumer. Different from the basic DeserializationSchema, this schema offers additional Kinesis-specific information about the record that may be useful to the user application.