我正在尝试将SQL代码转换为Pyspark。在从表中选择列时，Select语句具有如下内容：
Select a.`(column1|column2|column3)?+.如何解决这一问题，同时将sql转换为pyspark？
浏览 2提问于2022-02-11得票数 0
回答已采纳
1回答
我有以下SQL语句：-- How many questions answered correct in thatfrom freecourse_info_step_7我将Pyspark转换为
column_list = ["hacker_rank_id", "
浏览 0提问于2020-08-12得票数 0
1回答
在将一些SAS代码转换为PySpark的过程中，我们在此代码中为where语句使用了一个宏变量。在适应PySpark的过程中，我试图向where语句传递一个日期列表，但是我总是会出错。我希望SQL代码能够从这3个月中提取所有数据。有什么指示吗？month_list = ['202107', '202108', '202109']
sql_query = """
浏览 7提问于2022-01-20得票数 0
回答已采纳
我有一个由函数生成的列表。当我在列表中执行print时：我获得：但是，当我想使用以下命令创建一个DataFrame时：我收到一条错误消息：
浏览 1提问于2016-08-07得票数 7
回答已采纳
1回答
我在MySQL中有一条语句，我正在尝试将其转换为PySpark： my_table_name = default_engagements
UPDATE """ + my_table_name + ""808000000298' END WHERE Engagement IS NULL OR Engagement RLIKE '^[a-zA-Z]'; """ 我在python spark中找到了这个例子： from pyspa
浏览 15提问于2019-09-24得票数 1
回答已采纳
2回答
我希望在PL/SQL中将update语句转换为select语句。例如，应该将update temp set b='apple' where a=1转换为select count(*) from temp where a=1
浏览 0提问于2019-07-05得票数 0
回答已采纳
1回答
Hi Stackoverflow fams：
我对pyspark是个新手，正在努力学习尽可能多的东西。但现在，我想在pysprak中将GUID转换为整数。我目前可以在SQL中运行以下语句将GUID转换为int。，并在sql查询中添加上面的语句。有没有一种方法可以将"CHECKSUM“函数添加到pyspark中，或者使用另一种pyspark方法来做同样的事情？from awsglue.con
浏览 6提问于2021-05-14得票数 1
3回答
蜂巢兽人返回零
、、、
我正在创建hive外部表ORC (位于S3上的ORC文件)。CREATE EXTERNAL TABLE Table1 (Id INT, Name STRING) STORED AS ORC LOCATION 's3://bucket_name'Select * from Table1;+-------------------------------------+---------------------------------------++--------------------
浏览 7提问于2017-10-24得票数 1
1回答
如何才能以有问题的方式(pyspark)实现sql MERGE INTO语句。我有两个表，我使用createOrReplaceTempView选项将它们转换为临时视图。然后，我尝试在这两个临时视图上使用MERGE INTO语句。但它正在失败。原因可能是SPARK SQL不支持合并。有人能给出一个提示吗?如何在pyspark中以编程方式实现一个简单的MERGE INTO SQL等价语句(类似下面的内容)？
浏览 0提问于2018-08-05得票数 8
我是pyspark和python的初学者，并试图将我的SAS宏之一转换为pyspark，但无法找到与SAS中的扫描功能等价的有用资源，而且在EMR studio pyspark集群中执行when循环也有困难我正在尝试将下面的SAS宏转换为pyspark，谢谢大家。
浏览 6提问于2022-11-22得票数 0
2回答
我正在处理将SQL代码转换为PySpark代码，并遇到了一些SQL语句。我不知道如何在pyspark中使用case语句？我计划创建一个RDD，然后使用rdd.map，然后做一些逻辑检查。
浏览 2提问于2016-10-12得票数 24
1回答
我需要将pandas DataFrame对象转换为一系列重现该对象的SQL语句。()方法，该方法允许通过SQLAlchemy引擎将整个DataFrame转储到数据库。我无法将SQLite内存中的数据库转储到SQL语句，我也找不到能够将SQL语句转储到文件中而不是执行它们的sqlalchemy驱动程序。有没有办法将所有作为SQLAlchemy<em
浏览 26提问于2018-12-18得票数 2
1回答
使用regex语句的case语句
、、、、
在代码中，我将从另一个已转换为临时视图的dataframe创建一个dataframe。然后，我将使用sql查询在最后一个查询中创建一个新字段。我想要创建的字段的代码最初来自postgresql，我想知道在pyspark中正确版本的case语句和regex是什么？代码：from pyspark.context import SparkContext
from pyspark.sql
浏览 1提问于2021-04-16得票数 0
回答已采纳
在PySpark (v1.6.2)中，当使用指定的模式将RDD转换为DataFrame时，值类型与模式中声明的值类型不匹配的字段将转换为null。from pyspark import SparkContextfrom pyspark.sql.types import StructTypesqlContext.createDataFrame(rd
浏览 27提问于2016-07-27得票数 0
回答已采纳
我想将pyspark.sql.dataframe.DataFrame转换为pyspark.rdd.RDD[String]data = df.rddtype (data)新的RDD data包含Rowtype(first)R
浏览 2提问于2016-02-17得票数 8
回答已采纳
在postgresql中使用ceil()时，我发现了一些奇怪的行为，请参见SQL： *, ceil( (58*5)/100 ), XYZceil( (550*0.5)/100 )返回3(将2.75转换为3)如果
浏览 0提问于2018-01-04得票数 1
回答已采纳
1回答
我正试图在databricks中将SAS proc transpose语句转换为pyspark。=['ver'], values='finc stress') .reset_index())
有没有办法将PROC转置的SAS逻辑转换成派斯喀斯特而不是使用熊猫？/sql/group.py in agg(self, *e
浏览 32提问于2022-05-11得票数 0
回答已采纳
如何将存储过程执行结果中的DateTime2转换为DateTime？我有一个过程，它将执行一个动态形成的sql语句，该语句将输出各种列，其中包含一些datetime2数据类型。我如何将datetime2更改为datetime，因为我必须将此过程作为数据源分配给crystal report，但crystal report将datetime2转换为string，而string无法在报告中执行所需逻辑
浏览 2提问于2013-03-22得票数 0
回答已采纳
我尝试了以下几种方法：%%pysparkselect * from silver.employee_dim
浏览 23提问于2021-06-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
