在Spark SQL中，我想创建一个名为"CHANGE_SEQUENCE“的列，其中的逻辑是THEN 1 CASE WHEN CHANNEL_CHANGED200 | 7 | TRUE | 31 | 300 | 300 | 9 | FALSE | 3
自从前3个记录以来，客户观看了频道100，它是一个组
浏览 12提问于2017-08-10得票数 0
回答已采纳
1回答
我有一个包含人员列表和持续时间值的表，我需要将表中每个人的总持续时间相加，并显示每个人的记录数。如果某个人有足够的记录，他们的总和超过3小时，那么我需要为该人生成2个组，或者将总数保持在3以下所需的组数。基表中没有单个条目包含持续时间> 3，因此有效的组集始终是可能的。我目前的解决方案是使用游标遍历已排序的表，并在累计总小时数超过3小时时将新组输出到临时表。temorpary表还包括一列逗号分隔的id值列，用于组成分组的基表中的每一行。是否也可以将聚合连接回基表，这样我就有了<em
浏览 0提问于2011-12-10得票数 2
回答已采纳
我有一个数据框架： from pyspark.sql import SparkSessiondf = spark.createDataFrame([("a", "65"), ("b", "23"),("c", "65"), ("d", "23&q
浏览 27提问于2019-04-12得票数 0
回答已采纳
在SQL中，根据某个条件对记录进行分组，为每个组分配一个批号，然后为批/组中的每个记录分配一个序列号(事务号)，最有效的方法是什么？我们可以有多个组，每组最多可以有5000份记录。将批号分配给每个组是没有问题的，但是在每个组内分配自动增量号需要花费很长时间。假设在5个不同的地区有7000名客户
我们必须按地区(5批)对客户进行分组，并为每个地区<em
浏览 6提问于2015-01-02得票数 0
我在scala中有一个数据框架，如A- 0.2A- 0.3B- 0.8我想添加一个行id列作为
类别?得分?我已经有了一个排序的dataframe，所以所有具有相同类别的行都分组在一起。但是，我仍然不知道如何生成当新类别出现时重新启动的row_id。请帮帮我！
浏览 0提问于2018-09-19得票数 1
回答已采纳
1回答
SSRS报告，它将类别显示为x轴，子类别显示为y轴，产品显示为数据。每个类别都有自己的子类别，因此我将在列组中为每一行组显示子类别。是否可以在SQ
浏览 1提问于2013-09-06得票数 3
回答已采纳
在SQL server2005中，我必须更新表中的多行(29)。BEFORE
D 1 AFTER
B 2 D 4
如何使用升序序列号高效地更新每一行？
浏览 0提问于2012-10-10得票数 5
回答已采纳
1回答
我正在使用一个带否定的数据日志版本。我正在尝试编写一个程序，为关系中的每一行分配递增的序列号。示例：items("a", "b") items("a", "c") items("b", "b")items_with_seq
浏览 3提问于2017-11-03得票数 0
1回答
根据组中的其他项为组中的项分配值
、、、、
我试图根据输入字符串是否位于组中另一个字符串的开头为组中的每一行分配一个值。例如，"hello“位于"hello world”的开头，因此这两种类型的值都被指定为“在一起”。“再见”没有分配“在一起”值，因为它不在组中另一个字符串的开头。goodbye'),('1', 'hello world, goodbye earth'),('2&#
浏览 5提问于2019-06-25得票数 0
回答已采纳
1回答
我在scala中乱搞Spark，并收到以下错误：spark.sql("select add from df FOR (select ,add ,none) where select = 1 "
浏览 4提问于2022-01-29得票数 0
回答已采纳
我有一个有10609行的dataframe，我希望一次将100行转换为JSON，并将它们发送回一个webservice。我尝试使用SQL的限制子句，如这将返回前100行，但如果我想要下temptable = spark.sql("select item_code_1 from join_table l
浏览 0提问于2019-04-15得票数 4
1回答
我是Spark的新手。我有一个应用程序，通过调用spark-shell来运行每个spark sql查询。因此它将生成一组如下查询，并调用spark-shell命令逐个处理这些查询。val Query=spark.sql(“从default.movieTable”中选择userid为userid，rating为rating，movieid为movieid )；
现在我想使用s
浏览 0提问于2018-10-16得票数 0
我有一个卡片表，它有一个名为“position”的属性，默认值为0。cards = Card.where(id: [3,4,7,8]).
单个Activerecord或SQL语句是否可以分配一个递增的值，从而给出这样的结果？
浏览 6提问于2016-12-09得票数 1
回答已采纳
我想要相当于这个熊猫的电火花代码。以下熊猫代码生成可访问名称和索引，其中可以找到可访问的名称： 'atable': ['Users', 'Users', 'Domains', 'Domains', 'Locks'],
'column': ['col_1', 'col_2', 'col_a', 'col_b'
浏览 1提问于2022-09-20得票数 1
回答已采纳
1回答
我有一个简单的流媒体工作，它从卡夫卡主题中提取数据并将其推送到S3。": "4g", "spark.executor.memoryOverhead": "4000",
"spark.port.maxRetries"
浏览 8提问于2020-10-27得票数 2
回答已采纳
1回答
我有一个表，我按每个用户的条目数量来订购。然后，我从这个表中复制这些值，并希望每1000行给出一个序列号。因此，如果一个用户有2000条条目，并且它是最高的，那么他的条目就会得到值1和2(不管他的条目中哪一个得到1和哪个2)。如果下两个用户有501和499个条目，那么他们的所有条目都会得到值3，依此类推。这就是我现在要做的，所以我需要插入一个“每1000个连续行”的条件，但是我不知道应该搜索哪个方向。
浏览 1提问于2016-01-15得票数 0
回答已采纳
我有一个小数据库，用于一个大学SQL类项目。该数据库是关于潜水训练的信息的集合。我尝试了其他一些方法，但无法
浏览 0提问于2018-05-18得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
