You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by gr...@apache.org on 2013/03/25 07:54:14 UTC

git commit: CRUNCH-183 Correct initialization of value PType

Updated Branches:
  refs/heads/master e20cbf089 -> bd72e849f


CRUNCH-183 Correct initialization of value PType


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

Branch: refs/heads/master
Commit: bd72e849f37956c8c050764dda88e18cbc20b37a
Parents: e20cbf0
Author: Gabriel Reid <gr...@apache.org>
Authored: Mon Mar 25 07:15:55 2013 +0100
Committer: Gabriel Reid <gr...@apache.org>
Committed: Mon Mar 25 07:15:55 2013 +0100

----------------------------------------------------------------------
 .../java/org/apache/crunch/lib/SampleUtils.java    |    2 ++
 1 files changed, 2 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/bd72e849/crunch/src/main/java/org/apache/crunch/lib/SampleUtils.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/lib/SampleUtils.java b/crunch/src/main/java/org/apache/crunch/lib/SampleUtils.java
index d1cad35..8769eed 100644
--- a/crunch/src/main/java/org/apache/crunch/lib/SampleUtils.java
+++ b/crunch/src/main/java/org/apache/crunch/lib/SampleUtils.java
@@ -79,6 +79,7 @@ class SampleUtils {
     @Override
     public void initialize() {
       this.reservoirs = Lists.newArrayList();
+      this.valueType.initialize(getConfiguration());
       for (int i = 0; i < sampleSizes.length; i++) {
         reservoirs.add(Maps.<Double, T>newTreeMap());
       }
@@ -137,6 +138,7 @@ class SampleUtils {
       for (int i = 0; i < sampleSizes.length; i++) {
         reservoirs.add(Maps.<Double, T>newTreeMap());
       }
+      this.valueType.initialize(getConfiguration());
     }
     
     @Override