我在Databricks 7.0运行时集群中使用SQL for Spark 3.0。200 || a2 | b2 | 150 |
+-------+-------+------+ 但是，我正在尝试编写一个查询，其中只需要汇总b列。SQL中支持这种操作，但是在尝试运行上面的查询时，我得到了Error in SQL statement: UnsupportedOperationException。有没有人知道这种行为在
浏览 17提问于2020-07-02得票数 3
回答已采纳
如何在spark上按操作执行组。我无法对某一列进行分组，并在各列上按聚合值分组。 group by values")
( org.apache.spark</em
浏览 3提问于2019-01-08得票数 1
回答已采纳
----------------------------------------------------+---------------+我已经尝试过使用posexplode了，但是它改变了我的dataframe模式，添加了col和pos列，newDF.printSchema() }} }
那么，在不更改Da
浏览 1提问于2019-06-25得票数 2
回答已采纳
0回答
我目前正在学习python中的spark。我有一个小问题，在SQL这样的其他语言中，我们可以简单地按指定的列对表进行分组，然后对它们执行进一步的操作，如sum、count等。我们如何在Spark中做到这一点？"20"] [n
浏览 3提问于2016-07-14得票数 2
3回答
我有一个包含数组列的数据帧，如下所示： val df = Seq( Array("bcd", "bc", "bcd看起来是这样的： col:["bcd","bc","bcd&qu
浏览 43提问于2020-04-02得票数 0
回答已采纳
2回答
星星之火:无法读取蜂窝表中的数据
、、、、
>我的班级正在读取蜂窝表中的数据：import org.apache.spark.SparkConfimport org.apache.spark.SparkContext
import org.apache.spark</em
浏览 5提问于2017-02-20得票数 1
回答已采纳
csv文件，它有3列数据类型:String，Long，Date。我想按字符串的第一列进行分组，并检索最大的日期值。Justin, 18,01/08/2003Ben Stokes, 29,30
浏览 22提问于2021-03-10得票数 0
回答已采纳
我试过这样做， """| 1| b|| 1| a|不像上面使用dataframe操作显示的输出 spark.sql,')) as exploded )
pivot (exp
浏览 0提问于2020-05-11得票数 4
回答已采纳
1回答
一种方法是首先获得单个项目的mrp总和，并存储在一个变量中，然后获得所有项目的总mrp的总和，执行division.But这将需要对单个项目进行循环。我想用spark的方式来做，只使用sql。
浏览 1提问于2017-07-19得票数 1
我的应用程序中有平面数据，我需要像通常使用sql查询一样对这些数据进行分组、汇总和计数。但是，对于这个项目，它必须在flex应用程序中完成。我需要弄清楚如何使用Arraycollection中的datatime字段按天或月对数据进行分组，然后对其他字段中的数据进行适当的计数或汇总。我以前使用过Groupingcollections，但仅在绑定到分层控件(如Adva
浏览 3提问于2011-09-24得票数 0
2回答
我想根据两个方向上的两列对我的dataframe元素进行分组。这是一个用过的数据格式的示例。, "A"), ("B", "A"),("A", "C"), ("B", "A"), ("C", "D"),("D", "C"), ("A", "C"), ("C", &qu
浏览 2提问于2021-11-09得票数 1
回答已采纳
我有一张桌子，上面有我要分组的记录。某些列可以包含一些不同的值，例如：1----Candy--------23.441----CAND---------8.18
“列'PRODUCT‘在select列表<
浏览 3提问于2014-02-26得票数 0
回答已采纳
2回答
在选择我正在使用的多个元素代码的sql spark中，是否有按表分组的方法：df.createOrReplaceTempView("GETBYID")val sqlDF = spark.sql(
"SELECT count(customerId)
浏览 7提问于2017-01-02得票数 2
回答已采纳
1回答
"z", 16),("y", 18),("x",3),("w",39),("v",98), ("u", 88)))
val df1 = spark.createDataFrame(rdd1).toDF("id1", "val1")
val df2 = spark.createDataFrame(rdd2).toDF(&
浏览 2提问于2019-06-27得票数 1
回答已采纳
我的目标是-找出用户'a‘在每个区域花费了多少时间，按什么顺序？SQL窗口函数可以用于此目的。除了组中的最后一个条目外，regionTimeEnd列只是regionTimeStart的'lead‘。我看到聚合操作有'first‘和'last’函数，但为此我需要基于('uid'，' region ')对数据进行分组，这会破坏遍历的路径的单调递增顺序，即在时间13,14用户已返回区域' 1‘，我希望保留
浏览 1提问于2016-02-10得票数 1
我想做的是按键对元组进行分组，为了使其更有趣，将分组值的长度限制为任意数(例如3)。
浏览 3提问于2020-07-02得票数 1
回答已采纳
1回答
我希望使用Spark对数据帧的每一列执行Group。Dataframe将有大约。1000列。val df = sqlContext .format("org.apache.spark.sql.cassandra")channelDf.groupBy(c).cou
浏览 0提问于2019-08-12得票数 1
回答已采纳
我有一个包含列id和几个字符串列的.csv文件。我想按id分组，然后将string_column1中的所有值写入一个文本文件(每个值在一个新行上)。我在Java中使用Apache Spark。我不知道如何使用id列中的不同值来命名文本文件。import org.apache.log4j.Level;import org.apache.
浏览 2提问于2019-11-02得票数 0
3回答
我正在尝试从一个Hive表中检索列列表，并将结果存储在一个中。var my_column_list = hiveContext.sql(s""" SHOW COLUMNS IN $my_hive_table""")import or
浏览 8提问于2016-11-08得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
