如何根据Pyspark中的单元格值重命名列？
在Pyspark中，要根据单元格值重命名列，可以通过使用withColumnRenamed函数来实现。该函数可以将DataFrame中的某一列重命名为新的列名。
具体步骤如下：
- 首先，导入必要的库和模块：
from pyspark.sql import SparkSession
from pyspark.sql.functions import col, when- 创建SparkSession对象：
spark = SparkSession.builder.appName("ColumnRenaming").getOrCreate()- 创建一个示例DataFrame对象：
data = [("John", 25), ("Alice", 30), ("Bob", 35)]
df = spark.createDataFrame(data, ["Name", "Age"])
df.show()输出：
+-----+---+
| Name|Age|
+-----+---+
| John| 25|
|Alice| 30|
| Bob| 35|
+-----+---+- 使用withColumnRenamed函数根据单元格值重命名列：
new_column_name = "NewName"
df = df.withColumnRenamed("Name", when(col("Name") == "John", new_column_name).otherwise(col("Name")))
df.show()输出：
+-------+---+
|NewName|Age|
+-------+---+
| John| 25|
| Alice| 30|
| Bob| 35|
+-------+---+在上述代码中，我们使用了withColumnRenamed函数将"Name"列重命名为"NewName"列，当单元格的值为"John"时进行重命名操作，否则保持原列名不变。
需要注意的是，Pyspark中的withColumnRenamed函数不会修改原始的DataFrame，而是返回一个新的DataFrame对象。
关于Pyspark的更多信息和详细介绍，可以参考腾讯云的Pyspark相关产品和文档：
- 腾讯云Pyspark产品介绍：Pyspark产品介绍
- Pyspark文档：Pyspark官方文档
相关·内容
5回答
查看新的spark API，还不清楚是否有可能修改DataFrame列。
如何更改数据文件的行x列y中的值？
在pandas中，这将是：
df.ix[x,y] = new_value
编辑：合并下面所说的内容，您不能修改现有的数据格式，因为它是不可变的，但是您可以返回一个新的数据格式，并进行所需的修改。
如果只想根据条件替换列中的值，如np.where
from pyspark.sql import functions as F
update_func = (F.when(F.col('update_col') == replace_val, new_value)
浏览 12提问于2015-03-17得票数 95
回答已采纳
当我在熊猫中加载数据时，df列显示为
tablename.columnname1 | tablename.columnname2 | tablename.columnname3| ..... | tablename.columnnameN
我如何使它只显示为
columnname1 | columnname2 | columnname3| ..... | columnnameN
这些数据是在火星雨上处理的，最初是从蜂巢中检索的。当我在pyspark上显示df时，列名显示为正常，而前面没有表名。
在完成该过程后，它将再次以schemaname.tablename的形式写入单元格中的架构中。
当我
浏览 1提问于2021-03-09得票数 0
回答已采纳
我有以下的一小段代码。
# do all the required imports
import pyspark
import pandas as pd
from pyspark.sql.functions import udf
from pyspark.sql import SparkSession
#create a session
spark = SparkSession \
.builder \
.appName("Python Spark SQL basic example") \
.config("spark.some.config
浏览 11提问于2018-08-22得票数 2
1回答
在Postgres中，我有一个名为"mytable“的表，其中有两个列，id (bigint)和value (varchar(255))。
id使用nextval('my_sequence')从序列中获取其值。
PySpark应用程序接受一个dataframe并使用postgresql(PostgreSQL42.1.4.jar)将数据插入到"mytable“中。我使用以下方法创建id列：
df.withColumn('id', lit("nextval('my_sequence')"))
Postgres将该列解释
浏览 0提问于2018-01-21得票数 2
回答已采纳
1回答
我尝试在pyspark中对两列进行左连接，其中只有一列的名称是相同的： 如何删除连接的数据帧df2.date和df2.accountnr的两列 dfAll = (
df1
.join(df2,
[df1.order_date == df2.date, df1.accountnr== df2.accountnr],
how = 'left')
) 不幸的是，添加.drop(df2.date, df2.accountnr) (错误: col应该是一个字符串)或.drop('date', 'accountn
浏览 30提问于2019-02-10得票数 0
2回答
我在AWS、table_1和table_2中有两个表，它们的模式几乎相同，但是table_2有两个额外的列。我试图将这两个表连接到相同的列上，并为模式不包括这些值的“旧”数据添加对table_2唯一的列，并将其为空值。
目前，我可以使用类似于以下内容的方法加入两个表：
joined_table = Join.apply(table_1, table_2, 'id', 'id')
其中第一个' id‘是table_1中的id列，第二个'id’是table_2中的id列。这个调用成功地将表连接成一个表，但是，生成的joined_table具有匹配列的
浏览 0提问于2018-02-13得票数 4
2回答
我有一个JTable，并在其中添加了一个DefaultTabelModel。当用户右键单击表中的单元格时，我创建了一个弹出菜单。菜单中的项目之一是“重命名”。单击重命名项时，如何使选定的单元格可编辑？我已经设置了所有元素，这里唯一缺少的部分是使选定的单元格可编辑。
在这里，isCellEditable(row, col)方法在DefaultTableModel中没有帮助，因为它根据单元格在表中的位置(即行和列)而不是单元格的选择状态来设置单元格的可编辑性。
我怀疑我将需要TableCellEditor，但我不知道如何使用它。我非常希望提供一个示例代码，说明如何实现这一点，并/或解释如何为此目的
浏览 1提问于2018-09-14得票数 1
回答已采纳
1回答
我正在尝试从Apache中的另一列中创建一个新列。
这些数据(大量缩写)看上去像
Date Day_of_Week
2018-05-26T00:00:00.000+0000 5
2018-05-05T00:00:00.000+0000 6
而且应该看起来像
Date Day_of_Week Weekday
2018-05-26T00:00:00.000+0000 5 Thursday
2018-05-05T00:00:00.000+0000 6 Friday
我尝试过 & & 手册中的建议
其结果是：
def int2da
浏览 0提问于2018-10-26得票数 0
回答已采纳
我必须对dataframe的"activity“列执行group和pivot操作，并用"quantity”列之和填充由pivot产生的新列。但是，其中一个活动列必须使用“成本”列的总和填充。
分组和支点之前的数据帧：
+----+-----------+-----------+-----------+-----------+
| id | quantity | cost | activity | category |
+----+-----------+-----------+-----------+-----------+
| 1 | 2
浏览 1提问于2022-08-01得票数 0
回答已采纳
我正试着在熊猫里做运动。
我有两张数据。如果比较成功，我需要比较两个dataframe之间的几个列，并更改第一个dataframe中一个列的值。
Dataframe 1：
Article Country Colour Buy
Pants Germany Red 0
Pull Poland Blue 0
最初，我所有的文章都将标志'Buy‘设置为零。我有dataframe 2，它看起来是：
Article Origin Colour
Pull Poland Blue
Dres
浏览 3提问于2019-09-23得票数 0
回答已采纳
我正尝试在PySpark中批量重命名我的列，从： 'collect_list(Target_Met_1)[1]' --> 'AB11'
'collect_list(Target_Met_1)[2]' --> 'AB12'
'collect_list(Target_Met_2)[1]' --> 'AB21'
'collect_list(Target_Met_1)[150]' --> 'AB150' 我如何以编程方式在中处理它？现在，我可
浏览 99提问于2019-06-22得票数 1
回答已采纳
我有一个带有n个cols的percentage ( df )，我想要生成另一个n cols的df，其中每一列都记录相应的原始df列中的b/w连续行的百分比差。新df中的列标题应该是旧dataframe + "_diff“中相应的列标题。使用下面的代码，我可以为原始df中的每一列生成百分比变化的新列，但无法将它们插入具有适当列标题的新df中：
from pyspark.sql import SparkSession
from pyspark.sql.window import Window
import pyspark.sql.functions as func
spark = (Sp
浏览 0提问于2018-05-31得票数 0
回答已采纳
2回答
我带了下面的电子表格给熊猫看：
我进口它时：
import pandas as pd
df = pd.read_excel("sessions.xlsx")
朱庇特像这样展示了它：
然后，我将数据传输到
df = df.T
这导致了这个
在这个阶段，我现在如何更改最左边索引列中的文本？我想将单词Day更改为服务，但我不知道如何处理该单元格/标头。我不能引用第0列并为此更改标题。
同样地，我如何继续修改A，B，C，D文本，它现在是索引列？
浏览 1提问于2019-02-20得票数 0
2回答
我有一个csv，currentData.csv，它是通过运行脚本生成的：
| first | last | isStudent | height_in | weight_lbs | age | favColor |
| Jane | Doe | 21 | red | True | 62 | 146.3 |
| John | Doe | 19 | blue | False | 59 | 162.2 |
我的脚本在错误的位置添加了两个列名，因此您可以看到firstName和lastName行中
浏览 8提问于2019-07-28得票数 1
回答已采纳
我有一个PySpark DataFrame df，它有一些列，如下所示。hour列采用UTC时间，我想创建一个基于time_zone列的具有本地时间的新列。我如何在PySpark中做到这一点？
df
+-------------------------+------------+
| hour | time_zone |
+-------------------------+------------+
|2019-10-16T20:00:00+0000 | US/Eastern |
|2019-10-15T23:0
浏览 2提问于2019-12-03得票数 5
回答已采纳
如何根据某些单元格之间的验证来更改列的值？我需要的是比较每个客户的(id)记录的千米值，以比较紧跟在千米值之后的记录是否更高。 fecha id estado id_cliente error_code kilometraje error_km
1/1/2019 1 A 1 10
2/1/2019 2 A ERROR 20
3/1/2019 1 D 1 ERROR
浏览 44提问于2019-07-04得票数 0
我在pyspark中有一个超过300列的数据框架。在这些列中，有一些列的值为null。
例如：
Column_1 column_2
null null
null null
234 null
125 124
365 187
and so on
当我想对column_1求和时，我得到的结果是一个空值，而不是724。
现在，我想用空格替换数据框所有列中的null。所以当我尝试对这些列求和时，我不会得到空值，但我会得到一个数值。
我们如何在pyspark中实现这一点呢？
浏览 1提问于2017-02-18得票数 56
回答已采纳
我希望使用Spark DataFrame的PySpark在特定的单元格中更改一个值。
简单的例子--我创建了一个模拟Spark DataFrame
df = spark.createDataFrame(
[
(1, 1.87, 'new_york'),
(4, 2.76, 'la'),
(6, 3.3, 'boston'),
(8, 4.1, 'detroit'),
(2, 5.70, 'miami'),
(3, 6.320, '
浏览 4提问于2018-05-17得票数 7
回答已采纳
2回答
在PySpark中，可以使用列对象和字符串来选择列。这两种方法返回相同的结果。有什么不同吗？什么时候应该使用列对象而不是字符串？例如，我可以使用column对象：
import pyspark.sql.functions as F
df.select(F.lower(F.col('col_name')))
# or
df.select(F.lower(df['col_name']))
# or
df.select(F.lower(df.col_name))
或者我可以使用字符串来代替，并得到相同的结果：
df.select(F.lower('col_n
浏览 0提问于2020-11-09得票数 0
我已经导入了一个excel文件来创建PBI报告。在此excel中，有一个包含日期的单元格。我想在这个单元格的基础上创建列。
例如，如果单元格包含2017年1月4日，那么我希望生成像Apr-17，May-17，...，Dec-17，Jan-18，...，Mar-18这样的列名。
有没有办法做到这一点呢？
浏览 0提问于2017-09-25得票数 0
我有两个数据文件，如下所示。预期产出也低于预期。数据格式的差异出现在“学院”列中，而第二个数据格式则缩短了一行。当df2和student_NAME匹配时，我想用df1中的'college‘栏代替student_ID中的'college’列。有人知道如何获得预期的输出吗？
import pyspark
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('sparkdf').getOrCreate()
# list of students data
da
浏览 1提问于2022-10-04得票数 -1
1回答
我有两个数据帧，如下
DF1 -包含过去1个月的数据
root
|-- id: integer (nullable = true)
|-- name: string(nullable = true)
|-- age: string (nullable = true)
|-- createdDate: long (nullable = false)
|-- school: string(nullable = true)
DF2 -包含今天的数据
root
|-- id: integer (nullable = true)
|-- name: string(nullable = tr
浏览 0提问于2021-10-04得票数 0
我有一个描述试题的数据集。我想把它和学生们所取得的分数联系起来，并做一些分析。为此，我想把问题文件的细节融为一体。
Question Marks BL PI CO PSO PO
0 Q1 2 2 1.4 1 1 1,2
1 Q2 2 3 2.1 2 1 1,2
2 Q3 2 2 1.1 1 1 1,2
3 Q4 2 2 1.1 1 1 1,2
4 Q5 4 2 1.1 1 1 1,2
我试过了
qns = pd.read_csv('https://raw.git
浏览 4提问于2019-11-17得票数 0
回答已采纳
我有两个清单
List1=['curentColumnName1','curentColumnName2','currentColumnName3']
List2=['newColumnName1','newColumnName2','newColumnName3']
它们是包含所有列的dataframe df。
我想要检查是否在dataframe中存在列'curentColumnName1，如果是，那么将其重命名为newColumnName1，如果所有列都存在于dataframe中，则需要
浏览 1提问于2022-08-18得票数 0
在jqGrid中如何使特定列值的单元格可编辑为true ..我有一个row.Row有一个四个column.In，我想要两个列的单元格可编辑true和两个列的单元格可编辑false..What，我应该做什么？？对这个问题给我一个解决方案
浏览 0提问于2015-06-11得票数 0
我们有一个自动化管道的需求。 我的需求是使用具有固定名称的pyspark生成/覆盖一个文件 但是，我现在的命令是- final_df.coalesce(1).write.option("header", "true").csv("s3://finalop/" , mode="overwrite") 这确保目录(finalop)是相同的，但每次我覆盖它时，该目录中的文件总是以不同的名称创建。 现在，下一个作业读取它不是在pyspark中，所以我们不能自动化管道。我们正在尝试让它读取目录的方法。 但是在pyspark中有没有办法生成
浏览 25提问于2020-10-14得票数 0
回答已采纳
1回答
实现以下目标的最佳办法是什么：
如果A列中的单元格有内容，则将公式放入同一行B列的单元格中，引用A列中的单元格。
处理完公式后，将公式替换为公式返回的原始值。
浏览 0提问于2023-03-16得票数 0
在Excel中，如何将单元格样式保存在具有来自另一个工作表的数据验证列表的列中？
我有一张有选择列表的工作表，每个选项都是一个有自己风格的单元格(每个选项的背景色不同)。在用户输入值的工作表中，单元格如何获得与从验证数据中选择的选项相同的样式？
例子:列表名"myList“
工作表“List”的"myList“单元格范围为3，每个单元格都有一个值和一个样式背景色。(“项目1”有红色背景，第2项有黄色背景，等等)sheet " data“有一个列，其数据验证为"myList"，当我选择其中一个选项时，单元格保持它的默认样式。
在选择数据验证列表中的选项时，
浏览 0提问于2011-07-01得票数 0
回答已采纳
1回答
我的PipelinedRDD中有一列标称值，为了分类目的，我想将其转换为索引编码。
我曾经在pyspark.ml中使用pyspark.ml，这是非常容易使用的。然而，这一次我正在学习如何处理rdd而不是数据格式，而且在pyspark.mllib中没有这样的东西。
任何帮助都是非常感谢的。
浏览 0提问于2018-02-14得票数 1
回答已采纳
1回答
在谷歌上搜索这是没有效率的，因此在这里发布。
我在D和E列中有可用的数据，当向A列中添加数字时，我需要Excel来检查它是否存在于列D中。我可以使用MATCH函数( A1不匹配，但是A2和D3之间存在匹配)来检查它是否存在。
我所缺少的是，如果A和D列之间存在匹配，我还需要将E列中的数据粘贴到B列中。也就是说，在单元格A2的D3中找到匹配项时，单元格B2中应该填充单元格E3中的数据(文本“黄色”)。
我把C列留给了公式，但这并不重要。如何处理这样的事情？没有必要绝对使用匹配。
A B C D E
13 #N/A 25
浏览 3提问于2017-11-02得票数 0
回答已采纳
我正在将聚合函数应用于pyspark中的数据框架中。我使用字典传递列名和聚合函数。
df.groupBy(column_name).agg({"column_name":"sum"})
现在，我想对使用聚合方法生成的这个列应用一个别名。有办法吗？
我使用字典方法的原因是聚合将根据输入参数动态应用。
所以基本上就像
def aggregate(df, column_to_group_by, columns_to_aggregate):
df.groupBy(column_to_group_by).agg(columns_to_aggregate)
col
浏览 16提问于2022-02-23得票数 2
如何在不使用pyspark重命名列的情况下，从单行数据框列中计算同一列的平均值、最大值、最小值 我使用了下面的命令，但它抛出了一个错误 df5=df5.agg(avg(col("Salaray")),min(col("Salaray")),max(col("Salaray")))
浏览 22提问于2021-10-29得票数 0
我有一个data frame在pyspark，如下所示。
df.show()
+---+----+
| id|name|
+---+----+
| 1| sam|
| 2| Tim|
| 3| Jim|
| 4| sam|
+---+----+
现在，我向df添加了一个新列，如下所示
from pyspark.sql.functions import lit
from pyspark.sql.types import StringType
new_df = df.withColumn('new_column', lit(None).cast(StringType()))
浏览 1提问于2018-05-02得票数 0
回答已采纳
我有一个问题，我需要动态更新星火数据中的列。
基本上，我需要遍历列列表，如果列已经存在于列表中，将其重命名为该列加上它的索引。
我尝试的代码如下所示：
def dup_cols(df):
for i, icol in enumerate(df.columns):
for x, xcol in enumerate(df.columns):
if icol == xcol and i != x:
df = df.withColumnsRenamed(xcol, xcol + '_' + str(x))
return df
但这个名称按名称
浏览 0提问于2018-12-13得票数 5
回答已采纳
我是PySpark的新手，正面临一个奇怪的问题。在加载CSV数据集时，我尝试将某些列设置为不可为空。我可以用一个非常小的数据集(test.csv)重现我的案例：
col1,col2,col3
11,12,13
21,22,23
31,32,33
41,42,43
51,,53
在第5行，第2列有一个空值，我不想在我的DF中获取该行。我将所有字段都设置为不可空(nullable=false)，但是我得到了一个所有三列都具有nullable=true的模式。即使我将所有三列都设置为不可空，也会发生这种情况！我运行的是Spark的最新版本，2.0.1。
代码如下：
from pyspark.sql
浏览 0提问于2016-10-07得票数 14
回答已采纳
我有一个hive表，它是按插入时间列分区的。
我有一个pyspark dataframe，除了已分区的列之外，它与表具有相同的列。
当表未分区时，以下操作效果很好：
df.insertInto('tablename',overwrite=True)
但是我不知道如何从pyspark插入到一个特定的分区。
下面尝试过：
df.insertInto('tablename',overwrite=True,partition(inserttime='20170818-0831'))
但它不起作用，失败的原因是
SyntaxError: non-keyw
浏览 0提问于2017-09-16得票数 1
1回答
我正在尝试在Excel工作表中显示链接到单元格值的图像
示例-如果单元格A1 =值10，则显示图像(图10)
然后对于另一个单元格
如果单元格A10 -值为90%，则显示图像(图90)。
我已经使用了下面的VBA代码，它在A1上运行良好，但是当我添加第二个单元格值和图片时，它将只显示A1值/图片。
Private Sub Worksheet_Change(ByVal Target As Range)
If Not Application.Intersect(Target, Range("J27")) Is Nothing _
And Not Target.Cou
浏览 0提问于2015-07-21得票数 0
我试图根据pyspark数据格式中的ID列对列进行分组，并根据另一列的值对列进行求和。
为了举例说明，请考虑以下虚拟数据格式：
+-----+-------+---------+
| ID| type| amount|
+-----+-------+---------+
| 1| a| 55|
| 2| b| 1455|
| 2| a| 20|
| 2| b| 100|
| 3| null| 230|
+-----+-------+---------+
我想
浏览 1提问于2019-06-13得票数 0
回答已采纳
1回答
在解析pyspark中不一致的数据类型时，我遇到了一个问题。如下面的示例文件所示，SA键总是包含一个字典，但有时它可以显示为string值。当我尝试获取列SA.SM.Name时，会得到如下所示的异常。
对于SA.SM.Name列，如何将null设置为除了JSONs之外的值的pyspark/hive。有人能帮帮我吗？
我试图转换成不同的数据类型，但是没有工作，或者我可能做错了什么。
输入文件内容: mypath
{"id":1，"SA":{"SM"：{"Name"："John"，"Email"：“Jo
浏览 6提问于2020-10-10得票数 0
在Spark中，我需要减去两列的值，并检查结果的绝对值是否大于某个值。我怎么能这么做？我试过这个：
import pyspark.sql.functions as f
f.abs((f.col("col1") - f.col("col2"))) > 100
但这是抛出PySpark异常。我认为这是因为'abs‘函数接受的是’列‘而不是值。对吗？
如何在Spark中完成我想做的事情？
浏览 21提问于2022-01-24得票数 -2
我想用lambda实现reduce函数。例如，如果有pyspark数据帧，并且在某些列上，我想要获取那些列值长度在某个范围内的所有记录。如何使用带有lambda的reduce函数实现这一点。我试着用下面的代码来实现它，但我对此不是很确定。 bad_df = reduce(lambda x, (min < f.col(x) < max for x in df.columns if x in col_list)) col_list有我想要检查列值是否在范围内的列的列表。
浏览 4提问于2020-08-20得票数 0
2回答
我有一个pyspark，分布在整个集群中，如下所示：
Name ID
A 1
B 2
C 3
我想修改'ID‘列，使所有值成为python字典，列名为键&值作为列中的现有值，如下所示：
Name TRACEID
A {ID:1}
B {ID:2}
C {ID:3}
我如何使用火花放电代码来实现这一点呢？我需要一个高效的解决方案，因为它是一个跨集群的大容量分布式df。提前谢谢。
浏览 11提问于2022-04-04得票数 1
回答已采纳
考虑下面的Excel表
Id Reference Id Name
20059136 Gj
20012323 Am
如何处理Event model XSSFReader中缺少的单元格，在这里读取数据时，跳过列Reference Id并发生一次左移，因此在读取输出中将Name列的所有值附加到Reference Id。
如何使用Apache POI 'XssfReader‘和SheetContentsHandler查找缺少的单元格或空/空白单元格。
如何在一组非常大的文件读取的情况下动态查找
浏览 2提问于2017-05-30得票数 1
我是PySpark的新手。
我只想保留至少有10个值的列
我已经使用describe来获取每列的非空记录的计数
现在如何提取值小于10的列名，然后在写入新文件之前删除这些列
df = spark.read.parquet(file)
col_count = df.describe().filter($"summary" == "count")
浏览 1提问于2019-09-28得票数 1
我刚接触pyspark，我想在pyspark dataframe列中动态地用数字替换名称，因为我的dataframe中有超过500,000个名称。如何继续？
----------
| Name |
----------
| nameone|
----------
| nametwo|
----------
应该变成
--------
| Name |
--------
| 1 |
--------
| 2 |
--------
浏览 9提问于2019-07-25得票数 0
我正在尝试跨多个工作表集成几个表，但全部集成在一个工作簿中。目前，我正在使用Power从所有工作表上的表中获取数据，以便在第一个工作表的概述中显示。
例如，请考虑以下几点：
表1-
Date Time Note
01/02/03 13:59 First entry
03/04/05 08:36 Second entry
表2-
Date Time Type
02/03/04 19:19 Cold
06/07/08 07:22 Hot
概述-
Date T
浏览 5提问于2016-01-24得票数 0
回答已采纳
我需要一些关于如何设置规则来更改基于多个单元格或列颜色的特定单元格的颜色的建议。 示例-单元格A1应更改蓝色n颜色，列B1:B15应包含设定数量的橙色和红色单元格。 对于这种类型的规则配置，您建议的最佳方法是什么？ 提前谢谢。
浏览 11提问于2021-05-06得票数 0
我对pyspark是个新手。我有一个包含ID和BALANCE列的pyspark数据框。我尝试将列balance存储到100% (1-100%)的存储桶中，并计算每个存储桶中有多少个in。
我不能使用任何与RDD相关的东西，我只能使用Pyspark语法。我试过下面的代码
w = Window.orderBy(df.BALANCE)
test = df.withColumn('percentile_col',F.percent_rank().over(w))
我希望得到一个新的列，它可以自动计算平衡列中每个数据点的百分位数，并忽略缺少的值。
浏览 14提问于2019-07-11得票数 0
我在excel中有一列日期，由于单元格格式，它显示为mmm/yy (左列)，而实际上单元格值是完整的dd/mm/yyyy日期(如右列所示)。
如何使左列的实际单元格值与它们显示的mmm/yy文本相同？我尝试过遍历该列并使用cell.value = cell.text，但由于某些原因，它最终将日期更改为其年份。
浏览 1提问于2020-06-03得票数 0
我有包含一些数据的json文件，我将这个json转换为pyspark dataframe(我选择了一些列，而不是所有列)，这是我的代码： import os
from pyspark import SparkContext
from pyspark.streaming import StreamingContext
from pyspark.sql import SparkSession
import json
from pyspark.sql.functions import col
sc = SparkContext.getOrCreate()
spark = SparkSession
浏览 125提问于2019-03-12得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
