diff options
| author | Yin Huai <yhuai@databricks.com> | 2016-06-19 21:45:53 -0700 |
|---|---|---|
| committer | Yin Huai <yhuai@databricks.com> | 2016-06-19 21:45:53 -0700 |
| commit | 6d0f921aedfdd3b7e8472b6776d0c7d8299190bd (patch) | |
| tree | 29f6f34219596d37c44927ff386a77550854bf41 /sql/catalyst | |
| parent | 4f17fddcd57adeae0d7e31bd14423283d4b625e9 (diff) | |
| download | spark-6d0f921aedfdd3b7e8472b6776d0c7d8299190bd.tar.gz spark-6d0f921aedfdd3b7e8472b6776d0c7d8299190bd.tar.bz2 spark-6d0f921aedfdd3b7e8472b6776d0c7d8299190bd.zip | |
[SPARK-16036][SPARK-16037][SPARK-16034][SQL] Follow up code clean up and improvement
## What changes were proposed in this pull request?
This PR is the follow-up PR for https://github.com/apache/spark/pull/13754/files and https://github.com/apache/spark/pull/13749. I will comment inline to explain my changes.
## How was this patch tested?
Existing tests.
Author: Yin Huai <yhuai@databricks.com>
Closes #13766 from yhuai/caseSensitivity.
Diffstat (limited to 'sql/catalyst')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala index 69b8b059fd..ff3dcbc957 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala @@ -369,6 +369,8 @@ case class InsertIntoTable( if (table.output.isEmpty) { None } else { + // Note: The parser (visitPartitionSpec in AstBuilder) already turns + // keys in partition to their lowercase forms. val staticPartCols = partition.filter(_._2.isDefined).keySet Some(table.output.filterNot(a => staticPartCols.contains(a.name))) } |