可以从内存中将 avros 反序列化为 Scala 案例类，但为什么不能从文件中反序列化？记录不能投射到案例类？

Question

我正在尝试使用Salat-Avro来序列化和反序列化Scala用例类。

我可以在内存中进行精细的序列化和反序列化，但我只能序列化到文件；我还不能反序列化表单文件。

为什么我的DatumReader在从文件读取时不能像从流读取一样成功？

[error] (run-main) java.lang.ExceptionInInitializerError
java.lang.ExceptionInInitializerError
at Main.main(salat-avro-example.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:616)
Caused by: java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot be cast to models.Record
at Main$.<init>(salat-avro-example.scala:55)
at Main$.<clinit>(salat-avro-example.scala)
at Main.main(salat-avro-example.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:616)
java.lang.RuntimeException: Nonzero exit code: 1
at scala.sys.package$.error(package.scala:27)
[error] {file:/home/julianpeeters/salat-avro-example/}default-7321ab/compile:run: Nonzero exit code: 1
[error] Total time: 18 s, completed Aug 30, 2012 12:04:01 AM

这是代码：

val obj2 = grater[Record].asObjectFromDataFile(infile)

调用：

lazy val asDatumReader: AvroDatumReader[X] = asGenericDatumReader
lazy val asGenericDatumReader: AvroGenericDatumReader[X] = new AvroGenericDatumReader[X](asAvroSchema)def asObjectFromDataFile(infile: File): X = {
val asDataFileReader: DataFileReader[X] = new DataFileReader[X](infile, asDatumReader)
asDataFileReader.next()

}`

代码也可以在Github.com上看到：Salat-Avro-Example.scala和Salat-Avrro.avrograter.scala

我该如何解决这个问题？谢谢

Answer 1

现在我看到dataFileReader.next返回了一条记录，但字段的值仍然是UTF-8，我需要使用applyValues将所有值解组为scala对象。下面的一些类似于黑客的东西对我有用：

 val objIterator = asDataFileReader.asScala
                                  .iterator
                                  .map(i => asGenericDatumReader.applyValues(i.asInstanceOf[GenericData.Record]).asInstanceOf[X])