问源

EN

是。有两种方法。

1. 以编程方式使用SQLContext加载函数。

load函数将JDBC数据源数据作为DataFrame加载。如果希望在后续的Spark查询中将此DataFrame作为表使用，则必须使用

yourDataFrame.registerTempTable("yourTableName")

如果您想要一个完整的示例，请查看我的博客帖子。

1. 使用SQL

我还没试过呢。根据我从文档中读到的内容，可以这样做，如下面的示例所示。

CREATE TEMPORARY TABLE yourTableName
USING org.apache.spark.sql.jdbc
OPTIONS (
  url "jdbc:postgresql:dbserver",
  dbtable "schema.tablename"
)

您可以猜到，它既可以加载数据，也可以在同一个命令中将其注册为表。

我认为SQLContext.sql函数可以用来执行上面的SQL语句。但它会抛出你提到的同样的错误。

失败：“插入”预期，但标识符创建找到

基于所有这些，我现在的结论是，这个DDL语句是在Spark对其执行数据库时从SQL客户端执行的。这意味着，如果您使用SparkThrift服务器从server或任何其他SQL编辑器连接Spark，则可能会调用它。如果成功，还可以使用JDBC/ODBC驱动程序以编程方式进行操作，然后再连接到Thrift服务器。