Skip to content

Instantly share code, notes, and snippets.

@baunz
baunz / patch
Created January 30, 2013 22:32
fix for multiple outputs
Index: mapred/src/main/java/org/apache/avro/mapreduce/AvroMultipleOutputs.java
===================================================================
--- mapred/src/main/java/org/apache/avro/mapreduce/AvroMultipleOutputs.java (revision 1440190)
+++ mapred/src/main/java/org/apache/avro/mapreduce/AvroMultipleOutputs.java (working copy)
@@ -133,6 +133,8 @@
private static final String COUNTERS_ENABLED =
"avro.mapreduce.multipleoutputs.counters";
+ private static final String KEY_SCHEMA = ".keySchema";
+ private static final String VALUE_SCHEMA = ".valueSchema";
@baunz
baunz / AvroRecordReader.java
Created November 2, 2012 06:06
Avro Input Job
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0