1回答
我使用JDBC连接到数据库，并且正在尝试运行更新查询。首先我输入查询，然后执行它(与执行SELECT的方式一样，它工作得非常好)。caseoutputUpdateQuery = "(UPDATE dbo.CASEOUTPUT_TEST SET NOTIFIED = 'YES') alias_output "
spark.read.jdbc我试着用不同的方法解决这个问题，但总会出现另一个错误。我尝试重写的另一种方式是： caseou
浏览 23提问于2020-07-23得票数 0
回答已采纳
5回答
并使用模式覆盖向目标写入 .option("url", "jdbc:mysql://localhost/test") .option("dbtable","temptgtUpdate")
.option(
浏览 3提问于2020-05-10得票数 0
如果我查看Imapala Shell或Hue，我可以为KUDU编写足够复杂的IMPALA更新语句。例如，使用子选择更新和不更新的内容。很好。看看过去的JDBC连接方法，比如通过SPARK / SCALA进行mySQL，通过这种连接进行复杂的更新的可能性不大，这是可以理解的。不过，有了古都，我想情况会发生变化。查看有关使用Apache KUDU开发应用程序
浏览 2提问于2017-11-08得票数 1
回答已采纳
问题陈述：，我正在创建到Impala的Spark连接，并将这些表加载到spark中，以便进行像这样的验证，这很好：现在是下一步，我的实际
浏览 2提问于2020-08-13得票数 2
回答已采纳
1回答
随着数据的变化，我需要每天提取它们，并得到更新，我还想通过使用Azure密钥库/秘密传递经过编辑的凭据来获取它们。我知道我可以在spark中使用下面的代码来更快地完成这个任务，并且可以在一小部分时间内成功地提取几乎所有的表，而不是使用python。但是，我似乎无法将其设置为源代码，并传递用户名和密码的秘密。%sql
USING org.apache.spark.sql.jdbc
OPTIONS (
浏览 2提问于2020-11-17得票数 1
回答已采纳
1回答
我试图使用scala编写经典的sql查询，以便将一些信息插入到sql服务器数据库表中。到我的数据库的连接工作得很好，我成功地从JDBC读取数据，从最近创建的一个名为"textspark“的表中读取数据，该表只有一个名为”create table textspark(firstname varcharnot found: textspark//Step 1: Check that the
浏览 0提问于2018-08-02得票数 0
回答已采纳
我正在使用ApacheSpark1.5.1，并试图连接到名为SQLite的本地clinton.db数据库。从数据库的一个表创建数据框架很好，但是当我对创建的对象执行一些操作时，我会得到下面的错误，上面写着"SQL错误或缺少数据库(连接关闭)“。有趣的是，我还是得到了手术的结果。/spark/bin/spark-shell --master local[8] --jars ../libraries/sqlite-
浏览 2提问于2015-09-30得票数 1
回答已采纳
为什么下面的代码在返回语句中有编译错误， val res = spark.read.format("jdbc").jdbc(jdbcUrl, "", props).registerTempTable("") }type mismatch; found :Unit required: Array[org.
浏览 0提问于2018-05-15得票数 0
回答已采纳
System.exit(1) def getControlTableData(): Unit = { idf = spark.read.format("jdbc").option("url","&quo
浏览 19提问于2020-04-09得票数 0
2回答
我想在spark中创建一个持久化(全局)视图，从底层jdbc数据库连接中获取数据。当我使用临时(会话范围)视图时，它工作得很好，如下所示，但是当我试图创建一个常规(持久和全局)视图时，它会失败。我不明白为什么后者不能工作，但是找不到任何文档/提示，因为所有的示例都是用临时视图完成的。从技术上讲，我不明白为什么它不应该工作，因为数据是在临时视图中正确地从jdbc源检索的，因此，如果我想将查询“存储”在一个持久视图中，那么无论何时调用视图，它都可以直接从j
浏览 14提问于2022-10-27得票数 0
回答已采纳
1回答
凤凰星火插件
、、
插件更新是为了激发2.0吗？val df = spark.read .option("driver", "org.apache.phoenix.jdbc.PhoenixDriver.load()
线程"main“中的异常在org.apache.spark.sql.execution.datasources.jdbc.JDB
浏览 2提问于2017-01-18得票数 1
我试图在JDBC中使用预置语句。其结果是ResultSet对象。我想把它转换成火花数据格式。rs.next() print(" " + rs.getObject(i)) println()我想从Spark调用上面的代码，这样我就可以将数据加载到Dataframe中，并以更快的速度获得结果。我不能使用spark.jdbc.load，因为Ter
浏览 6提问于2017-08-04得票数 1
在我的java项目中，我导入了clickhouse-jbdc.jar (因为我的JDBC将基于clickhouse )但当我打字的时候Dataset<Row> df = spark.read() .option("url", "jdbc:("<e
浏览 3提问于2021-05-31得票数 0
回答已采纳
目前，我们的数据库托管在其他数据库中。我们正在考虑使用JDBC连接器在SPARK中执行流程。是否可以在连接数据源之后使用SPARK.SQL语句，还是必须加载数据才能使用spark.sql查询？
浏览 3提问于2022-08-11得票数 -1
我在尝试建立到Snowflake的连接时收到以下错误。我正在努力通过SSIS将数据从SQL服务器表加载到Snowflake表。我已经设置了ODBC连接并通过代理进行连接，在DSN中输入了代理名称。感谢您的帮助，谢谢！
错误: URL https：.//abc.azure.sknowflakecomputing.com的REST请求失败: CURL错误(curl_easy_perform()失败)- code=56 msg =‘从对等体接收数据时失败
浏览 2提问于2020-07-20得票数 1
2回答
到目前为止，我可以使用Teradata jdbc连接器for Spark从Teradata读取数据帧。阅读的语法如下： Map( "dbtable" -> (sel * from= teradata的连接url
我想将一个数据帧保存到Teradata表中。我尝试使用上述语法，将dbtabl
浏览 1提问于2016-11-15得票数 2
传递给Postgres的一些查询包含CREATE TABLE、INSERT、CREATE TEMP TABLE和CTE WITH语句。我正试图确定是否可以通过JDBC从Spark将这些查询传递给Postgres。 .config("spark.jars", "/usr/share/java/postgresql-<e
浏览 5提问于2020-02-06得票数 1
回答已采纳
1回答
由于某些需求，我需要使用SELECT INTO语句创建一个临时表，该表将在查询中进一步使用。但是，当我运行查询时，我会得到以下错误
drivers = {"mssql": "com.microsoft.sqlserver.<e
浏览 4提问于2021-06-10得票数 1
1回答
用python编写的代码是： .format("jdbc") \
.option("driver", "com.facebook.presto.jdbc.PrestoDriver:spark-streaming-kinesis-asl_2.11:2.4.0,org.postgresql:postgresql:42.2.9,com.facebook.presto:presto-<em
浏览 1提问于2020-01-24得票数 1
为了理解如何在我自己的python函数中使用map，我创建了这个人为的需求。获取所有数据库，并使用map为每个数据库运行show tables，并收集到所有数据库和表的数据帧中。return dataframe of tableName:string '''
return spark.sql("show tables in {0}".format(dat
浏览 2提问于2018-02-22得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号