Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/22930#discussion_r230609078
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SaveIntoDataSourceCommand.scala
---
@@ -37,13 +37,12 @@ case class SaveIntoDataSourceCommand(
query: LogicalPlan,
dataSource: CreatableRelationProvider,
options: Map[String, String],
- mode: SaveMode) extends RunnableCommand {
+ mode: SaveMode,
+ outputColumnNames: Seq[String]) extends DataWritingCommand {
- override protected def innerChildren: Seq[QueryPlan[_]] = Seq(query)
-
- override def run(sparkSession: SparkSession): Seq[Row] = {
- dataSource.createRelation(
- sparkSession.sqlContext, mode, options, Dataset.ofRows(sparkSession,
query))
--- End diff --
See what I commented in https://github.com/apache/spark/pull/22941
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
