将每个组的合计作为新行添加到Pyspark中的dataframe中
在Pyspark中，可以使用groupBy和agg函数将每个组的合计作为新行添加到DataFrame中。
首先，我们需要导入必要的库和创建一个示例DataFrame：
from pyspark.sql import SparkSession
from pyspark.sql.functions import sum
# 创建SparkSession
spark = SparkSession.builder.getOrCreate()
# 创建示例DataFrame
data = [("A", 10), ("A", 20), ("B", 30), ("B", 40), ("C", 50)]
df = spark.createDataFrame(data, ["Group", "Value"])
df.show()输出结果为：
+-----+-----+
|Group|Value|
+-----+-----+
| A| 10|
| A| 20|
| B| 30|
| B| 40|
| C| 50|
+-----+-----+接下来，我们可以使用groupBy和agg函数来计算每个组的合计，并将其添加为新行到DataFrame中：
# 使用groupBy和agg计算每个组的合计
df_with_total = df.groupBy("Group").agg(sum("Value").alias("Total"))
# 将合计添加为新行到DataFrame中
df_with_total = df.union(df_with_total)
# 显示包含合计的新DataFrame
df_with_total.show()输出结果为：
+-----+-----+
|Group|Value|
+-----+-----+
| A| 10|
| A| 20|
| B| 30|
| B| 40|
| C| 50|
| A| 30|
| B| 70|
| C| 50|
+-----+-----+在这个例子中，我们首先使用groupBy函数按照"Group"列对DataFrame进行分组。然后，使用agg函数和sum函数计算每个组的"Value"列的合计，并将其命名为"Total"。最后，使用union函数将原始DataFrame和包含合计的新DataFrame合并在一起，从而将每个组的合计作为新行添加到DataFrame中。
这是一个简单的示例，你可以根据实际需求进行更复杂的操作。关于Pyspark的更多信息和示例，你可以参考腾讯云的Pyspark产品介绍页面：Pyspark产品介绍。
相关·内容
我有一个spark dataframe，我需要根据当前行和上一行基于col_x赋值的金额的总和来计算一个运行合计，当col_y中出现负数时，我应该打破以前记录的运行合计，并从当前行开始计算运行合计。
样本数据集：
预期输出应如下所示：
如何使用pyspark通过dataframe实现这一点？
浏览 26提问于2021-06-11得票数 1
回答已采纳
1回答
将比率添加到SSRS矩阵
、、、
我想在ratio列的每一行中添加一个表达式。我想将行合计除以组合计，并在ratio列中显示每行的合计金额。对于ratio列的第一行，应该是11/44。 ? 我的设计选项卡有以下设计。 ?
浏览 16提问于2021-09-03得票数 0
回答已采纳
我正在尝试使用PandasUDF in PySpark来查找层次结构中的“最长唯一尾”。
例如，如果我的输入是：
1.2
1.2.3
那么最长的尾巴是'1.2.3‘
我还可能有多个唯一集，例如：
1.2
1.2.3
5.6.7
5.6
在这种情况下，输出应该是：
1.2.3
5.6.7
我使用的方法是：
对输入进行排序，以便像列出行一样，以便如果下一行中“包含”上一行，则可以筛选出它并只返回最长的唯一行。
示例输入：
1.2.3
5.6.7
5.6
1.2
排序如下：
1.2
1.2.3
5.6
5.6.7
当我在线过滤线路时，我的输出应该是
1.2.3
5.6.7
我试过两种方法。首
浏览 5提问于2021-12-11得票数 1
1回答
我有一个矩阵，它有100多个行记录。我想在矩阵中显示每页合计(而不是在矩阵末尾合计)，如下图所示，但没有得到任何解决方案。有什么解决方案吗？谢谢。
浏览 0提问于2017-06-08得票数 3
2回答
我有一个火花数据帧，有少量的字段。其中一些字段是巨大的二进制小块。整行的大小约为50 MB。
我正在将数据帧保存为拼花格式。我使用parquet.block.size参数控制行组的大小。
星火将生成一个拼花文件，但我将始终得到至少100行在一行组。这对我来说是个问题，因为块大小可能变成千兆字节，这与我的应用程序不太一样。
只要parquet.block.size的大小足以容纳100多行，就可以正常工作。
我将修改为MINIMUM_RECORD_COUNT_FOR_CHECK = 2，这解决了这个问题，但是，我发现没有任何配置值支持对这个硬编码常量进行调优。
是否有不同的/更好的方法来获得小于1
浏览 2提问于2018-01-09得票数 11
回答已采纳
3回答
如何从PySpark DataFrame获取随机行？我只看到了sample()方法，它接受一个分数作为参数。将这个分数设置为1/numberOfRows会导致随机结果，有时我不会得到任何行。
在RDD上，有一个takeSample()方法，它将您希望样本包含的元素数量作为参数。我知道这可能会很慢，因为你必须计算每个分区，但是有没有办法在DataFrame上得到这样的东西？
浏览 0提问于2015-12-01得票数 40
回答已采纳
1回答
如果我有两个行组:年份和状态，是否可以显示按状态分组的所有年份的合计？
Year Status Value
2014 Open 100
Closed 200
2015 Open 200
Closed 300
Total Open 300
Closed 500
到目前为止，我一直使用“变通方法”(在total组中创建2行，并使用硬编码公式=SUM(IIF(Status="Open",Value,Nothing)等)来实现这一点，但我希望能够“巧妙”地做到这一点。
浏览 0提问于2016-11-09得票数 0
在我通过使用窗口和对一组列进行分区来计算pyspark dataframe中每行5行内的平均数量之后 from pyspark.sql import functions as F
prep_df = ...
window = Window.partitionBy([F.col(x) for x in group_list]).rowsBetween(Window.currentRow, Window.currentRow + 4)
consecutive_df = prep_df.withColumn('aveg', F.avg(prep_df['quantity&#
浏览 14提问于2020-06-19得票数 0
回答已采纳
1回答
根据组中的其他项为组中的项分配值
、、、、
我试图根据输入字符串是否位于组中另一个字符串的开头为组中的每一行分配一个值。例如，"hello“位于"hello world”的开头，因此这两种类型的值都被指定为“在一起”。“再见”没有分配“在一起”值，因为它不在组中另一个字符串的开头。
input = [('1', 'hello'),('1', 'goodbye'),('1', 'hola'),('1', 'hi'),('1', 'hello world'),(
浏览 5提问于2019-06-25得票数 0
回答已采纳
我正在使用PySpark通过下面的JDBC命令向PostgreSQL数据库写入一个DataFrame。如何获取插入的行id？它被设置为具有自动增量的标识列。
我使用的是下面的命令，而不是单独插入每一行的for循环。
df.write.jdbc(url=url, table="table1", mode=mode, properties=properties)
我知道我可以使用monotonicallyIncreasingId并在Spark中设置in，但我正在寻找DB处理分配的替代方案，但我想让他的in返回到其他DataFrames中使用。
我在文档中没有找到这个。
浏览 2提问于2019-09-18得票数 2
1回答
如何将Vectors.dense列添加到pyspark中？
import pandas as pd
from pyspark import SparkContext
from pyspark.sql import SQLContext
from pyspark.ml.linalg import DenseVector
py_df = pd.DataFrame.from_dict({"time": [59., 115., 156., 421.], "event": [1, 1, 1, 0]})
sc = SparkContext(master="loc
浏览 1提问于2018-04-14得票数 1
回答已采纳
我有两个数据帧，我需要使用具有两个连接谓词的非相等连接(即不等式连接)将它们连接在一起。
一个数据帧是直方图DataFrame[bin: bigint, lower_bound: double, upper_bound: double]
另一个数据帧是观察值DataFrame[id: bigint, observation: double]的集合
我需要确定每个观察值落入直方图的哪个柱状图中，如下所示：
observations_df.join(histogram_df,
(
(observations_df.observation >= histogram_d
浏览 1提问于2018-10-02得票数 1
我正在尝试理解DataFrame列类型。当然，DataFrame不是一个物化的对象，它只是一组Spark的指令，将来要转换成代码。但我认为，这个类型列表代表了在执行操作时JVM中可能出现的对象类型。
import pyspark
import pyspark.sql.types as T
import pyspark.sql.functions as F
data = [0, 3, 0, 4]
d = {}
d['DenseVector'] = pyspark.ml.linalg.DenseVector(data)
d['old_DenseVector'] =
浏览 1提问于2016-07-31得票数 7
回答已采纳
我用火花来处理我的数据，就像这样：
dataframe_mysql = spark.read.format('jdbc').options(
url='jdbc:mysql://xxxxxxx',
driver='com.mysql.cj.jdbc.Driver',
dbtable='(select * from test_table where id > 100) t',
user='xxxxxx'
浏览 2提问于2022-05-11得票数 0
回答已采纳
如何跳过csv中的第一行，并将第二行视为pyspark dataframe中的头部： prod,daily,impress
id,name,country
01,manish,USA
02,jhon,UK
03,willson,Africa 如何跳过第一行(prod daily impress)，并使用spark dataframe将(id，name，country)视为标题。
浏览 12提问于2019-04-08得票数 0
2回答
我有数以十亿计的行要用Pyspark来处理。
Dataframe看起来如下：
category value flag
A 10 1
A 12 0
B 15 0
and so on...
我需要运行两个groupby操作:一个在flag==1的行上运行，另一个在所有行上运行。目前，我正在这样做：
frame_1 = df.filter(df.flag==1).groupBy('category').agg(F.sum('value').alias
浏览 0提问于2019-11-06得票数 1
回答已采纳
我有一个按日期分区的S3存储桶列表。第一个存储桶标题为2019-12-1，第二个存储桶标题为2019-12-2，依此类推。 这些存储桶中的每一个都存储我正在读取到pyspark dataframe中的拼图文件。从每个存储桶生成的pyspark dataframe具有完全相同的模式。我想要做的是迭代这些存储桶，并将所有这些拼图文件存储到一个单独的pyspark dataframe中，该数据框有一个date列，表示dataframe中的每个条目实际来自哪个存储桶。 因为单独导入每个存储桶时生成的数据帧的模式是多层的(即每一行都包含结构数组的结构等)，所以我认为将所有存储桶合并到一个数据帧中的唯一
浏览 13提问于2019-12-16得票数 0
回答已采纳
我希望按一列分组，然后找到另一列的最大值。最后，显示基于此条件的所有列。然而，当我使用我的代码时，它只显示2列，而不是所有列。
# Normal way of creating dataframe in pyspark
sdataframe_temp = spark.createDataFrame([
(2,2,'0-2'),
(2,23,'22-24')],
['a', 'b', 'c']
)
sdataframe_temp2 = spark.createDataFrame([
浏览 0提问于2020-01-19得票数 0
回答已采纳
1回答
我有一个代码，它工作良好，但使用熊猫数据帧组处理。但是，由于文件很大(>7000万组)，我需要转换代码以使用PYSPARK数据帧。下面是使用熊猫数据和小示例数据的原始代码：
import pandas as pd
import numpy as np
from scipy.optimize import minimize
df = pd.DataFrame({
'y0': np.random.randn(20),
'y1': np.random.randn(20),
'x0': np.random.randn(20),
'x1&
浏览 3提问于2017-09-15得票数 4
1回答
我使用的是SSRS2008 R2客户端报告。
我有一个经过排序的数据集，其中包含客户分支机构编号、帐户编号、名称和帐户余额。我在“分支机构号”上设置了一个家长组。每次分支机构编号发生变化时，我都希望打印合计，并从下一个分支机构详细信息行开始新的页面。
目前，报表先打印group1 customers，然后打印group2等，直到打印完成，然后在最底部打印每个组的总数。这是可以的，但不是我寻求的行为。
浏览 2提问于2013-06-30得票数 0
4回答
如果我调用map或mapPartition，并且我的函数接收来自PySpark的行，那么创建本地PySpark或Pandas DataFrame的自然方法是什么？合并行并保留架构的东西？
目前，我所做的事情如下：
def combine(partition):
rows = [x for x in partition]
dfpart = pd.DataFrame(rows,columns=rows[0].keys())
pandafunc(dfpart)
mydf.mapPartition(combine)
浏览 0提问于2015-12-23得票数 2
回答已采纳
1回答
我已经使用S3数据格式在pyspark.pandas中读取和存储了拼花文件。现在，在第二阶段，我试图在databricks中读取pyspark dataframe中的parquet文件，并面临将嵌套的json列转换为适当列的问题。首先，我使用以下命令从S3读取拼图数据：
adf = spark.read.parquet('s3://path')
我的pyspark dataframe中的一个嵌套列如下所示：
event_params:array
element:struct
key:string
value:struct
dou
浏览 8提问于2022-06-07得票数 0
我有一个报告，其中的字段来自从SQL服务器提取的数据。我有一个添加到report...however中的总字段，我有一个有趣的难题--我希望有人有我可以使用的公式。
我的三个列不需要summation...however，我的项目需求告诉我，只需从报告的最后一行中提取最后一个数字，并将其放在总计行中。为了更好地澄清：
1999 0.1% 0.2% 0.3%
2001 -2% 0.3% 3.4%
基本上，在total字段中，我将提取2001年的值，因为它是最后一个报告行。在我的合计行中，我希望显示-2%、0.3%和3.4% (因为这些是最后一行的值)。因此，基本上，我只
浏览 0提问于2010-04-01得票数 2
回答已采纳
2回答
从列表中添加列的pySpark
、、、、
我有一个数据文件名，并希望根据列表中的值向它添加列。
我的值列表将从3-50个值变化。我是pySpark新手，我试图将这些值作为新列(空)附加到我的df中。
我看到了关于如何将一列添加到dataframe中的推荐代码，而不是从列表中添加多列的代码。
mylist = ['ConformedLeaseRecoveryTypeId', 'ConformedLeaseStatusId', 'ConformedLeaseTypeId', 'ConformedLeaseRecoveryTypeName', 'ConformedLea
浏览 2提问于2020-05-12得票数 1
回答已采纳
如何在循环中创建一个pyspark DataFrame？在这个循环中，在每次迭代中，我输出2个值print(a1,a2)。现在，我想将所有这些值存储在一个pyspark数据帧中。
浏览 26提问于2021-01-12得票数 0
1回答
我有一个python方法，它接收多个参数并返回多个参数。我指定了它们的类型，但是行太长了。Pycharm不允许我将它分成两行，即使我使用"“。
我应该如何打破这条线(除了做import pyspark.sql.DataFrame as something_shorter之外)？
import pandas as pd
import pyspark
def my_metod(sdf1, sdf2, df1, df2):
# type: (pyspark.sql.DataFrame, pyspark.sql.DataFrame, pd.DataFrame, pd.DataFram
浏览 4提问于2021-01-05得票数 0
1回答
删除pyspark中的嵌套列
、、、、
我有一个包含一列结果的pyspark数据帧。在结果列中，我想删除列"Attributes“。dataframe的模式是：(在结果中有更多的列，但为了方便起见，我没有显示它们，因为模式很大) |-- results: struct (nullable = true)
| |-- l: array (nullable = true)
| | |-- element: struct (containsNull = true)
| | | |-- m: struct (nullable = true)
| | | | |-
浏览 20提问于2020-06-15得票数 0
回答已采纳
1回答
我一直在研究熊猫DataFrame，
df = pd.DataFrame({'col':[-0.217514, -0.217834, 0.844116, 0.800125, 0.824554]}, index=[49082, 49083, 49853, 49854, 49855])
我得到的数据如下：
如您所见，索引突然跳过770个值(由于我之前进行的排序)。
现在，我想将这个DataFrame分解成许多不同的行，其中每个行将由索引只彼此跟随的行组成(在这里，前2行将位于相同的DataFrame中，而最后3行将位于不同的DataFrame中)。
有人知道怎么做吗？
谢
浏览 3提问于2022-01-12得票数 0
1回答
我们有一个1.5BM记录分散在几个csv文件。为了生成一个count聚合，我们需要对几个列进行分组。
我们目前的战略是：
将它们加载到数据文件中(使用Dask或pyspark)
聚合列，以便生成2列作为键:value(我们不确定这是否值得)
将文件保存为Parquet
读取Parquet文件(Dask或pyspark)，并在dataframe的索引上运行groupby。
对于Parquet文件上高效的groupby来说，最佳实践是什么？
在索引上而不是在列(或一组列)上执行groupby有多大益处？
我们知道有一个partition可以提供帮助--但在我们的例子中，我们
浏览 2提问于2017-07-09得票数 3
我有像这样的DataFrame，我在下面的代码中创建了df。
我有三个excel文件(名称：- 1C1,1M1,1V1)，现在我想按DataFrame列'Sheet2‘拆分/分组，并在不擦除'Sheet1’中现有数据的情况下将数据保存在新的‘Sheet1’中。
import glob
from openpyxl import load_workbook
from openpyxl.utils.dataframe import dataframe_to_rows
import pandas as pd
df=pd.DataFrame()
for f in gl
浏览 0提问于2020-06-11得票数 0
我在Crsystal report9中运行合计时遇到了一个问题，如果他们的值对于特殊字段没有可用的值，我们如何将运行合计返回为'0‘
浏览 0提问于2009-09-28得票数 4
2回答
I have a column in pyspark dataframe which contain values separated by ;
+----------------------------------------------------------------------------------+
|name |
+-----------------------------------------------------
浏览 30提问于2019-01-10得票数 1
回答已采纳
我想使用PySpark (Spark1.6.2)对存在于Hive表中的数值数据执行主成分分析(PCA)。我能够将Hive表导入到：
>>> from pyspark.sql import HiveContext
>>> hiveContext = HiveContext(sc)
>>> dataframe = hiveContext.sql("SELECT * FROM my_table")
>>> type(dataframe)
<class 'pyspark.sql.dataframe.D
浏览 1提问于2016-10-06得票数 4
回答已采纳
我对pyspark和json解析还是个新手，我被困在了某些特定的场景中。让我先解释一下我要做什么，我有一个json文件，其中有一个数据元素，这个数据元素是一个包含另外两个json对象的数组。给定的json文件如下所示
{
"id": "da20d14c.92ba6",
"type": "Data Transformation Node",
"name": "",
"topic": "",
"x": 380,
浏览 142提问于2019-06-05得票数 0
回答已采纳
我正在将一些用熊猫编写的代码转换为PySpark。该代码有许多for循环，用于根据用户指定的输入创建可变数量的列。
我使用的是Spark 1.6.x，其中包含以下示例代码：
from pyspark.sql import SQLContext
from pyspark.sql import functions as F
import pandas as pd
import numpy as np
# create a Pandas DataFrame, then convert to Spark DataFrame
test = sqlContext.createDataFrame(pd.D
浏览 1提问于2016-10-15得票数 9
回答已采纳
我正在尝试从一个简单的Pandas DataFrame构建一个火花DataFrame。这是我遵循的步骤。
import pandas as pd
pandas_df = pd.DataFrame({"Letters":["X", "Y", "Z"]})
spark_df = sqlContext.createDataFrame(pandas_df)
spark_df.printSchema()
直到这一点，一切都好。产出如下：
根部
-字符串(nullable = true)
当我试图打印DataFrame时，问题就来了：
浏览 0提问于2019-02-14得票数 12
回答已采纳
有没有办法用pyspark 2.1.0创建/填充列，其中列的名称是另一个列的值？我尝试了以下几种方法
def createNewColumnsFromValues(dataFrame, colName, targetColName):
"""
Set value of column colName to targetColName's value
"""
cols = dataFrame.columns
#df = dataFrame.withColumn(f.col(colName), f.col(targetCol
浏览 0提问于2018-09-13得票数 1
2回答
我有一个列的，其中每一行都是一个长字符串(实际上是一个xml文件)。我想遍历DataFrame并将每一行中的字符串保存为文本文件，它们可以简单地称为1.xml、2.xml等等。
我似乎找不到任何关于如何做到这一点的信息或例子。我刚刚开始与斯派克和PySpark合作。也许可以在DataFrame上映射一个函数，但是函数必须将字符串写到文本文件中，我无法找到如何做到这一点。
浏览 1提问于2018-04-17得票数 3
回答已采纳
2回答
我正在把一段python代码‘翻译’成pyspark。我想使用现有的列作为dataframe的索引。我使用pandas在python中做到了这一点。下面的一小段代码解释了我所做的事情。谢谢你的帮助。 df.set_index('colx',drop=False,inplace=True)
# Ordena index
df.sort_index(inplace=True) 我希望结果是一个以'colx‘为索引的数据帧。
浏览 12提问于2019-05-31得票数 0
2回答
在PySpark中分解
、、、
我想将包含单词列表的DataFrame转换为DataFrame，每个单词都在自己的行中。
如何在DataFrame中的列上分解？
下面是我尝试过的一个示例，您可以取消注释每一行代码，并获得以下注释中列出的错误。我在Python2.7和Spark 1.6.1中使用PySpark。
from pyspark.sql.functions import split, explode
DF = sqlContext.createDataFrame([('cat \n\n elephant rat \n rat cat', )], ['word'])
print '
浏览 2提问于2016-07-06得票数 30
回答已采纳
我希望找到每列的1%le和99%le，并删除各自的pyspark dataframe行。谢谢
浏览 2提问于2017-05-18得票数 0
1回答
我在sqL服务器中有3个表，我想在一个报告中显示它们，计算同一供应商的总销售额和所有销售额的总和。
tblSalesCash列:供应商、合计
tblSalesCheck列:供应商、合计
tblSalesTerms列:供应商、合计
tblSalesCash
*
*
*
*亚信营销|2000年后的今天|
*Yassin Marketing |推送推送服务，推送推送，推送5000|
*
tblSalesCheck
*
*
*
*Yassin Marketing |推送推送服务，推送推送，推送5000|
*Yassin Marketing |推送推送服务，推送推送，推送5000|
*
tblSales
浏览 0提问于2016-01-15得票数 2
2回答
我有一个每周的报告，从200 - 1000行数据的任何地方。对于我的会计人员来说，合计是导入的唯一价值，因为他们只是将其用于应计目的。我希望将合计显示在报告的顶部，或显示在单独的文本框中，以指示这是报告的合计。有没有人对如何做到这一点有好的想法？
浏览 2提问于2015-07-21得票数 1
1回答
我想根据DataFrame中一行的第一个字符来分割文件。
原始数据有一列，数据包括
文件名(如'DATE20191009') 文件内容(如'1‘、'2’、'3')
输入样例文件(Pyspark)：
column1
Date20191009
1
2
3
Date20191010
1
4
5
我想要一个DataFrame文件名作为数据的分割。
文件名放在DataFrame的column2中，文件的内容放置在DataFrame的column2中。
预期输出(Pyspark)
column1 column2
Date20191009 [
浏览 3提问于2019-10-10得票数 1
回答已采纳
3回答
我正在使用openxml创建一个excel报告。openxml使用命名范围对模板excel文件进行操作。
客户端要求在行列表的末尾有一个合计行。听起来是个合理的要求！！
但是，我从db返回的数据表可以包含任意数量的行。使用模板行和'InsertBeforeSelf'，我的合计行将被覆盖。
我的问题是，使用openxml，我如何在电子表格中插入行，导致每次插入行时合计行被下移？
致敬..。
浏览 3提问于2010-06-24得票数 5
我有220 GB的数据。我已经将其作为两列读取到spark dataframe中: JournalID和Text。现在，我的数据帧中缺少27行。
使用NGram类，我在dataframe中添加了另外两个列Unigram和Bigram，其中包含文本列中的单字和双字。然后，我使用一元和二元语法列上的pyspark的TF和IDF类计算TFIDF，并将其作为另一列添加到dataframe中。
现在我为dataframe中的每一行都有了journalID和TFIDF vector。我想将支持向量机应用于所有类型的核，以TFIDF向量作为特征，以JournalID作为标签。由于多类支持向量机不存在于pys
浏览 1提问于2018-12-17得票数 0
1回答
按字段将两个结构相加
、、、
我有一个DataFrame模式，如下(在PySpark中)：
root
|-- ID: string (nullable = true)
|-- 2022: struct (nullable = true)
| |-- val_1: int (nullable = true)
| |-- val_2: double (nullable = true)
| |-- val_3: double (nullable = true)
|-- 2021: struct (nullable = true)
| |-- val_1: int (nullable = tr
浏览 5提问于2022-02-24得票数 0
回答已采纳
我正在使用PySpark，并且需要将DataFrame中的每一行转换为JSON文件(在s3中)，最好使用选定列的值来命名该文件。
我不知道该怎么做。任何帮助都将不胜感激。
浏览 10提问于2019-08-05得票数 0
我试图将爆炸的列添加到dataframe中：
from pyspark.sql.functions import *
from pyspark.sql.types import *
# Convenience function for turning JSON strings into DataFrames.
def jsonToDataFrame(json, schema=None):
# SparkSessions are available with Spark 2.0+
reader = spark.read
if schema:
reader.schema(s
浏览 9提问于2022-12-02得票数 1
1回答
我将df作为一个pyspark.sql.dataframe.DataFrame导入到Databricks中。在这个df中，我有3列(我已经证实它们是字符串)，我希望将它们连接起来。我试过先使用一个简单的"+“函数。
df["fullname"] = df["firstname"] + df["middlename"] + df["lastname"]
但是我一直收到错误"'DataFrame‘对象不支持项分配“。因此，我试图在每一列后面添加.astype(str)，但没有结果。最后，我尝试简单地添加另一列，
浏览 1提问于2022-12-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
