You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2013/04/25 01:45:51 UTC

git commit: CRUNCH-197: Swap in AvroKey for AvroWrapper in the AvroKeyConverter object.

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 <jw...@apache.org>
Authored: Wed Apr 24 16:43:05 2013 -0700
Committer: Josh Wills <jw...@apache.org>
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;
   }