Updated Branches: refs/heads/master 77327bef8 -> 7c536c395
CRUNCH-197: Swap in AvroKey for AvroWrapper in the AvroKeyConverter object. Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/7c536c39 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/7c536c39 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/7c536c39 Branch: refs/heads/master Commit: 7c536c395d6e2d402858b5992a89dfd3168c8114 Parents: 77327be Author: Josh Wills <[email protected]> Authored: Wed Apr 24 16:43:05 2013 -0700 Committer: Josh Wills <[email protected]> Committed: Wed Apr 24 16:43:05 2013 -0700 ---------------------------------------------------------------------- .../apache/crunch/types/avro/AvroKeyConverter.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/7c536c39/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroKeyConverter.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroKeyConverter.java b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroKeyConverter.java index 68b717d..d59e9a9 100644 --- a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroKeyConverter.java +++ b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroKeyConverter.java @@ -17,6 +17,7 @@ */ package org.apache.crunch.types.avro; +import org.apache.avro.mapred.AvroKey; import org.apache.avro.mapred.AvroWrapper; import org.apache.crunch.types.Converter; import org.apache.hadoop.io.NullWritable; @@ -53,7 +54,7 @@ class AvroKeyConverter<K> implements Converter<AvroWrapper<K>, NullWritable, K, private AvroWrapper<K> getWrapper() { if (wrapper == null) { - wrapper = new AvroWrapper<K>(); + wrapper = new AvroKey<K>(); } return wrapper; }
