grundprinzip commented on code in PR #38192:
URL: https://github.com/apache/spark/pull/38192#discussion_r995393706
##########
connector/connect/src/main/scala/org/apache/spark/sql/connect/command/SparkConnectCommandPlanner.scala:
##########
@@ -40,17 +46,19 @@ class SparkConnectCommandPlanner(session: SparkSession,
command: proto.Command)
command.getCommandTypeCase match {
case proto.Command.CommandTypeCase.CREATE_FUNCTION =>
handleCreateScalarFunction(command.getCreateFunction)
+ case proto.Command.CommandTypeCase.WRITE_OPERATION =>
+ handleWriteOperation(command.getWriteOperation)
case _ => throw new UnsupportedOperationException(s"$command not
supported.")
}
}
/**
* This is a helper function that registers a new Python function in the
SparkSession.
*
- * Right now this function is very rudimentary and bare-bones just to
showcase how it
- * is possible to remotely serialize a Python function and execute it on the
Spark cluster.
- * If the Python version on the client and server diverge, the execution of
the function that
- * is serialized will most likely fail.
+ * Right now this function is very rudimentary and bare-bones just to
showcase how it is
+ * possible to remotely serialize a Python function and execute it on the
Spark cluster. If the
+ * Python version on the client and server diverge, the execution of the
function that is
+ * serialized will most likely fail.
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
