我尝试做一个声明，如果EDW_ABC.edw_xdpt_act_arrv_lb为空，则使用EDW_ABC.edw_putt_act_arrv_lb，如果两者都为空，则将值设置为0。我该怎么做？我正在尝试下面的方法，我知道它是不正确的。F.lit(0)\
.otherwise(EDW_ABC.edw_xdpt_act_arrv_lb.isNull()),
浏览 19提问于2021-10-25得票数 1
如果我在工作簿A中运行一个计算成本很高的pyspark转换，并试图在工作簿B中运行某些内容，则这两个队列都将永久排队，直到工作簿A中的构建停止，然后工作簿B中的生成立即运行，就好像它在等待工作簿A中的构建
浏览 5提问于2022-03-24得票数 0
回答已采纳
1回答
在PySpark中给出的ALS示例中，根据本文档-- )，使用的数据在一列中具有显式反馈。这些数据是这样的:收人品的收视率高我知道我们可以通过将implicitPrefs设置为
浏览 5提问于2022-06-17得票数 0
我想当userid=22650984.How在pyspark平台上更新它的价值?谢谢你的帮助。
浏览 8提问于2018-04-08得票数 11
回答已采纳
1回答
我正在尝试使用时间更新PySpark数据帧中的列。我正在使用数组检查多个条件。我得到了错误'Cannot convert column into bool'。我假设这是因为我使用in来检查一个值列表。该错误提供了其他选项，如和(&)和(或)，但不能用于in。是否有什么方法可以对所有的值进行检查，而不是链接几个there语句</e
浏览 1提问于2018-05-23得票数 0
回答已采纳
我正在使用Openrowset导入具有"Status“列的excel，该列的值可以是”TRUE/FALSE/ can“。我已经用TypeGuessRows=0设置了相应的注册表。当excel文件中的status列包含TRUE/FALSE/canced值时，如所期望的那样作为文本<
浏览 1提问于2017-11-29得票数 0
当我阅读Spark/Hive文档时，将插入到带有列列表的表中，在Spark2.4和更早版本中不支持。
我有一个源表和一个目标表，它们有不同的列数和不同的列名，我需要复制它们。这是否意味着我必须在PySpark中编写此代码以完成此工作，因为Spark将无法完成此任务？，如MS、PostgreSQL等)，我将</e
浏览 1提问于2019-01-09得票数 4
回答已采纳
芬兰的SQL转换至少提供了两种编写逻辑代码的方法: Python和纯文本SQL。我已经注意到了一些不同之处：在某些方面我错了，还有其他区别(例如执行时间、消耗资源)吗？
浏览 2提问于2022-02-05得票数 0
回答已采纳
1回答
我正在使用一个select语句(5个字段)使用联接从多个表中获取一些字段。
我必须将这些值插入另一个表表-B表中，它有更多的列(10列)。
如何在Table_B (如Col1 )中将这些值插入到Alias中的id列和Col2，以及在emp_age和Col4中
浏览 1提问于2022-09-13得票数 0
1回答
在Postgres中，我有一个名为"mytable“的表，其中有两个列，id (bigint)和value (varchar(255))。id使用nextval('my_sequence')从序列中获取其值。PySpark应用程序接受一个dataframe并使用postgresql(PostgreSQL42.1.4.jar)将数据插入到"mytable“中。我
浏览 0提问于2018-01-21得票数 2
回答已采纳
我有一个dataframe，我正在尝试基于现有列的值创建一个新列： F.when(dfg['list'].isin(["A","']) .when(dfg['list']=="D&q
浏览 14提问于2018-02-01得票数 0
NULL", 5.0),]).toDF()
现在，我希望将NULL、NA和NaN替换为(None)值。如何在多个列一起实现它。df = df.withColumn("v", replace(col("v"), &qu
浏览 9提问于2017-12-06得票数 0
回答已采纳
3回答
我有一个Person表，其中有多个列表示该人所声明的种族(例如，非洲裔美国人、西班牙裔、亚洲人、白人等)。允许多种选择(如白色和亚洲)。如果选择了特定的族裔，列值为1，如果没有选择，则为0，如果完全跳过族裔问题，则为NULL。
我希望制定一个SELECT查询，该查询将检查多个族裔列，并返回一个文本值，该值是基于值为</e
浏览 3提问于2013-11-22得票数 1
回答已采纳
这个问题在这里已经有答案了 ： 如何在Spark SQL中使用连字符转义列名 (3个答案) 列名中包含破折号/连字符的PySpark Sql (1个答案) 使用selectExpr选择其中包含特殊字符的spark dataframe列 (1个答案) 如何在SparkContext中处理dash的SQL请求 (1个答案) 3个月前就关门了。我正在尝试基于多个CASE
浏览 70提问于2020-11-30得票数 0
我正在使用PySpark分析Palantir Foundry中的一些JSON数据。源是一个30 60上传的JSON文件，包含四个元素，其中一个包含大约60列和20,000行的表。该表中的某些列是包含表示UTF字符的HTML实体的字符串(其他列是数字或布尔列)。我想清理这些字符串，用相应
浏览 20提问于2022-10-24得票数 2
回答已采纳
在板岩铸造厂中，我会以编程方式修改下拉列表的参数。更改显示值或禁用值。但不起作用。我的代码select.selectedValue = "202201"console.log({{w_selectEndMonthYear}})在我<
浏览 1提问于2022-08-12得票数 1
回答已采纳
在一个比率列中有多个值20invalidtextNA#NA"^0-9" // If input value is not anumeric value (0-9) then replace it with null
但这将用null替换列中的所有文本值，我只想使用</em
浏览 0提问于2019-10-09得票数 0
我试图使用Glue和pySpark在AWS上执行ETL工作，但不幸的是，我对此非常陌生。
在大多数情况下，我没有任何问题，使用胶水动态数据，以执行应用程序和一些其他的转换，我必须执行。但是，我面临一个特定列的问题，必须将其从字符串转换为整数数组。在这个列value中，我们将数据类型设置为string，它实际上是一个转换为string并由空格分隔<
浏览 5提问于2020-04-20得票数 2
回答已采纳
这可能是没有意义的，但我希望在一个查询中，当合格等于1时，只需要第二个值，但总是更新第一个值。因此，如果合格的值已经是0(或其他值)，就不要更新合格的值。我可以在一个查询中做到这一点吗？---Looping through this SET p.first= 'C', p.eligible = 0
WHERE i
浏览 17提问于2020-07-16得票数 0
我正在做一个尖峰，我们想发布数据，因为它是写在卡桑德拉表卡夫卡的主题。我们正在研究使用Kafka Connect和Stream反应堆连接器。json_doc列的值。，以便只将json_doc的值写入主题，使其看起来如下所示：似乎是可行的，但它并不限制写入KCQL中指定的列的内容。-1bce55915fdd,jso
浏览 6提问于2017-02-28得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
