aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorHerman van Hovell <hvanhovell@databricks.com>2016-08-16 21:35:39 -0700
committerReynold Xin <rxin@databricks.com>2016-08-16 21:35:39 -0700
commit4a2c375be2bcd98cc7e00bea920fd6a0f68a4e14 (patch)
tree1db9080a62e4a7972155a42a0526f6b8e63ba777 /sql/core
parente28a8c5899c48ff065e2fd3bb6b10c82b4d39c2c (diff)
downloadspark-4a2c375be2bcd98cc7e00bea920fd6a0f68a4e14.tar.gz
spark-4a2c375be2bcd98cc7e00bea920fd6a0f68a4e14.tar.bz2
spark-4a2c375be2bcd98cc7e00bea920fd6a0f68a4e14.zip
[SPARK-17084][SQL] Rename ParserUtils.assert to validate
## What changes were proposed in this pull request? This PR renames `ParserUtils.assert` to `ParserUtils.validate`. This is done because this method is used to check requirements, and not to check if the program is in an invalid state. ## How was this patch tested? Simple rename. Compilation should do. Author: Herman van Hovell <hvanhovell@databricks.com> Closes #14665 from hvanhovell/SPARK-17084.
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala5
1 files changed, 2 insertions, 3 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala
index 9da2b5a254..71c3bd31e0 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala
@@ -18,7 +18,6 @@
package org.apache.spark.sql.execution
import scala.collection.JavaConverters._
-import scala.util.Try
import org.antlr.v4.runtime.{ParserRuleContext, Token}
import org.antlr.v4.runtime.tree.TerminalNode
@@ -799,7 +798,7 @@ class SparkSqlAstBuilder(conf: SQLConf) extends AstBuilder {
}
/**
- * Create an [[AlterTableDiscoverPartitionsCommand]] command
+ * Create an [[AlterTableRecoverPartitionsCommand]] command
*
* For example:
* {{{
@@ -1182,7 +1181,7 @@ class SparkSqlAstBuilder(conf: SQLConf) extends AstBuilder {
entry("mapkey.delim", ctx.keysTerminatedBy) ++
Option(ctx.linesSeparatedBy).toSeq.map { token =>
val value = string(token)
- assert(
+ validate(
value == "\n",
s"LINES TERMINATED BY only supports newline '\\n' right now: $value",
ctx)