http://git-wip-us.apache.org/repos/asf/kylin/blob/386a2ff7/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITDoggedCubeBuilderTest.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITDoggedCubeBuilderTest.java b/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITDoggedCubeBuilderTest.java index 1e10d79..0338da8 100644 --- a/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITDoggedCubeBuilderTest.java +++ b/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITDoggedCubeBuilderTest.java @@ -26,7 +26,6 @@ import java.io.FileInputStream; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; -import java.util.List; import java.util.Map; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; @@ -83,7 +82,7 @@ public class ITDoggedCubeBuilderTest extends LocalFileMetadataTestCase { @Test public void test() throws Exception { - ArrayBlockingQueue<List<String>> queue = new ArrayBlockingQueue<List<String>>(1000); + ArrayBlockingQueue<String[]> queue = new ArrayBlockingQueue<String[]>(1000); ExecutorService executorService = Executors.newSingleThreadExecutor(); long randSeed = System.currentTimeMillis();
http://git-wip-us.apache.org/repos/asf/kylin/blob/386a2ff7/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITInMemCubeBuilderTest.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITInMemCubeBuilderTest.java b/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITInMemCubeBuilderTest.java index 49d267a..ad754cd 100644 --- a/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITInMemCubeBuilderTest.java +++ b/kylin-it/src/test/java/org/apache/kylin/cube/inmemcubing/ITInMemCubeBuilderTest.java @@ -113,7 +113,7 @@ public class ITInMemCubeBuilderTest extends LocalFileMetadataTestCase { //DoggedCubeBuilder cubeBuilder = new DoggedCubeBuilder(cube.getDescriptor(), dictionaryMap); cubeBuilder.setConcurrentThreads(nThreads); - ArrayBlockingQueue<List<String>> queue = new ArrayBlockingQueue<List<String>>(1000); + ArrayBlockingQueue<String[]> queue = new ArrayBlockingQueue<String[]>(1000); ExecutorService executorService = Executors.newSingleThreadExecutor(); try { @@ -144,11 +144,13 @@ public class ITInMemCubeBuilderTest extends LocalFileMetadataTestCase { } } - static void feedData(final CubeInstance cube, final String flatTable, ArrayBlockingQueue<List<String>> queue, int count) throws IOException, InterruptedException { + static void feedData(final CubeInstance cube, final String flatTable, ArrayBlockingQueue<String[]> queue, int count) + throws IOException, InterruptedException { feedData(cube, flatTable, queue, count, 0); } - static void feedData(final CubeInstance cube, final String flatTable, ArrayBlockingQueue<List<String>> queue, int count, long randSeed) throws IOException, InterruptedException { + static void feedData(final CubeInstance cube, final String flatTable, ArrayBlockingQueue<String[]> queue, int count, + long randSeed) throws IOException, InterruptedException { IJoinedFlatTableDesc flatDesc = EngineFactory.getJoinedFlatTableDesc(cube.getDescriptor()); int nColumns = flatDesc.getAllColumns().size(); @@ -177,14 +179,14 @@ public class ITInMemCubeBuilderTest extends LocalFileMetadataTestCase { // output with random data for (; count > 0; count--) { - ArrayList<String> row = new ArrayList<String>(nColumns); + String[] row = new String[nColumns]; for (int i = 0; i < nColumns; i++) { String[] candidates = distincts.get(i); - row.add(candidates[rand.nextInt(candidates.length)]); + row[i] = candidates[rand.nextInt(candidates.length)]; } queue.put(row); } - queue.put(new ArrayList<String>(0)); + queue.put(InputConverterUnitForRawData.EMPTY_ROW); } static Map<TblColRef, Dictionary<String>> getDictionaryMap(CubeInstance cube, String flatTable) throws IOException {
