回答情况：
提问时间：
问题标签：
1回答
UNION SELECT 4 UNION SELECT 5 UNION SELECT 6 UNION SELECT 7 UNION SELECT 8 UNION SELECT 9) t4
但是当我将它迁移到SparkSQL
浏览 0修改于2019-04-24得票数 1
回答已采纳
SparkSql。我得到粘贴在Json文件下面的错误。我是星火公司的新人，所以请你解释一下。object testSql { val conf = new SparkConf()15/11/05 17:21:20 INFO Ha
浏览 0提问于2015-11-05得票数 0
回答已采纳
任何人直接在HBase表上使用SparkSQL，就像在Hive表上使用SparkSQL一样。我是spark.Please新手，指导我如何连接hbase和spark.How来查询hbase表。
浏览 22修改于2020-05-16得票数 7
回答已采纳
我使用的是cloudera vm 10.0，spark版本为1.6。sqlContext.sql("select * from /user/hive/warehouse/default.party").show()Traceback (most recent call last): File "/usr/lib/spark/python/pyspark/
浏览 2修改于2017-08-03得票数 0
在我的例子中，我在JavaSparkSQL中使用了一个数据集(Dataframe)。此数据集来自JSON文件。json文件是由key- value组成的。当我查询查看我为examle编写的值时： SELECT key1.name from table JSON文件示例 { { "name": ".....",....} { "name":"....",....}
} 我的问题是，当我想要加入
浏览 17提问于2019-03-04得票数 0
回答已采纳
2回答
我有一个Dataframe，我想对其运行一个简单的查询，如下所示： spark.sql(queryString)
其中queryString可以是像这样的但我真的很想提前知道查询是否可以在不抛出异常的情况下工作。例如，如果
浏览 1修改于2018-06-12得票数 0
我是SparkSQL新手，我主要负责编写SparkSQL查询。我们经常需要在查询中使用JOIN大表，并且不需要很长时间就会遇到与它们相关的性能问题(例如。Joins、aggregates等)。在网上搜索补救方法时，我最近遇到了一些术语-- COALESCE()、REPARTITION()、DISTRIBUTE BY、CLUSTER BY等，而且它们可能用于提高慢速运行的SparkSQL 查询的性能有谁能在这里帮助我，并提供SparkSQL查询它们的用法和何时使用它们的例子？例如。syntaxhint syntaxtipss
浏览 5提问于2020-06-05得票数 0
1回答
我有一个火花作业，它将从CSV文件中的数据加载到MySQL数据库中。这将不会为每个插入打开一个连接。如果需要处理1K记录，这是很好的，但是当您处理数十亿条记录时，需要大量的资源。
浏览 1修改于2018-07-24得票数 1
回答已采纳
我正在从Impala迁移到SparkSQL，使用以下代码读取表：如何调用上面的SparkSQL，这样它就可以返回如下内容：
'select col_A, col_B from my_table'
浏览 5修改于2018-12-06得票数 29
回答已采纳
我有CSV文件，事件如下表所示。|Created |Name ||2018-09-30 21:00:08|EVENT A||2018-09-30 21:04:17|Event 3||2018-09-30 21:06:11|Event 5|
浏览 0修改于2019-01-03得票数 0
回答已采纳
我需要使用sparksql.I在我的hive表中插入一些值。我使用以下代码。result(3) //filename
val e=LocalDateTime.now() //timestamp 首先，我尝试使用Insert Into Values，但后来我发现此功能在sparksqlinsert into mytable("filepath,filename,Start_Time") values('${filepath}','${fn}',&#x
浏览 39修改于2020-04-13得票数 0
回答已采纳
我对蜂巢中的扣环有一个疑问。我已经创建了一个临时表，该表在列关键字上存储桶。当我检查这个表的基目录时，它显示了前缀为part_*的文件名。我不确定spark sql是否将数据写入存储桶中。谢谢,
浏览 1修改于2020-06-23得票数 5
我正在使用远程mysql亚稳态作为蜂巢。当我运行蜂巢客户端时，它运行得非常完美。但是，当我试图使用火花-sql，无论是通过火花壳或通过火花提交，我无法连接到蜂箱。&得到以下错误：Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.apache.derby.jdbc.EmbeddedDriver
浏览 1提问于2016-06-30得票数 0
回答已采纳
我正在尝试在SparkSQL中重现与sql中的group by相同的行为。下面是一个使用SQL而不是使用SparkSQL函数在SparkSQL中所能完成的操作的示例： 输入数据集： val input = Seq( ("Toronto----+-----+|Toronto|2016|4 |+-------+----+-----+ 我希望对SparkSQL</em
浏览 26提问于2021-08-30得票数 0
回答已采纳
我的表有一个类型为integer的date列sc.sql('select date from table).show(1)19860102sc.sql('select cast(date to Timestamp) from table).show(1)1970-08-18 20:41:42有没有办法用sql代替函数F呢？
浏览 7提问于2021-12-01得票数 0
1回答
我们如何在Spark中分解多个数组列？我有一个包含5个字符串化数组列的数据帧，我想在所有5列上进行分解。为了简单起见，用3列显示示例。 如果我有以下输入行： col1 col2 col3
["b_val1","b_val2"] ["at_val1","at_val2","at_val3"] ["male","female"] 我想对所有3个数组列进行分解，因此输出应该如下所示： b_
浏览 5提问于2020-09-08得票数 0
回答已采纳
有人知道如何在MEMORY_ONLY_SER中使用SparkSQL缓存吗？我的目标是使用来自SparkSQL的序列化表缓存。有什么想法吗？
浏览 2修改于2017-05-23得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号