如果你有一个基于dask数据帧的groupby对象，为什么len(<groupby object>)会返回一个错误？(错误或功能)
浏览 13提问于2018-02-11得票数 5
回答已采纳
1回答
我想对dask数据的单个列进行频率计数。代码可以工作，但是我收到一个warning抱怨meta没有定义。虚拟数据和列频率from dask import dataframe as dd
Out[60]: Alice 2Sam 3
试图
浏览 7提问于2017-06-08得票数 25
回答已采纳
在Dask中，我得到了： File "<ipython-input-16-0beb32700c04>", line 3, in <module>
File "/anaconda3/lib/python3.7/site-packages/dask/dataframe/groupby</em
浏览 35提问于2019-08-27得票数 2
'B', 'C']
x = grouped.filter\dataframe\groupby.py in __getattr__(self, key)-> 1163 return self[\dataframe</e
浏览 15提问于2019-03-22得票数 2
回答已采纳
我想知道在使用Dask进行groupBy聚合之后，是否可以获得给定列中唯一项的数量。我在文档中没有看到任何类似的东西。它在pandas dataframe上可用，并且非常有用。
浏览 10提问于2017-08-28得票数 8
我正在使用dask读取大型csv数据文件，并试图对生成的数据文件执行groupby。groupby on Pandas DataFrame')for name, group in pgroup:print(ddf.head(5))
print('Performin
浏览 0提问于2019-07-28得票数 2
2回答
是否可以遍历dask GroupBy对象来访问底层数据帧？我试过了：import pandas as pdddf = dd.from_pandas(pdf, npartitions
浏览 21提问于2016-09-28得票数 10
回答已采纳
我有一个熊猫代码，想要翻译成Dask 让我们有一个虚拟数据 import dask.dataframe as dd
df = pd.DataFrame({'item_id': [10, 10, 10,item_hist_rating_up=pd.NamedAgg(column='rating', aggfunc=lambda x: round(100 * sum(x>=3.75) / lenitem_hist_rating_down=pd.Named
浏览 20提问于2021-03-31得票数 1
回答已采纳
为了转换大型数据集，我使用了dask包。pySpark实现： df.groupBy('Key').agg(collect_set('ColumnA').alias('Items'), collect_set('ColumnB').alias('DocumentId')) 到Pandas df.groupby("Key")[['ColumnA','ColumnB']].agg(set)
浏览 31提问于2021-08-16得票数 0
1回答
拥有一个占用大约100 in内存的dask.DataFrame： ddf = client.persist(ddf)# 246652596 rows ## Runningsome other code like groupby/aggregate etc 现在我想使用.loc操作符过滤掉数据，但在运行以下命令后，内存消耗为165 to： ddf_c = ddf_c.locddf_c.is_in_valid_set_of_combis == True]
ddf_c = clien
浏览 21提问于2020-08-06得票数 1
我在两个列上使用了groupby ( df有大约70列，除日期时间外，所有列都是浮动的)来获得dask数据文件：我不能使用结果，因为它是以某种奇怪的格式：如何将结果作为dataframe&#
浏览 3提问于2021-01-26得票数 1
回答已采纳
1回答
我正在尝试将我的应用程序的一部分从pandas移植到dask，但在dask DataFrame上的groupby中使用lamdba函数时遇到了障碍。import dask.dataframe as dd
dask_df = dask_df.groupbygroupby同样适用于pand
浏览 3提问于2016-11-28得票数 6
我用pandas编写脚本，但为了提高效率，我需要切换到dask，但我不确定如何在dask中实现unstack和reindex？这是我的pandas脚本的样子： df_new = df.groupby(['Cars', 'Date'])['Durations'].mean().unstack(fill_value=0).reindex
浏览 11提问于2020-06-18得票数 0
回答已采纳
我从Castra创建了以下dask dataframe：2353 2015-08-08 00:00:00 b我尝试了以下几点：
df.groupby
浏览 6提问于2015-11-26得票数 5
回答已采纳
1回答
: .groupby['target'].sum().shift(i).ffill().bfill().values
是否可以对值进行排序、分组、移位，然后分配给一个新变量，而不需要在Dask
浏览 10提问于2017-03-15得票数 4
我有一个Dask DataFrame，我想从其中按列分组，并将agg作为其他列的列表。例如：ddf.groupby('group_id')['name', 'department'].agg(list) 有没有什么方法可以让我做到这一点？
浏览 15提问于2019-06-06得票数 0
3回答
当数据库查询返回数据时，它工作得很好，但是当没有返回数据时，它会抛出一个错误(这是预期的)。如何捕获此异常并返回空数据？#When dataframe is non-empty, transformation works fine:0 41 Jason31.0 32.0 2012.0 2013.0 2014.0
#But when dataframeis empt
浏览 4提问于2016-06-30得票数 7
回答已采纳
1回答
如何使用dask找到数据帧的长度？例如，在熊猫中，我可以这样做：import numpy as npimport dask.dataframe as ddprint df_dask
print df_daskDask
浏览 0提问于2018-05-28得票数 6
1回答
我正在学习在我的大学项目中使用Dask进行并行数据处理。我用Dask连接两个节点来处理数据。concat = concat.groupby(axis=1, level=0).sum()
for idx inrange(5,len(piv
浏览 7提问于2022-05-27得票数 2
1回答
sklearn.preprocessing import LabelEncoderdf = df.groupby(['ID_0', 'ID_1']).size().rename('count').reset_index
浏览 1提问于2016-09-10得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
