我在MySQL中有一个'user‘表。我想把它读到我的Spark SQL程序中。如何使用Python将表从MySQL读取到Apache Spark的SparkSQL模块？有没有可以用来完成这个任务的连接器？谢谢。
浏览 0提问于2016-04-25得票数 12
2回答
最近，当我们遇到这个问题时，我正在和我的朋友讨论SparkSQL的特性。它们是酸性交易吗？SparkSQL是否遵循CAP定理？
我对这个领域有点陌生，帮帮我吧。提前谢谢。
浏览 3提问于2016-05-10得票数 3
回答已采纳
1回答
任何人直接在HBase表上使用SparkSQL，就像在Hive表上使用SparkSQL一样。我是spark.Please新手，指导我如何连接hbase和spark.How来查询hbase表。
浏览 22提问于2016-09-16得票数 7
回答已采纳
MySQL的命令kill query (定义为)是否等同于Apache SparkSQL?谢谢！
浏览 2提问于2017-10-17得票数 0
回答已采纳
在MySQL的命令show processlist;中有Apache SparkSQL的等价物吗？
浏览 3提问于2017-10-17得票数 0
回答已采纳
有了SparkSQL卡桑德拉连接器，JDBC工具(即DBVisualizer、Tableau、Alteryx.etc)可以将2个Cassandra表与SparkSQL连接起来吗？
浏览 0提问于2018-06-25得票数 1
回答已采纳
1)我们有来自不同来源( MySQL、甲骨文、卡桑德拉、蒙戈)的数据。我们想知道如何将这些数据放入Spark SQL中？有没有我们可以使用的实用程序？3)对于报告UI，我们使用Jasper，我们希望从Jasper连接到Spark SQL。当我们进行最初的搜索时，我们了解到目前还不支持消费者通过JDBC连接Spark SQL，但在未来的版本中，您会希望添加相同的功能。我们想知道Spark SQL什么时候会有一个支持JDBC的稳定版本？
浏览 0提问于2014-07-08得票数 7
我有一个到外部数据库的SparkSQL连接： .builder \我使用的是pyspark v2.1，以防有什么不同。
浏览 2提问于2017-03-19得票数 11
回答已采纳
我最近被介绍给SparkSQL。我们使用Spark 2.4。最近，我发现SparkSQL查询支持其连接策略的以下提示：
有人能用一些例子来解释吗。任何帮助都是非常感谢的。谢谢
浏览 3提问于2020-06-08得票数 1
我有一个火花结构化流scala作业，它从kafka读取json消息并将数据写入S3。我配置了一个合流模式注册中心，该模式使用type=object的json格式。现在，我可以从注册表中检索模式，但是我需要在包含kafka记录的dataframe上使用这个模式。val valueRestResponseSchema = restService.getLatestVersion(schemaName) // return type is io.confluent.kafka.schemare
浏览 7提问于2022-11-30得票数 0
我使用的是Spark SQL 2.1， 我可以在Spark SQL中以临时视图的形式从mysql/oracle中读取数据： val url = "jdbc:mysql://localhost:3306password '$pass', numPartitions '3')
val session = SparkSession.builder().appName("S
浏览 9提问于2019-03-29得票数 0
使用SparkR连接到MySQL或任何其他SQL数据库。
编写SQL查询，如SELECT、UPDATE等来修改数据库中的表。我知道使用R来做这件事，但是我需要一些帮助来使用Spark Sessions或SparkSQL context。我正在使用R Studio进行开发。
浏览 4提问于2016-08-21得票数 0
我试着在SparkSQL中做group by，这很好，但是大多数行都丢失了。227967 ||100004 |227973 |MySQL--请注意，，我已经检查了与此相关的其他答案，比如连接以获取所有行等等，但是我想知道是否还有其他方法可以得到类似于MySQL的结果？
浏览 10提问于2020-12-02得票数 0
回答已采纳
我有点困惑于不同的演员在这个故事: PySpark，SparkSQL，卡桑德拉和火星雨-卡桑德拉连接器。据我所知，星火已经进化了很多，SparkSQL现在是一个关键组件(有了'dataframes')。显然，没有SparkSQL是绝对没有理由工作的，特别是如果连接到卡桑德拉。因此，我的问题是:需要哪些组件，以及如何以最简单的方式将它们连接在一起？.
浏览 7提问于2016-02-28得票数 1
是否有可能从“外部”连接到Azure Synapse星火池。指的是Rstudio还是Sparksql？
浏览 5提问于2022-01-27得票数 1
回答已采纳
如何使用SparkSession.SQL对Java中的Cassandra执行准备语句和批处理语句？我在使用Spark2.1
浏览 4提问于2017-01-19得票数 0
回答已采纳
1回答
在这种情况下，我希望使用SparkSQL“迭代”或映射“宽行”，而不是逻辑Cassandra行(CQL行)。我如何通过保持数据的局部性(我认为我的数据模型非常适合于这些任务)来有效地使用SparkSQL呢？
我阅读了，其中提到了Cassandra连接器中的spanBy和spanByKey。这将如何与SparkSQL一起使用？
浏览 0提问于2016-03-13得票数 0
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
