[12/13] kylin git commit: KYLIN-1356 move all it to a seprate module
http://git-wip-us.apache.org/repos/asf/kylin/blob/59943fee/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveSourceTableLoaderTest.java -- diff --git a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveSourceTableLoaderTest.java b/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveSourceTableLoaderTest.java deleted file mode 100644 index 23780cf..000 --- a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveSourceTableLoaderTest.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ - -package org.apache.kylin.source.hive; - -import static org.junit.Assert.assertTrue; - -import java.io.IOException; -import java.util.Set; - -import org.apache.kylin.common.KylinConfig; -import org.apache.kylin.storage.hbase.steps.HBaseMetadataTestCase; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; - -public class ITHiveSourceTableLoaderTest extends HBaseMetadataTestCase { - -@Before -public void setup() throws Exception { -super.createTestMetadata(); -} - -@After -public void after() throws Exception { -super.cleanupTestMetadata(); -} - -@Test -public void test() throws IOException { -KylinConfig config = getTestConfig(); -String[] toLoad = new String[] { "DEFAULT.TEST_KYLIN_FACT", "EDW.TEST_CAL_DT" }; -Set loaded = HiveSourceTableLoader.reloadHiveTables(toLoad, config); - -assertTrue(loaded.size() == toLoad.length); -for (String str : toLoad) -assertTrue(loaded.contains(str)); -} - -} http://git-wip-us.apache.org/repos/asf/kylin/blob/59943fee/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java -- diff --git a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java b/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java deleted file mode 100644 index 57c0be3..000 --- a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java +++ /dev/null @@ -1,49 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ - -package org.apache.kylin.source.hive; - -import java.io.IOException; - -import org.apache.kylin.storage.hbase.steps.HBaseMetadataTestCase; -import org.junit.Assert; -import org.junit.Test; - -/** - * This test case need the hive runtime; Please run it with sandbox; - * @author shaoshi - * - * It is in the exclude list of default profile in pom.xml - */ -public class ITHiveTableReaderTest extends HBaseMetadataTestCase { - -@Test -public void test() throws IOException { -HiveTableReader reader = new HiveTableReader("default", "test_kylin_fact"); -int rowNumber = 0; -while (reader.next()) { -String[] row = reader.getRow(); -Assert.assertEquals(9, row.length); -//System.out.println(ArrayUtils.toString(row)); -rowNumber++; -} - -reader.close(); -Assert.assertEquals(1, rowNumber); -} -} http://git-wip-us.apache.org/repos/asf/kylin/blob/59943fee/assembly/src/test/java/org/apache/kylin/source/hive/ITSnapshotManagerTest.java -- diff --git
[12/13] kylin git commit: KYLIN-1356 move all it to a seprate module
http://git-wip-us.apache.org/repos/asf/kylin/blob/7f08dab5/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java -- diff --git a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java b/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java deleted file mode 100644 index 57c0be3..000 --- a/assembly/src/test/java/org/apache/kylin/source/hive/ITHiveTableReaderTest.java +++ /dev/null @@ -1,49 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ - -package org.apache.kylin.source.hive; - -import java.io.IOException; - -import org.apache.kylin.storage.hbase.steps.HBaseMetadataTestCase; -import org.junit.Assert; -import org.junit.Test; - -/** - * This test case need the hive runtime; Please run it with sandbox; - * @author shaoshi - * - * It is in the exclude list of default profile in pom.xml - */ -public class ITHiveTableReaderTest extends HBaseMetadataTestCase { - -@Test -public void test() throws IOException { -HiveTableReader reader = new HiveTableReader("default", "test_kylin_fact"); -int rowNumber = 0; -while (reader.next()) { -String[] row = reader.getRow(); -Assert.assertEquals(9, row.length); -//System.out.println(ArrayUtils.toString(row)); -rowNumber++; -} - -reader.close(); -Assert.assertEquals(1, rowNumber); -} -} http://git-wip-us.apache.org/repos/asf/kylin/blob/7f08dab5/assembly/src/test/java/org/apache/kylin/source/hive/ITSnapshotManagerTest.java -- diff --git a/assembly/src/test/java/org/apache/kylin/source/hive/ITSnapshotManagerTest.java b/assembly/src/test/java/org/apache/kylin/source/hive/ITSnapshotManagerTest.java deleted file mode 100644 index 0df632a..000 --- a/assembly/src/test/java/org/apache/kylin/source/hive/ITSnapshotManagerTest.java +++ /dev/null @@ -1,83 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ - -package org.apache.kylin.source.hive; - -import static org.junit.Assert.assertArrayEquals; -import static org.junit.Assert.assertEquals; - -import org.apache.kylin.dict.lookup.SnapshotManager; -import org.apache.kylin.dict.lookup.SnapshotTable; -import org.apache.kylin.metadata.MetadataManager; -import org.apache.kylin.metadata.model.TableDesc; -import org.apache.kylin.source.ReadableTable; -import org.apache.kylin.source.ReadableTable.TableReader; -import org.apache.kylin.source.SourceFactory; -import org.apache.kylin.storage.hbase.steps.HBaseMetadataTestCase; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; - -/** - * @author yangli9 - * - */ -public class ITSnapshotManagerTest extends HBaseMetadataTestCase { - -SnapshotManager snapshotMgr; - -@Before -public void setup() throws Exception { -createTestMetadata(); -snapshotMgr = SnapshotManager.getInstance(getTestConfig()); -} - -@After -public void after() throws Exception { -cleanupTestMetadata(); -} - -@Test -public void basicTest() throws Exception { -String tableName = "EDW.TEST_SITES"; -TableDesc tableDesc = MetadataManager.getInstance(getTestConfig()).getTableDesc(tableName); -ReadableTable hiveTable = SourceFactory.createReadableTable(tableDesc); -