crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject git commit: CRUNCH-197: Swap in AvroKey for AvroWrapper in the AvroKeyConverter object.
Date Wed, 24 Apr 2013 23:45:51 GMT
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 <jwills@apache.org>
Authored: Wed Apr 24 16:43:05 2013 -0700
Committer: Josh Wills <jwills@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;
   }


Mime
View raw message