Repository: carbondata Updated Branches: refs/heads/master 85dc4fff0 -> 0a972e0a3
[CARBONDATA-1752] There are some scalastyle error should be optimized in CarbonData Remove unused import in scala code This closes #1528 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/0a972e0a Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/0a972e0a Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/0a972e0a Branch: refs/heads/master Commit: 0a972e0a31cb0269b20ff45cbc0beb5eae202a29 Parents: 85dc4ff Author: xubo245 <601450...@qq.com> Authored: Sat Nov 18 11:46:59 2017 +0800 Committer: Jacky Li <jacky.li...@qq.com> Committed: Sat Nov 18 23:37:02 2017 +0800 ---------------------------------------------------------------------- .../testsuite/dataload/TestLoadDataWithNotProperInputFile.scala | 4 ---- .../org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala | 5 +---- .../src/main/scala/org/apache/spark/sql/CarbonSource.scala | 4 ++-- .../spark/sql/execution/command/CarbonCreateTableCommand.scala | 1 - .../org/apache/spark/sql/parser/CarbonSparkSqlParser.scala | 2 +- 5 files changed, 4 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/0a972e0a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataWithNotProperInputFile.scala ---------------------------------------------------------------------- diff --git a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataWithNotProperInputFile.scala b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataWithNotProperInputFile.scala index 9237627..47f05ce 100644 --- a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataWithNotProperInputFile.scala +++ b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataWithNotProperInputFile.scala @@ -17,11 +17,7 @@ package org.apache.carbondata.spark.testsuite.dataload -import java.io.File - import org.apache.spark.util.FileUtils -import org.apache.carbondata.processing.loading.model.CarbonLoadModel -import org.apache.carbondata.spark.util.GlobalDictionaryUtil import org.apache.spark.sql.test.util.QueryTest /** http://git-wip-us.apache.org/repos/asf/carbondata/blob/0a972e0a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala index 72f40ac..1f4e739 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDatasourceHadoopRelation.scala @@ -23,11 +23,9 @@ import org.apache.spark.CarbonInputMetrics import org.apache.spark.rdd.RDD import org.apache.spark.sql.catalyst.InternalRow import org.apache.spark.sql.execution.command.management.LoadTableByInsertCommand -import org.apache.spark.sql.execution.streaming.Sink import org.apache.spark.sql.hive.CarbonRelation import org.apache.spark.sql.optimizer.CarbonFilters -import org.apache.spark.sql.sources.{BaseRelation, Filter, InsertableRelation, StreamSinkProvider} -import org.apache.spark.sql.streaming.OutputMode +import org.apache.spark.sql.sources.{BaseRelation, Filter, InsertableRelation} import org.apache.spark.sql.types.StructType import org.apache.carbondata.core.constants.CarbonCommonConstants @@ -37,7 +35,6 @@ import org.apache.carbondata.core.scan.expression.Expression import org.apache.carbondata.core.scan.expression.logical.AndExpression import org.apache.carbondata.hadoop.CarbonProjection import org.apache.carbondata.spark.rdd.CarbonScanRDD -import org.apache.carbondata.streaming.StreamSinkFactory case class CarbonDatasourceHadoopRelation( sparkSession: SparkSession, http://git-wip-us.apache.org/repos/asf/carbondata/blob/0a972e0a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala index 6331f12..c9e2c20 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala @@ -27,7 +27,7 @@ import org.apache.spark.sql.catalyst.catalog.CatalogTable import org.apache.spark.sql.execution.command.{TableModel, TableNewProcessor} import org.apache.spark.sql.execution.strategy.CarbonLateDecodeStrategy import org.apache.spark.sql.execution.streaming.Sink -import org.apache.spark.sql.hive.{CarbonMetaStore, CarbonRelation} +import org.apache.spark.sql.hive.CarbonMetaStore import org.apache.spark.sql.optimizer.CarbonLateDecodeRule import org.apache.spark.sql.parser.CarbonSpark2SqlParser import org.apache.spark.sql.sources._ @@ -38,7 +38,7 @@ import org.apache.carbondata.core.constants.CarbonCommonConstants import org.apache.carbondata.core.metadata.AbsoluteTableIdentifier import org.apache.carbondata.core.metadata.schema.SchemaEvolutionEntry import org.apache.carbondata.core.metadata.schema.table.TableInfo -import org.apache.carbondata.core.util.{CarbonProperties, CarbonSessionInfo, CarbonUtil, ThreadLocalSessionInfo} +import org.apache.carbondata.core.util.{CarbonProperties, CarbonUtil} import org.apache.carbondata.core.util.path.{CarbonStorePath, CarbonTablePath} import org.apache.carbondata.spark.CarbonOption import org.apache.carbondata.spark.exception.MalformedCarbonCommandException http://git-wip-us.apache.org/repos/asf/carbondata/blob/0a972e0a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala index f83766d..8880626 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala @@ -18,7 +18,6 @@ package org.apache.spark.sql.execution.command import org.apache.spark.sql.{CarbonEnv, GetDB, Row, SparkSession} -import org.apache.spark.sql.catalyst.TableIdentifier import org.apache.carbondata.common.logging.LogServiceFactory import org.apache.carbondata.core.constants.CarbonCommonConstants http://git-wip-us.apache.org/repos/asf/carbondata/blob/0a972e0a/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala index 401b149..6a3bab4 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala @@ -18,7 +18,7 @@ package org.apache.spark.sql.parser import scala.collection.mutable -import org.apache.spark.sql.{CarbonEnv, CarbonSession, SparkSession} +import org.apache.spark.sql.{CarbonSession, SparkSession} import org.apache.spark.sql.catalyst.TableIdentifier import org.apache.spark.sql.catalyst.parser.{AbstractSqlParser, ParseException, SqlBaseParser} import org.apache.spark.sql.catalyst.parser.ParserUtils._