ローカルにサンプルデータセットがあり、クラスタ上でいくつかの基本操作を実行しようとしています。 import dask.dataframe as ddf
from dask.distributed import Client
client = Client('Ip address of the scheduler')
import dask.dataframe as
私はdaskを試してみる新しいユーザーです。 Delayedに関数とコードを自動的に変換するためにdelayedを使用したい。しかし、私はdelayed.computeを再帰的コレクションで遅延計算しませんでした... from dask import delayed, base
@delayed
def inc(x):
return x + 1
@delayed
def c
Daskでループを実装する際に問題が発生しています。 は、例えば、次のコードで： for i in range(len(col)):
if df[col[i]].dtype=='object':
pass
elif df[col[i]].std().compute()==0:
cols_constant.append(col[i])
df = df.d