Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22263#discussion_r213706428
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala ---
@@ -272,7 +272,7 @@ class SparkSqlAstBuilder(conf: SQLConf) extends
AstBuilder(conf) {
throw new ParseException(s"It is not allowed to add database prefix
`$database` to " +
s"the table name in CACHE TABLE AS SELECT", ctx)
}
- CacheTableCommand(tableIdent, query, ctx.LAZY != null)
+ CacheTableCommand(tableIdent, query, ctx.LAZY != null,
Option(ctx.storageLevel).map(source))
--- End diff --
why `source` instead of `getText`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
