＆＃x27; dataFrame＆＃x27;对象没有属性＆＃x27; to_delayed＆＃x27;？
我正在使用Scikit Localforest模型从DASK学习和BlockWaseVottingRegressor。 代码： 错误： …
DASK多阶段资源设置原因无法序列化错误
使用Dask文档的确切代码 https：//jobqueue.dask.org/en/latest/latest/exampleast/examples.htmples.html 如果页面更改，这是代码： from dask_jobqu…
Dask在分支图中执行重新计算
假设，我创建以下图： import dask import time @dask.delayed def step_1(): print("Running Step 1") time.sleep(1) return True @dask.delayed def…
DASK数据帧并行任务
我想从数据框架创建功能（附加列），并且具有以下许多功能的结构。 之后此文档 https://docs.dask.dask.org/en/stable /delayed-best-practices.html …
用Xarray -Compute（）结果延迟的dask仍然延迟
我试图在两个数据集上使用Dask和Xarray进行一些分析（例如AVG），然后计算两个结果之间的差异。 这是我的代码， cluster = LocalCluster(n_workers=5,…
使用“ dask”填充在同类中存储在同类中的boost_histograms。
我有一个 dask - boost_histogram 问题。我的代码结构如下： 我在某些脚本中定义了一个类： class MyHist: def __init__(....): self.bh = None def m…
如何使我的代码与dask并行化？
首先导入一些软件包： import numpy as np from dask import delayed 假设我有两个numpy数组： a1 = np.ones(5000000) a2 = np.ones(8000000) 我想显…
Python 中匹配地理空间数据集的快速方法
我有一组 2000 个地理空间点（经度/纬度），我需要将其与其他几个地理空间数据集（我正在使用 Geopandas GeoDataFrames）进行匹配。我使用 sklearn Ba…
使用Dask dataframe的scipy插值方法
我已经从某人的 GitHub 代码或 dask 问题中阅读了一堆 dask 示例。但在使用 Scipy 插值和 Dask 并行计算时仍然遇到问题，希望有人能帮助我解决它。 我…
Dask @delayed 将数据帧转换为 pandas
我有这段代码调用 dask @delayed 函数，该函数将 N 个 dask 数据帧作为输入并返回一个 dask 数据帧作为输出。 有两个问题（1）函数内部数据帧的类型是…
- 共 1 页
- 1
