Mark S created AVRO-1744:
----------------------------
Summary: New AvroValueInputFormat class to process Avro messages
without a key.
Key: AVRO-1744
URL: https://issues.apache.org/jira/browse/AVRO-1744
Project: Avro
Issue Type: New Feature
Components: java
Affects Versions: 1.7.7
Reporter: Mark S
My Avro messages do not contain a Key value and as such, there are no Avro
supporting classes to deal with this.
As I was unable to use the following classes,
* org.apache.avro.mapreduce.AvroKeyInputFormat
* org.apache.avro.mapreduce.AvroKeyValueInputFormat
I created the following supporting classes:
*
[AvroValueInputFormat|https://github.com/mark1900/druid-sandbox/blob/master/spark-hdfs-avro-test/src/main/java/test/avro/AvroValueInputFormat.java]
*
[AvroValueRecordReader|https://github.com/mark1900/druid-sandbox/blob/master/spark-hdfs-avro-test/src/main/java/test/avro/AvroValueRecordReader.java]
*
[AvroValueOutputFormat|https://github.com/mark1900/druid-sandbox/blob/master/spark-hdfs-avro-test/src/main/java/test/avro/AvroValueOutputFormat.java]
*
[AvroValueRecordWriter|https://github.com/mark1900/druid-sandbox/blob/master/spark-hdfs-avro-test/src/main/java/test/avro/AvroValueRecordWriter.java]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
