crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject crunch git commit: CRUNCH-514: Initialize delegate MapFns inside of AvroDerivedValueDeepCopier
Date Sat, 25 Apr 2015 17:18:35 GMT
Repository: crunch
Updated Branches:
  refs/heads/master ba7a3477c -> a3761da72


CRUNCH-514: Initialize delegate MapFns inside of AvroDerivedValueDeepCopier


Project: http://git-wip-us.apache.org/repos/asf/crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/a3761da7
Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/a3761da7
Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/a3761da7

Branch: refs/heads/master
Commit: a3761da72503ee209b487d831178d234281ac332
Parents: ba7a347
Author: Josh Wills <jwills@apache.org>
Authored: Sat Apr 25 10:11:04 2015 -0700
Committer: Josh Wills <jwills@apache.org>
Committed: Sat Apr 25 10:11:04 2015 -0700

----------------------------------------------------------------------
 .../org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/a3761da7/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java
----------------------------------------------------------------------
diff --git a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java
b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java
index e872dd2..f1bd8e2 100644
--- a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java
+++ b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java
@@ -39,6 +39,10 @@ public class AvroDerivedValueDeepCopier<T, S> implements DeepCopier
{
 
   @Override
   public void initialize(Configuration conf) {
+    derivedToAvroFn.setConfiguration(conf);
+    derivedToAvroFn.initialize();
+    avroToDerivedFn.setConfiguration(conf);
+    avroToDerivedFn.initialize();
     avroBaseType.initialize(conf);
   }
 


Mime
View raw message