Which scheduler will be used?
In the following block of code, which of the results, w
, x
, y
, and z
, will be computed using parallel processes?
dask_df
is a Dask DataFrame and dask_bag
is a Dask bag.
w = dask_df.compute()
client = Client(processes=True)
x = dask_df.compute()
y = dask_df.compute(scheduler='threads')
z = dask_bag.compute()
Diese Übung ist Teil des Kurses
Parallel Programming with Dask in Python
Interaktive Übung
Setze die Theorie in einer unserer interaktiven Übungen in die Praxis um
