[CARBONDATA-1346] SDV cluster tests New module spark-common-cluster-test has been added under integration module. Framework to run the tests in cluster is added here. And all the existing tests are migrated here.Following activities are done part of this PR.
This closes #1169 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/14624953 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/14624953 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/14624953 Branch: refs/heads/master Commit: 1462495372f9c3f39852ab1a2797e72c714c3a79 Parents: 946e4ce Author: ravipesala <[email protected]> Authored: Wed May 17 21:14:05 2017 +0530 Committer: chenliang613 <[email protected]> Committed: Tue Aug 1 13:59:49 2017 +0800 ---------------------------------------------------------------------- core/pom.xml | 22 +- .../core/constants/CarbonCommonConstants.java | 2 - .../core/indexstore/DataMapStoreManager.java | 2 +- .../carbondata/core/util/CarbonProperties.java | 12 + integration/spark-common-cluster-test/pom.xml | 235 + .../src/test/resources/hdfs-site.xml | 24 + .../src/test/resources/testdatafileslist.txt | 230 + .../sdv/generated/AlterTableTestCase.scala | 1090 ++ .../sdv/generated/BadRecordTestCase.scala | 203 + .../sdv/generated/BatchSortLoad1TestCase.scala | 311 + .../sdv/generated/BatchSortLoad2TestCase.scala | 294 + .../sdv/generated/BatchSortQueryTestCase.scala | 1259 ++ .../sdv/generated/ColumndictTestCase.scala | 528 + .../sdv/generated/DataLoadingTestCase.scala | 1476 ++ .../sdv/generated/DataLoadingV3TestCase.scala | 385 + .../sdv/generated/InvertedindexTestCase.scala | 1048 ++ .../sdv/generated/OffheapQuery1TestCase.scala | 1275 ++ .../sdv/generated/OffheapQuery2TestCase.scala | 1276 ++ .../sdv/generated/OffheapSort1TestCase.scala | 239 + .../sdv/generated/OffheapSort2TestCase.scala | 241 + .../sdv/generated/PartitionTestCase.scala | 553 + .../sdv/generated/QueriesBVATestCase.scala | 12328 +++++++++++++++ .../sdv/generated/QueriesBasicTestCase.scala | 13884 +++++++++++++++++ .../generated/QueriesCompactionTestCase.scala | 6809 ++++++++ .../QueriesExcludeDictionaryTestCase.scala | 5044 ++++++ .../QueriesIncludeDictionaryTestCase.scala | 4686 ++++++ .../sdv/generated/QueriesNormalTestCase.scala | 504 + .../generated/QueriesRangeFilterTestCase.scala | 691 + .../QueriesSparkBlockDistTestCase.scala | 281 + .../sdv/generated/ShowLoadsTestCase.scala | 63 + .../sdv/generated/SinglepassTestCase.scala | 783 + .../sdv/generated/SortColumnTestCase.scala | 465 + .../sdv/generated/TimestamptypesTestCase.scala | 87 + .../sdv/generated/V3offheapvectorTestCase.scala | 350 + .../cluster/sdv/generated/Vector1TestCase.scala | 645 + .../cluster/sdv/generated/Vector2TestCase.scala | 625 + .../cluster/sdv/suite/SDVSuites.scala | 125 + .../spark/sql/common/util/CarbonFunSuite.scala | 47 + .../apache/spark/sql/common/util/PlanTest.scala | 59 + .../spark/sql/common/util/QueryTest.scala | 199 + .../org/apache/spark/sql/common/util/Tags.scala | 25 + integration/spark-common-test/pom.xml | 7 + .../TestDataLoadWithColumnsMoreThanSchema.scala | 4 +- .../DateDataTypeDirectDictionaryTest.scala | 6 +- ...TypeDirectDictionaryWithNoDictTestCase.scala | 6 +- .../DateDataTypeNullDataTest.scala | 6 +- ...estampDataTypeDirectDictionaryTestCase.scala | 6 +- ...TypeDirectDictionaryWithNoDictTestCase.scala | 6 +- .../TimestampDataTypeNullDataTest.scala | 6 +- .../TestAllDataTypeForPartitionTable.scala | 4 +- .../TestCompactionForPartitionTable.scala | 2 - .../partition/TestDDLForPartitionTable.scala | 2 - .../TestDataLoadingForPartitionTable.scala | 2 - .../partition/TestQueryForPartitionTable.scala | 2 - .../org/apache/spark/sql/common/util/Tags.scala | 25 + integration/spark-common/pom.xml | 35 + .../apache/carbondata/spark/rdd/CarbonRDD.scala | 6 +- .../sql/test/ResourceRegisterAndCopier.scala | 113 + .../spark/sql/test/TestQueryExecutor.scala | 99 +- integration/spark/pom.xml | 8 + .../spark/sql/test/SparkTestQueryExecutor.scala | 3 +- integration/spark2/pom.xml | 9 + .../spark/sql/hive/CarbonFileMetastore.scala | 2 + .../spark/sql/hive/CarbonHiveMetaStore.scala | 2 + .../sql/test/Spark2TestQueryExecutor.scala | 29 +- .../vectorreader/AddColumnTestCases.scala | 5 + pom.xml | 51 + 67 files changed, 58807 insertions(+), 44 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/core/pom.xml ---------------------------------------------------------------------- diff --git a/core/pom.xml b/core/pom.xml index 49587bc..1c6d0c4 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -49,11 +49,11 @@ <artifactId>gson</artifactId> <version>2.3.1</version> </dependency> - <dependency> - <groupId>io.netty</groupId> - <artifactId>netty-all</artifactId> - <version>4.1.8.Final</version> - </dependency> + <!--<dependency>--> + <!--<groupId>io.netty</groupId>--> + <!--<artifactId>netty-all</artifactId>--> + <!--<version>4.1.8.Final</version>--> + <!--</dependency>--> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> @@ -88,6 +88,10 @@ <groupId>jline</groupId> <artifactId>jline</artifactId> </exclusion> + <exclusion> + <groupId>io.netty</groupId> + <artifactId>netty</artifactId> + </exclusion> </exclusions> </dependency> </dependencies> @@ -113,5 +117,13 @@ </plugin> </plugins> </build> + <profiles> + <profile> + <id>sdvtest</id> + <properties> + <maven.test.skip>true</maven.test.skip> + </properties> + </profile> + </profiles> </project> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/core/src/main/java/org/apache/carbondata/core/constants/CarbonCommonConstants.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/constants/CarbonCommonConstants.java b/core/src/main/java/org/apache/carbondata/core/constants/CarbonCommonConstants.java index f2e59ab..c9f9373 100644 --- a/core/src/main/java/org/apache/carbondata/core/constants/CarbonCommonConstants.java +++ b/core/src/main/java/org/apache/carbondata/core/constants/CarbonCommonConstants.java @@ -1166,8 +1166,6 @@ public final class CarbonCommonConstants { */ @CarbonProperty public static final String LOAD_SORT_SCOPE = "carbon.load.sort.scope"; - @CarbonProperty - public static final String LOAD_USE_BATCH_SORT = "carbon.load.use.batch.sort"; /** * If set to BATCH_SORT, the sorting scope is smaller and more index tree will be created, http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/core/src/main/java/org/apache/carbondata/core/indexstore/DataMapStoreManager.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/indexstore/DataMapStoreManager.java b/core/src/main/java/org/apache/carbondata/core/indexstore/DataMapStoreManager.java index 1a36187..1664a6a 100644 --- a/core/src/main/java/org/apache/carbondata/core/indexstore/DataMapStoreManager.java +++ b/core/src/main/java/org/apache/carbondata/core/indexstore/DataMapStoreManager.java @@ -119,7 +119,7 @@ public final class DataMapStoreManager { int i = 0; for (TableDataMap tableDataMap: tableDataMaps) { if (tableDataMap != null && dataMapName.equals(tableDataMap.getDataMapName())) { - tableDataMap.clear(new ArrayList<String>()); + tableDataMap.clear(); tableDataMaps.remove(i); break; } http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java b/core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java index 842543e..12776de 100644 --- a/core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java +++ b/core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java @@ -22,7 +22,9 @@ import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.lang.reflect.Field; +import java.util.HashMap; import java.util.HashSet; +import java.util.Map; import java.util.Properties; import java.util.Set; @@ -55,6 +57,11 @@ public final class CarbonProperties { private Set<String> propertySet = new HashSet<String>(); /** + * It is purely for testing + */ + private Map<String, String> addedProperty = new HashMap<>(); + + /** * Private constructor this will call load properties method to load all the * carbon properties in memory. */ @@ -572,6 +579,7 @@ public final class CarbonProperties { */ public CarbonProperties addProperty(String key, String value) { carbonProperties.setProperty(key, value); + addedProperty.put(key, value); return this; } @@ -875,4 +883,8 @@ public final class CarbonProperties { public boolean isCarbonProperty(String key) { return propertySet.contains(key); } + + public Map<String, String> getAddedProperty() { + return addedProperty; + } } http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/integration/spark-common-cluster-test/pom.xml ---------------------------------------------------------------------- diff --git a/integration/spark-common-cluster-test/pom.xml b/integration/spark-common-cluster-test/pom.xml new file mode 100644 index 0000000..837cc99 --- /dev/null +++ b/integration/spark-common-cluster-test/pom.xml @@ -0,0 +1,235 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + 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. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.apache.carbondata</groupId> + <artifactId>carbondata-parent</artifactId> + <version>1.2.0-SNAPSHOT</version> + <relativePath>../../pom.xml</relativePath> + </parent> + + <artifactId>carbondata-spark-common-cluster-test</artifactId> + <name>Apache CarbonData :: Spark Common Cluster Test</name> + + <properties> + <dev.path>${basedir}/../../dev</dev.path> + </properties> + + <dependencies> + <dependency> + <groupId>org.apache.carbondata</groupId> + <artifactId>carbondata-spark-common</artifactId> + <version>${project.version}</version> + <scope>test</scope> + <exclusions> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-hive-thriftserver_2.10</artifactId> + </exclusion> + </exclusions> + </dependency> + <dependency> + <groupId>org.apache.spark</groupId> + <artifactId>spark-hive-thriftserver_${scala.binary.version}</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + </dependency> + <dependency> + <groupId>org.scalatest</groupId> + <artifactId>scalatest_${scala.binary.version}</artifactId> + <version>2.2.1</version> + <scope>test</scope> + </dependency> + </dependencies> + + <build> + <testSourceDirectory>src/test/scala</testSourceDirectory> + <resources> + <resource> + <directory>src/resources</directory> + </resource> + <resource> + <directory>.</directory> + <includes> + <include>CARBON_SPARK_INTERFACELogResource.properties</include> + </includes> + </resource> + </resources> + <plugins> + <plugin> + <groupId>org.scala-tools</groupId> + <artifactId>maven-scala-plugin</artifactId> + <version>2.15.2</version> + <executions> + <execution> + <id>compile</id> + <goals> + <goal>compile</goal> + </goals> + <phase>compile</phase> + </execution> + <execution> + <id>testCompile</id> + <goals> + <goal>testCompile</goal> + </goals> + <phase>test</phase> + </execution> + <execution> + <phase>process-resources</phase> + <goals> + <goal>compile</goal> + </goals> + </execution> + </executions> + </plugin> + <plugin> + <artifactId>maven-compiler-plugin</artifactId> + <configuration> + <source>1.7</source> + <target>1.7</target> + </configuration> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <version>2.18</version> + <!-- Note config is repeated in scalatest config --> + <configuration> + <includes> + <include>**/Test*.java</include> + <include>**/*Test.java</include> + <include>**/*TestCase.java</include> + <include>**/*Suite.java</include> + </includes> + <reportsDirectory>${project.build.directory}/surefire-reports</reportsDirectory> + <argLine>-Xmx4g -XX:MaxPermSize=512m -XX:ReservedCodeCacheSize=512m</argLine> + <systemProperties> + <java.awt.headless>true</java.awt.headless> + </systemProperties> + <failIfNoTests>false</failIfNoTests> + </configuration> + </plugin> + <plugin> + <groupId>org.scalatest</groupId> + <artifactId>scalatest-maven-plugin</artifactId> + <version>1.0</version> + <!-- Note config is repeated in surefire config --> + <configuration> + <suites>${suite.name}</suites> + <reportsDirectory>${project.build.directory}/surefire-reports</reportsDirectory> + <junitxml>.</junitxml> + <filereports>CarbonTestSuite.txt</filereports> + <argLine>-ea -Xmx6g -XX:MaxPermSize=512m -XX:ReservedCodeCacheSize=512m + </argLine> + <stderr /> + <environmentVariables> + </environmentVariables> + <systemProperties> + <java.awt.headless>true</java.awt.headless> + <user.timezone>GMT</user.timezone> + <spark.master.url>${spark.master.url}</spark.master.url> + <hdfs.url>${hdfs.url}</hdfs.url> + </systemProperties> + </configuration> + <executions> + <execution> + <id>test</id> + <goals> + <goal>test</goal> + </goals> + </execution> + </executions> + </plugin> + </plugins> + </build> + <profiles> + <profile> + <id>spark-1.5</id> + <dependencies> + <dependency> + <groupId>org.apache.carbondata</groupId> + <artifactId>carbondata-spark</artifactId> + <version>${project.version}</version> + <scope>test</scope> + <exclusions> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-hive-thriftserver_2.10</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-repl_2.10</artifactId> + </exclusion> + </exclusions> + </dependency> + </dependencies> + </profile> + <profile> + <id>spark-1.6</id> + <activation> + <activeByDefault>true</activeByDefault> + </activation> + <dependencies> + <dependency> + <groupId>org.apache.carbondata</groupId> + <artifactId>carbondata-spark</artifactId> + <version>${project.version}</version> + <scope>test</scope> + <exclusions> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-hive-thriftserver_2.10</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-repl_2.10</artifactId> + </exclusion> + </exclusions> + </dependency> + </dependencies> + </profile> + <profile> + <id>spark-2.1</id> + <dependencies> + <dependency> + <groupId>org.apache.carbondata</groupId> + <artifactId>carbondata-spark2</artifactId> + <version>${project.version}</version> + <scope>test</scope> + <exclusions> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-hive-thriftserver_2.10</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.spark</groupId> + <artifactId>spark-repl_2.10</artifactId> + </exclusion> + </exclusions> + </dependency> + </dependencies> + </profile> + </profiles> +</project> http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/integration/spark-common-cluster-test/src/test/resources/hdfs-site.xml ---------------------------------------------------------------------- diff --git a/integration/spark-common-cluster-test/src/test/resources/hdfs-site.xml b/integration/spark-common-cluster-test/src/test/resources/hdfs-site.xml new file mode 100644 index 0000000..0f7e571 --- /dev/null +++ b/integration/spark-common-cluster-test/src/test/resources/hdfs-site.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<?xml-stylesheet type="text/xsl" href="configuration.xsl"?> +<!-- + Licensed 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. See accompanying LICENSE file. +--> + +<!-- Put site-specific property overrides in this file. --> + +<configuration> + <property> + <name>dfs.client.block.write.replace-datanode-on-failure.policy</name> + <value>NEVER</value> + </property> +</configuration> http://git-wip-us.apache.org/repos/asf/carbondata/blob/14624953/integration/spark-common-cluster-test/src/test/resources/testdatafileslist.txt ---------------------------------------------------------------------- diff --git a/integration/spark-common-cluster-test/src/test/resources/testdatafileslist.txt b/integration/spark-common-cluster-test/src/test/resources/testdatafileslist.txt new file mode 100644 index 0000000..faec837 --- /dev/null +++ b/integration/spark-common-cluster-test/src/test/resources/testdatafileslist.txt @@ -0,0 +1,230 @@ +Data/cmb/data.csv +Data/complex/Array.csv +Data/complex/ArrayofArray.csv +Data/complex/arrayofstruct.csv +Data/complex/Struct.csv +Data/complex/structofarray.csv +Data/oscon/oscon.csv +Data/InsertData/Test/badrecords_test6.csv +Data/InsertData/Test/badrecords_test7.csv +Data/InsertData/Test/badrecords_test8.csv +Data/InsertData/2000_UniqData.csv +Data/InsertData/all_data_types_range.csv +Data/InsertData/bad_records1.csv +Data/InsertData/badrecords.csv +Data/InsertData/badrecords_2.csv +Data/InsertData/badrecords_3.csv +Data/InsertData/badrecords_4.csv +Data/InsertData/badrecords_5.csv +Data/InsertData/badrecords_6.csv +Data/InsertData/badrecords_test5.csv +Data/InsertData/badrecords_test6.csv +Data/InsertData/big.csv +Data/InsertData/blank.csv +Data/InsertData/Carbon_T_Join1.csv +Data/InsertData/Carbon_T_Join2.csv +Data/InsertData/chinese.csv +Data/InsertData/city_id.csv +Data/InsertData/datatype.csv +Data/InsertData/Delimiter_DoubleQuotes.csv +Data/InsertData/Delimiter_EsclationMark.csv +Data/InsertData/Delimiter_ForwardSlash.csv +Data/InsertData/Delimiter_One.csv +Data/InsertData/Delimiter_SingleQuotes.csv +Data/InsertData/Delimiter_Two.csv +Data/InsertData/dict.csv +Data/InsertData/DiffDilimiter.csv +Data/InsertData/DoubleVal.csv +Data/InsertData/Emp.csv +Data/InsertData/empty.csv +Data/InsertData/emptyLoad.csv +Data/InsertData/EScape_Test.csv +Data/InsertData/ExceedsDataTypeValue.csv +Data/InsertData/extra_column.csv +Data/InsertData/file.csv +Data/InsertData/Hive1.csv +Data/InsertData/hive2.csv +Data/InsertData/Hive3.csv +Data/InsertData/Hive5.csv +Data/InsertData/Hive_Array.csv +Data/InsertData/hive_t1.csv +Data/InsertData/improper.csv +Data/InsertData/improper1.csv +Data/InsertData/index.csv +Data/InsertData/index01.csv +Data/InsertData/info.csv +Data/InsertData/join1.csv +Data/InsertData/join2.csv +Data/InsertData/maxrange_double.csv +Data/InsertData/Measures.csv +Data/InsertData/Measures_1.csv +Data/InsertData/null.csv +Data/InsertData/nulltable.csv +Data/InsertData/Population.csv +Data/InsertData/records.csv +Data/InsertData/splchar.csv +Data/InsertData/T_Hive1.csv +Data/InsertData/T_Hive1_Bad.csv +Data/InsertData/T_Hive2.csv +Data/InsertData/T_Hive3.csv +Data/InsertData/T_Hive4.csv +Data/InsertData/T_Hive5.csv +Data/InsertData/T_Hive6.csv +Data/InsertData/T_Hive8.csv +Data/InsertData/T_Hive9.csv +Data/InsertData/T_Hive10.csv +Data/InsertData/T_Hive11.csv +Data/InsertData/T_Hive12.csv +Data/InsertData/T_Hive13.csv +Data/InsertData/T_Hive14.csv +Data/InsertData/T_Hive16.csv +Data/InsertData/T_Hive_01.csv +Data/InsertData/T_Hive_max.csv +Data/InsertData/T_Hive_maxc.csv +Data/InsertData/Test1.csv +Data/InsertData/test2.csv +Data/InsertData/test3.csv +Data/InsertData/Test4.csv +Data/InsertData/Test5.csv +Data/InsertData/Test6.csv +Data/InsertData/Test12.csv +Data/InsertData/Test121.csv +Data/InsertData/timetsmap.csv +Data/InsertData/vardhandaterestruct.csv +Data/InsertData/vardhandaterestruct2.csv +Data/InsertData/vardhandaterestruct3.csv +Data/InsertData/WithHeader.csv +Data/InsertData/WithHeaders.csv +Data/InsertData/WithoutHeader.csv +Data/uniqdata/1lac_UniqData.csv +Data/batchsort/data.csv +Data/3Lakh.csv +Data/1lakh.csv +Data/noinverted.csv +Data/partition/2000_UniqData_partition.csv +Data/100_VMALL_1_Day_DATA_2015-09-15.csv +Data/RangeFilter/rangedatasample.csv +Data/RangeFilter/rangefilterdata.csv +Data/singlepass/data/10_UniqData.csv +Data/singlepass/data/2000_UniqData.csv +Data/singlepass/data/cust_name.txt +Data/singlepass/data/data.dictionary +Data/singlepass/data/vardhandaterestruct.csv +Data/singlepass/2000_UniqData +Data/singlepass/2000_UniqData.csv +Data/singlepass/2000_UniqData.dat +Data/singlepass/2000_UniqData.txt +Data/singlepass/2000_UniqData.xls +Data/singlepass/2000_UniqData_001.csv +Data/singlepass/2000_UniqData_017.csv +Data/singlepass/2000_UniqData_badrec.csv +Data/singlepass/2000_UniqData_exclamation.csv +Data/singlepass/2000_UniqData_incomplete.csv +Data/singlepass/2000_UniqData_nodata.csv +Data/singlepass/2000_UniqData_pipe.csv +Data/singlepass/2000_UniqData_quote.csv +Data/singlepass/2000_UniqData_singlequote.csv +Data/singlepass/2000_UniqData_slash.csv +Data/sortcolumns/data.csv +Data/sortcolumns/dataDecimal.csv +Data/sortcolumns/dataDrop.csv +Data/sortcolumns/dataFloat.csv +Data/sortcolumns/dataInt.csv +Data/sortcolumns/dataString.csv +Data/vardhandaterestructddMMMyyyy.csv +Data/vardhandaterestructyyyyMMMdd.csv +Data/pushdownJoin/30thousand_unidata.csv +Data/pushdownJoin/city_id.csv +Data/pushdownJoin/join1.csv +Data/pushdownJoin/join2.csv +Data/pushdownJoin/Population.csv +Data/pushdownJoin/Test1.csv +Data/pushdownJoin/test2.csv +Data/pushdownJoin/test3.csv +Data/pushdownJoin/Test4.csv +Data/pushdownJoin/Test5.csv +Data/pushdownJoin/Test6.csv +Data/pushdownJoin/Test12.csv +Data/pushdownJoin/Test12.csv +Data/pushdownJoin/vardhandaterestruct.csv +Data/pushdownJoin/vardhandaterestruct2.csv +Data/pushdownJoin/vardhandaterestruct3.csv +Data/SEQ500/seq_500Records.csv +Data/sequencedata/100.csv +Data/sequencedata/dict.csv +Data/sequencedata/file.csv +Data/sequencedata/improper.csv +Data/sequencedata/improper1.csv +Data/sequencedata/nulltable.csv +Data/sequencedata/records.csv +Data/sequencedata/vardhandaterestruct.csv +Data/uniqdata/2000_UniqData.csv +Data/uniqdata/2000_UniqData_CommentChar.csv +Data/uniqdata/2000_UniqData_Date.csv +Data/uniqdata/2000_UniqData_EscapeChar.csv +Data/uniqdata/2000_UniqData_insert.csv +Data/uniqdata/2000_UniqData_tabdelm.csv +Data/uniqdata/3000_1_UniqData.csv +Data/uniqdata/3000_UniqData.csv +Data/uniqdata/3000_UniqData1.csv +Data/uniqdata/3000_UniqDatatdelm.csv +Data/uniqdata/4000_UniqData.csv +Data/uniqdata/4000_UniqDataquotedelm.csv +Data/uniqdata/5000_UniqData!delm.csv +Data/uniqdata/5000_UniqData.csv +Data/uniqdata/6000_UniqData.csv +Data/uniqdata/7000_UniqData +Data/uniqdata/7000_UniqData.csv +Data/VmaLL100/100_olap.csv +Data/VmaLL100/100olap.csv +Data/RangeFilter/rangedatasample.csv +Data/RangeFilter/rangefilterdata.csv +Data/partition/2000_UniqData_partition.csv +Data/100_olap_C20.csv +Data/100_VMALL_1_Day_DATA_2015-09-15.csv +Data/customer_C1.csv +Data/FACT_UNITED_DATA_INFO_sample_cube.csv +Data/newdata.csv +Data/payment_C1.csv +Data/HiveData/100_hive_test.csv +Data/Test_Data1.csv +Data/columndict/data1/data2/data3/data.csv +Data/columndict/data1/data2/data3/data1.csv +Data/columndict/data1/data2/data.csv +Data/columndict/data1/data.csv +Data/columndict/country.csv +Data/columndict/country.txt +Data/columndict/data.csv +Data/columndict/data.dat +Data/columndict/data.dictionary +Data/columndict/data.txt +Data/columndict/inValidData.csv +Data/columndict/inValidData.dictionary +Data/columndict/salary.csv +Data/badrecord/doubleqoute.csv +Data/badrecord/emptyComma.csv +Data/badrecord/insuffcient.csv +Data/badrecord/qoute1.csv +Data/badrecord/qoute2.csv +Data/badrecord/qoute3.csv +Data/badrecord/qoute4.csv +Data/badrecord/single.csv +Data/badrecord/test2.csv +Data/badrecord/test3.csv +Data/badrecord/test4.csv +Data/badrecord/test5.csv +Data/badrecord/test6.csv +Data/badrecord/test7.csv +Data/badrecord/test8.csv +Data/3Lakh.csv +Data/Delimiter_BackrwardSlash.csv +Data/DiffDilimiter.csv +Data/OSCON.csv +Data/bad_records1.csv +Data/badrecords.csv +Data/badrecords_2.csv +Data/badrecords_3.csv +Data/badrecords_4.csv +Data/badrecords_5.csv +Data/emptyLoad.csv +Data/splchar.csv \ No newline at end of file
