1回答
我必须在Spark Sql中旋转才能得到低于结果的结果 ? 我尝试过很多方法，但在AWS Glue中执行起来有点复杂。任何建议都会很有帮助。下面是我已经尝试过的内容， (select * from category_data(for a in (e1, e2)
));```
浏览 13提问于2021-07-27得票数 0
,("yankees-mets",5,17),("yankees-redsox",5,10)).toDF("teams","homeruns","hits")
我希望在团队的列上旋转，对于所有其他列，返回该列的2(或N)个最高值。所以对于洋基大都会和本垒打，它会返回这个，因为他们最高的两支全垒打总数是8分和6分。
在一般情况下，我该
浏览 0提问于2020-09-28得票数 0
1回答
在Scala Spark 2.0.1中，我试图在透视之后聚合多个列：df: org.apache.spark.sql.DataFrame = [a: int, b: int ... 2 more fields]
sca
浏览 3提问于2017-01-23得票数 3
回答已采纳
我对SQL的使用还很陌生。
如果我在SQL中有多个数据集，我想要透视相同的行/列，有没有一种方法可以设置它，使它对所有这些数据集都有效。或者，我仍然必须将我想要透视的列和行的名称。例如，如果我有两张不同的桌子，一张桌子上有苹果，另一张桌子上有桔子。表中显示了每种水果在某一天的数量。如
浏览 7提问于2019-08-06得票数 0
我无法在groupBy函数中指定列列表以及窗口操作。val aggDFrame = dframe.groupBy(groupCols, window($"EVENT_TIME", "60 minutes")).agg(Rule_Agg)这一行中的多个标记:重载的方法值String*)org.apache.spark.sql.RelationalGroupedDataset：(col1: String，c
浏览 4提问于2020-10-30得票数 0
回答已采纳
1回答
我正在尝试使用Spark将一行转换为多行。我的目标类似于SQL UNPIVOT。12345|is_male|1|is_college_educated|1用户希
浏览 2提问于2017-10-24得票数 0
1回答
我知道我可以“引爆”一列类型数组，如下所示：import org.apache.spark.sql.functions.explode payloadLegsDf.withColumn("legs", explode(payloadLegsDf.col("legs")))
现在我有多个行；数组中的</e
浏览 0提问于2018-06-21得票数 11
回答已采纳
下面是我在熊猫身上经常做的事情 cdr = datamonthly.pivot(index="msisdn", columns="last_x_month", values="arpu_sum").add_prefix('arpu_sum_l').reset_index() 但我在皮斯帕克所做的 cdr = datamonthly.groupBy("msisdn").pivot("last_x_month").sum("arpu_
浏览 55提问于2021-08-31得票数 0
回答已采纳
1回答
TSQL透视多列
、、、
Gearing Ratio Performance Ratio我承认，我对下一步要做什么才能产生我需要的结果感到非常困惑
浏览 1提问于2013-10-25得票数 42
回答已采纳
1回答
我们如何在一个数据帧中的多个列上进行透视。例如，这里提到的例子，https://spark.apache.org/docs/latest/sql-ref-syntax-qry-select-pivot.html SELECT * FROM person我们不能在Spark scala的pivot方法中传递多个参数，因为它只需要一个列名作为参数。我们如
浏览 11提问于2021-01-17得票数 0
回答已采纳
1回答
FROM TBL1 在那之后，我正在使用下面的PySpark代码读取新创建的位置(TBL2)下面的文件。但是，下面的data frame仅使用lowercase中的所有列名创建。而预期的结果是在camel case中，就像我在上面对CTAS所做的那样。df = spark.read.format('ORC') \ .option('hea
浏览 12提问于2019-12-23得票数 1
回答已采纳
任何人都可以给我一些关于数据透视表的指导，在python语言中使用spark dataframe，我得到了以下错误:Column is not iterable
有谁知道吗？
浏览 0提问于2019-10-04得票数 1
当行中的某些列值与Source表中的相同列值匹配时，我希望更新databricks中的目标Delta表。
问题是当源表中有多个行与目标Delta表中的一行匹配时。在这种情况下，源表中两个或两个以上行的主键与delta表中的一行主键匹配。(sql</e
浏览 2提问于2020-06-08得票数 0
回答已采纳
1回答
我目前正在尝试对Pyspark dataframe上的值进行透视后获得的列的别名。这里的问题是，我在别名调用中输入的列名没有正确设置。一个具体的例子：import pyspark.sql.functions as func
(217498, 100000001=false) AS ts_count#4L',
'C_(av
浏览 9提问于2017-01-25得票数 7
我已经制定了以下动态SQL查询，将未知数量的行值(Maschine名称为nvarchar)转换为列。旋转列的行值应该是特定机器的停机时间和维护时间(两者都是整数)的总和。DECLARE @columns NVARCHAR(MAX), @sql NVARCHAR(MAX);SELECT @columns += N', p.' +QUOTE
浏览 2提问于2013-10-23得票数 0
3回答
我需要在pyspark dataframe中透视多个列。101,2,45,13),(101,3,67,14),(101,4,78,15),(102,1,23,10),(102,2,45,11),(102,3,67,16),(102,4,78,18)]>>> pvtdf = myd
浏览 14提问于2017-07-11得票数 27
回答已采纳
2回答
转置PySpark数据帧
、、、、
如何转置以下PySpark数据帧？ 以下是pyspark数据帧。 +----+------+-----+-----+-----+-----+-----+-----+-----+-----+-----+----------------+--------+------++----+------+-----+-----+-----+-----+-----+-----+-----+-----+---
浏览 14提问于2020-12-03得票数 1
回答已采纳
我有一个包含字符串列的数据框，我想在其中创建多个列。
我想从它创建多个列。字符串的格式是相同的- col1:value1 col2:value2 col3:value3 ... colN:valueN。在输出中，我需要多个列- col1 to colN，值作为每列的行。
浏览 23提问于2021-06-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
