hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[dask-on-ray] Fix Dask-on-Ray examples in docs (#14461)

Browse source
This commit is contained in:
Clark Zinzow 2021-03-17 11:37:32 -06:00 • committed by GitHub
parent 10250d737f
commit a86277a93c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
doc/source/dask-on-ray.rst
View file

@ -35,11 +35,11 @@ Here's an example:
import ray
from ray.util.dask import ray_dask_get
import dask
import dask.array as da
import dask.dataframe as dd
import numpy as np
import pandas as pd
import time
# Start Ray.
# Tip: If you're connecting to an existing cluster, use ray.init(address="auto").
@ -56,7 +56,7 @@ Here's an example:
df = dd.from_pandas(pd.DataFrame(
np.random.randint(0, 100, size=(1024, 2)),
columns=["age", "grade"]))
columns=["age", "grade"]), npartitions=2)
df.groupby(["age"]).mean().compute()
@ -156,10 +156,10 @@ Simply set the `dataframe_optimize` configuration option to our optimizer functi
import ray
from ray.util.dask import ray_dask_get, dataframe_optimize
import dask
import dask.dataframe as dd
import numpy as np
import pandas as pd
import time
# Start Ray.
# Tip: If you're connecting to an existing cluster, use ray.init(address="auto").