code: def spark_dtype(self):
      # Lazy loading pyspark to avoid creating pyspark dependency on data reading code path
      # (currently works only with make_batch_reader). We should move all pyspark related code into a separate module
      import pyspark.sql.types as sql_types
  
      return sql_types.BinaryType()
  
imports: from abc import abstractmethod
  from io import BytesIO
  import numpy
label_desc: Use image node_id 5 for calling the CompressedImageCodec obj's underlying member method code with example usage: obj.spark_dtype() and returns: sql_types