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;
}