dask

1Hitze

2Antwort

Zu diesem dask Code Brennen: def inc(x): return x + 1 for x in range(5): array[x] = delay(inc)(x) Ich möchte alle Elemente in array zuzugreifen, indem die verzögerten Aufgaben ausführt.

0Hitze

1Antwort

Python Dask-Programm, die Ausgabe zu produzieren, obwohl es scheint zu berechnen

Ich bin verwirrt, warum mein DASK-Programm keine Ausgabe produziert, es hängt einfach nach dem Senden. Ich habe angegeben, Prozesse statt Threads zu verwenden und kann sehen, dass alle Kerne beim Send

1Hitze

1Antwort

Wie verwenden Sie das dask + für NFS-Dateien verteilt?

Arbeiten von Matthew Rocklin's post auf verteilte Datenrahmen mit Dask, ich versuche, einige statistische Statistiken Berechnungen über meinen Cluster zu verteilen. Das Einrichten des Clusters mit dcl

1Hitze

1Antwort

Dask Bag.to_textfiles funktioniert mit einer einzelnen Partition aber nicht multiple

Sehr kurz .. ist das ein Fehler oder fehlt mir etwas? tmp_j ist eine Tasche mit einem einzelnen Artikel und 6 Partitionen. Allerdings bekomme ich ähnliche Antworten mit größeren Taschen. >>> tmp_j = j

0Hitze

1Antwort

Speicherauspuff auf große Matrixoperation mit dask

Derzeit implementiere ich diese paper für meine Bachelor-Thesen mit Python, aber ich benutze nur die Mahalanobis Metrik lernen (falls Sie neugierig sind). In einer Verknüpfung, ich habe ein Problem, w

1Hitze

1Antwort

dask.array.reshape sehr langsam

Ich habe ein Array, das ich aufbauen iterativ wie folgt: step1.shape = (200,200) step2.shape = (200,200,200) step3.shape = (200,200,200,200) und dann umformen zu: step4.shape = (200,200**3) ich

10Hitze

1Antwort

Wie parallelisiert man viele (unscharfe) Zeichenkettenvergleiche mit Anwendung in Pandas? mit

ich habe folgendes Problem Ich habe einen Datenrahmen Master, die Sätze, wie master Out[8]: original 0 this is a nice sentence 1 this is another one 2 stackoverflow is nice Für jede Ze

1Hitze

1Antwort

Multiplikation von großen Arrays in Python

Ich habe große Arrays in vielen Iterationen auch zu multiplizieren. Ich trainiere ein Modell mit Array lang um 1500 und ich werde 3 Multiplikationen für etwa 1000000 mal durchführen, was eine lange Ze

3Hitze

1Antwort

Was ist das Dask-Äquivalent von numpy.tile?

Dask (http://dask.pydata.org/en/latest/array-api.html) ist eine flexible Bibliothek für parallele Berechnungen für Analysen. Es skaliert zu großen Daten, im Gegensatz zu Numpy und hat viele ähnliche M

0Hitze

1Antwort

DASK: IOError: [Errno 13] Erlaubnis verweigert:

ich mit der neuesten Anaconda Verteilung bin mit Dask 0.10 und ich laufe in den folgenden Fehler nach .compute(get=dask.multiprocessing.get) Aufruf: File "<ipython-input-8-cd6a1c9a02b6>", line 309, in