我正在尝试比较两个pandas数据帧，但是我得到一个错误，因为'DataFrame‘对象没有'withColumn’属性。可能的问题是什么？import pandas as pdpd_df1=pd.DataFrame(d
浏览 24提问于2019-07-11得票数 2
搜索代码，但对我不起作用
pdf = df.toPandas()
pdf.withColumn("t4", coalesce(pdf.t4, pdf.t5))另外，之前尝试过以下代码，但也没有工作。new_p
浏览 0提问于2019-08-16得票数 1
回答已采纳
from pyspark.sql.functions import *我想在dataframe中添加后缀取错为
谢谢
浏览 0提问于2018-02-21得票数 1
eval(i)= eval(i).withcolumn(column, lit=none) eval(dataframe[num])= eval(dataframe[num]).withcolumn(column问题是python不将字符串识别为对象。因此，我使用ev
浏览 1提问于2022-08-19得票数 0
然后我就做了：我在想，我可以使用withColumn一个接一个地添加另外两个列表作为附加列。
浏览 0提问于2020-12-17得票数 1
1回答
然而，我偶然发现下面的.add_columns()方法没有继承我的Pyspark dataframe方法，而.add_columns_2()方法继承了集成开发环境级别的方法。为什么我不能在赋值后列出与Pyspark dataframe相关的方法？ def __init__(self, df): self._df.withColumn</
浏览 16提问于2019-11-27得票数 0
AttributeError: DataFrame对象没有属性“OrderID”
列数：150语言等：Python、Apache、Azure", sep='~', escape="\"", header="true", inferSchema="false") display(df.limit(4))
df1 = df.withCol
浏览 3提问于2022-06-18得票数 0
回答已采纳
尝试1： (sum(df1('Col1'))/ 100))\.withColumn('Amt2',(sum(df1(Col3))/ 100))\(df1
浏览 2提问于2020-04-06得票数 0
回答已采纳
在Python中，使用方法链接的代码非常常见，与其他地方的代码的主要区别是，这也与返回相同类型但已修改的对象结合在一起。这种方法通常假定对象是不可变的，并且只返回新实例。.withColumn("c", F.col("a") + F.col("b"))另一种写这个的方法是：
浏览 0提问于2022-10-29得票数 1
回答已采纳
假设我有一个包含两个列的DataFrame，id (字符串标识符)和properties (包含单个JSON对象的字符串，例如{"foo":123,"bar":"test"})。我如何将属性对象的所有名称-值对“爆炸”成多列，例如id、foo、bar。df = df.withColumn
浏览 2提问于2022-08-25得票数 1
我正在加入多个数据格式，并通过从两个diff dataframe中乘两列并将其除以属于另一个dataframe的列来计算输出。我得到分组序列表达式是空错误，而no_order不是聚合函数。(df4, df4["id"] == df1["id"],how = 'left')\.withColumn("co
浏览 1提问于2020-05-24得票数 0
1回答
我将df作为一个pyspark.sql.dataframe.DataFrame导入到Databricks中。在这个df中，我有3列(我已经证实它们是字符串)，我希望将它们连接起来。df["fullname"] = df["firstname"] + df["middlename"] + df["lastname"]
但是我一直收到错误"'DataFrame‘对象不支持项分配“。因此，我试图在每一列后面添加.astype(st
浏览 1提问于2022-12-02得票数 0
我正在尝试继承dataframe类并添加额外的自定义方法，如下所示，这样我就可以流畅地链接，并确保所有方法都引用相同的数据帧。我得到一个异常，因为列是不可迭代的 from pyspark.sql.dataframe import DataFrame
def __init___jdf, df.sql_ctx)
// Add column1 to dataframe received
浏览 14提问于2020-01-09得票数 0
回答已采纳
2回答
| |-- val5: integer (nullable = true)“数据”数组可能包含75K对象在我们的星星之火应用程序中，我们将此ORC夷为平地，如下所示：val withData = dataFrame.withColumn("data", explode(dataFrame.col(&qu
浏览 2提问于2017-08-05得票数 1
回答已采纳
调用下面的对象时出错是在不丢失空值的情况下分解dataframe中的数组，但在调用列时我得到错误，说对象没有属性‘_ code.This _ object _id’。from pyspark.sql import SparkSessionfrom pyspark.sql import Row
return reduce(lambda df_with_explode, c
浏览 2提问于2018-07-05得票数 2
有没有办法将UDF应用于dataframe中的N列？ DataFrame newDF = df.withColumn("col2", callUDF("test", (df.col("col2")))); DataFrame newDF = df.withColumn("col2", callUDF("
浏览 9提问于2017-03-15得票数 1
1回答
在编写PySpark DataFrame时，我希望从DataFrame的Date列中提取天数，并将其添加到名为new_df的新DataFrame中。所以我写到：但是我得到了一个例外，那就是“解决了的属性(日期)#5502从.”但当我用：
new_df = new_df.<
浏览 4提问于2020-11-11得票数 0
回答已采纳
2回答
我有一个包含多个列的DataFrame，比如ID、name和properties。它们都是string类型。最后一列properties包括该对象的一些属性的JSON表示。我正在寻找一些方法来迭代DataFrame，解析JSON，并从每个项目中提取特定的JSON字段-并将其附加到DataFrame的行中。有一个net.liftweb.json库，但不幸的是我还没有找到一种方法让它工作- .<
浏览 9提问于2017-03-14得票数 0
我正在尝试运行一些代码，但是得到了错误：
items = [(1,12),(1,float('Nan')),(1,14as funcdf = df.withColumn
浏览 1提问于2019-08-05得票数 9
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
