class_docstr: Flink-customized datum reader to parse composite data structure, to fit with changed basic type
  serialization in FlinkAvroDecoder.
class_docstr_tok: ["Flink-customized","datum","reader","to","parse","composite","data","structure",",","to","fit","with","changed","basic","type","serialization","in","FlinkAvroDecoder","."]
code: def __init__(self, writer_schema=None, reader_schema=None):
      super().__init__(writer_schema, reader_schema)
  
imports: import struct
  from avro.io import AvroTypeException, BinaryDecoder, BinaryEncoder, DatumReader, DatumWriter, SchemaResolutionException, Validate
label_desc: Use image node_id 1 to create a new FlinkAvroDatumReader object from inherited base classes: DatumReader with example: obj = FlinkAvroDatumReader(writer_schema, reader_schema)