code: def __init__(self, writer_schema=None):
      super().__init__(writer_schema=writer_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 FlinkAvroDatumWriter object from inherited base classes: DatumWriter with example: obj = FlinkAvroDatumWriter(writer_schema)