class_docstr: 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.
class_docstr_tok: ["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","."]
code: def __init__(self, j_kinesis_deserialization_schema):
      self._j_kinesis_deserialization_schema = (
          j_kinesis_deserialization_schema
      )
  
imports: from typing import Dict, Union, List
  from pyflink.common import SerializationSchema, DeserializationSchema, AssignerWithPeriodicWatermarksWrapper
  from pyflink.datastream.functions import SourceFunction
  from pyflink.datastream.connectors import Sink
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 1 to create a new KinesisDeserializationSchema object from inherited base classes: object with example: obj = KinesisDeserializationSchema(j_kinesis_deserialization_schema)