0

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-Avro.avrograter.scala

これを修正するにはどうすればよいですか？ありがとう！

4

1 に答える 1

0

これdataFileReader.nextでレコードが返されましたが、フィールドの値はまだUTF-8であり、値をアンマーシャリングして.を使用してscalaオブジェクトに戻す必要がありましたapplyValues。以下のハックなもののようなものが私のために働いた：

 val objIterator = asDataFileReader.asScala
                                  .iterator
                                  .map(i => asGenericDatumReader.applyValues(i.asInstanceOf[GenericData.Record]).asInstanceOf[X])
于 2013-03-25T02:54:06.753 に答える