如何使用Avro序列化Scala case类？

libraryDependencies += "org.apache.avro" % "avro" % "1.10.2"

{
  "type": "record",
  "name": "User",
  "fields": [
    {"name": "id", "type": "int"},
    {"name": "name", "type": "string"},
    {"name": "email", "type": "string"}
  ]
}

java -jar avro-tools-1.10.2.jar compile schema user.avsc .

import org.apache.avro.Schema
import org.apache.avro.generic.GenericRecord
import org.apache.avro.io.{DatumReader, DatumWriter, Decoder, Encoder}
import org.apache.avro.specific.{SpecificDatumReader, SpecificDatumWriter}
import org.apache.avro.file.{DataFileReader, DataFileWriter}

import com.example.User // 导入生成的Scala类

val user = User.newBuilder()
  .setId(1)
  .setName("John Doe")
  .setEmail("john.doe@example.com")
  .build()

val writer: DatumWriter[GenericRecord] = new SpecificDatumWriter[GenericRecord](user.getSchema)
val dataFileWriter: DataFileWriter[GenericRecord] = new DataFileWriter[GenericRecord](writer)
dataFileWriter.create(user.getSchema, new File("user.avro"))
dataFileWriter.append(user)
dataFileWriter.close()

val reader: DatumReader[GenericRecord] = new SpecificDatumReader[GenericRecord](user.getSchema)
val dataFileReader: DataFileReader[GenericRecord] = new DataFileReader[GenericRecord](new File("user.avro"), reader)
val retrievedUser: User = dataFileReader.next().asInstanceOf[User]
dataFileReader.close()

println(retrievedUser)