crunch-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Whiting <>
Subject MemPipeline doesn't support writing Avro records via reflection.
Date Wed, 20 Nov 2013 15:00:23 GMT
It seems that this was half implemented but never finished, but I needed it
to create some test data to run through a cluster MapReduce test. The
current implementation correctly reflects the schema, but then uses a
GenericDatumWriter to try and write the record, causing a
ClassCastException. The correct way would be to get a ReflectDatumWriter
from the ReflectDataFactory.

I've attached a tiny patch that should fix it.

  • Unnamed multipart/mixed (inline, None, 0 bytes)
View raw message