Który scheduler zostanie użyty?
W poniższym bloku kodu które z wyników — w, x, y i z — zostaną obliczone z użyciem równoległych procesów?
dask_df to Dask DataFrame, a dask_bag to Dask bag.
w = dask_df.compute()
client = Client(processes=True)
x = dask_df.compute()
y = dask_df.compute(scheduler='threads')
z = dask_bag.compute()
To ćwiczenie jest częścią kursu
Programowanie równoległe z Dask w Pythonie
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie