You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by bi...@apache.org on 2016/12/13 07:54:50 UTC

[4/9] kylin git commit: minor, fix NumberDictionaryForestTest

minor, fix NumberDictionaryForestTest


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

Branch: refs/heads/yang22-cdh5.7
Commit: 9d2d7aef8aa62743452bb537757a92ec50743066
Parents: 740c220
Author: Li Yang <li...@apache.org>
Authored: Sun Dec 11 20:03:22 2016 +0800
Committer: Li Yang <li...@apache.org>
Committed: Sun Dec 11 20:05:47 2016 +0800

----------------------------------------------------------------------
 .../mr/steps/NumberDictionaryForestTest.java    | 35 +++++++-------------
 .../mr/steps/SelfDefineSortableKeyTest.java     |  8 ++---
 2 files changed, 16 insertions(+), 27 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/9d2d7aef/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/NumberDictionaryForestTest.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/NumberDictionaryForestTest.java b/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/NumberDictionaryForestTest.java
index 12105c9..bb10b4a 100644
--- a/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/NumberDictionaryForestTest.java
+++ b/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/NumberDictionaryForestTest.java
@@ -14,7 +14,6 @@ import java.util.Collections;
 import java.util.Comparator;
 import java.util.List;
 import java.util.Random;
-import java.util.UUID;
 
 import org.apache.hadoop.io.Text;
 import org.apache.kylin.common.util.Bytes;
@@ -35,14 +34,13 @@ import org.junit.Test;
 public class NumberDictionaryForestTest {
     @Test
     public void testNumberDictionaryForestLong() {
-        List<String> list = randomLongData(10);
+        List<String> list = randomLongData(100);
         testData(list, TypeFlag.INTEGER_FAMILY_TYPE);
     }
 
     @Test
     public void testNumberDictionaryForestDouble() {
-        List<String> list = randomDoubleData(10);
-
+        List<String> list = randomDoubleData(100);
         testData(list, TypeFlag.DOUBLE_FAMILY_TYPE);
     }
 
@@ -199,23 +197,15 @@ public class NumberDictionaryForestTest {
         Random rand = new Random(System.currentTimeMillis());
         ArrayList<String> list = new ArrayList<>();
         for (int i = 0; i < count; i++) {
-            list.add(rand.nextDouble() + "");
+            String str = rand.nextDouble() + "";
+            if (str.contains("E"))
+                continue;
+            list.add(str);
         }
         list.add("-1");
         return list;
     }
 
-    private List<String> randomStringData(int count) {
-        Random rand = new Random(System.currentTimeMillis());
-        ArrayList<String> list = new ArrayList<>();
-        for (int i = 0; i < count; i++) {
-            list.add(UUID.randomUUID().toString());
-        }
-        list.add("123");
-        list.add("123");
-        return list;
-    }
-
     private ArrayList<SelfDefineSortableKey> createKeyList(List<String> strNumList, byte typeFlag) {
         int partationId = 0;
         ArrayList<SelfDefineSortableKey> keyList = new ArrayList<>();
@@ -237,16 +227,15 @@ public class NumberDictionaryForestTest {
     }
 
     private String printKey(SelfDefineSortableKey key) {
-        byte[] data = key.getText().getBytes();
-        byte[] fieldValue = Bytes.copy(data, 1, data.length - 1);
-        System.out.println("type flag:" + key.getTypeId() + " fieldValue:" + new String(fieldValue));
-        return new String(fieldValue);
+        Text data = key.getText();
+        String fieldValue = Bytes.toString(data.getBytes(), 1, data.getLength() - 1);
+        System.out.println("type flag:" + key.getTypeId() + " fieldValue:" + fieldValue);
+        return fieldValue;
     }
 
     private String getFieldValue(SelfDefineSortableKey key) {
-        byte[] data = key.getText().getBytes();
-        byte[] fieldValue = Bytes.copy(data, 1, data.length - 1);
-        return new String(fieldValue);
+        Text data = key.getText();
+        return Bytes.toString(data.getBytes(), 1, data.getLength() - 1);
     }
 
     private <T> boolean isIncreasedOrder(List<T> list, Comparator<T> comp) {

http://git-wip-us.apache.org/repos/asf/kylin/blob/9d2d7aef/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/SelfDefineSortableKeyTest.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/SelfDefineSortableKeyTest.java b/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/SelfDefineSortableKeyTest.java
index 283a0f5..d71e366 100644
--- a/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/SelfDefineSortableKeyTest.java
+++ b/engine-mr/src/test/java/org/apache/kylin/engine/mr/steps/SelfDefineSortableKeyTest.java
@@ -182,10 +182,10 @@ public class SelfDefineSortableKeyTest {
     }
 
     private String printKey(SelfDefineSortableKey key) {
-        byte[] data = key.getText().getBytes();
-        byte[] fieldValue = Bytes.copy(data, 1, data.length - 1);
-        System.out.println("type flag:" + key.getTypeId() + " fieldValue:" + new String(fieldValue));
-        return new String(fieldValue);
+        Text data = key.getText();
+        String fieldValue = Bytes.toString(data.getBytes(), 1, data.getLength() - 1);
+        System.out.println("type flag:" + key.getTypeId() + " fieldValue:" + fieldValue);
+        return fieldValue;
     }
 
     private <T> boolean isIncreasedOrder(List<T> list, Comparator<T> comp) {