spark_json_to_avro.py