How to convert Avro Schema Object to StructType?

[kant111]

How to convert Avro Schema Object to StructType?

[gengliangwang]

Refer to:

spark-avro/src/main/scala/com/databricks/spark/avro/DefaultSource.scala

Line 94 in b04cfe8

SchemaConverters.toSqlType(avroSchema).dataType match {

[kant111]

@gengliangwang Thanks! I code in Java so I had to do something like this. Please let me know if there is any easier way.

    import com.databricks.spark.avro.SchemaConverters;

   // @param schema: Avro Schema
    public static StructType convertSchemaToStructType(Schema schema) {
        StructType structType = new StructType();
        for (Schema.Field field : schema.getFields()) {
            structType.add(field.name(), SchemaConverters.toSqlType(field.schema()).dataType());
        }
        return structType;
    }