dask

0Hitze

1Antwort

Dask Fehler: Länge des Wertes entspricht nicht Länge Index

Ich habe CSV-Datei liest dask auf diese Weise mit: import dask.dataframe as dd train = dd.read_csv('act_train.csv') Dann würde ich einfache Logik pro Zeile bewerben, die ziemlich gut in Pandas funk

python csv dataframe runtime-error dask 2016-08-08

---

2Hitze

1Antwort

Wie durch Spalten mit variabler Bins in Pandas/Dask

Ich bin die Lage, großen Datenrahmen diskretisieren einem Pandas Datenrahmen durch Spalten mit diesem Code diskretisieren: import numpy as np import pandas as pd def discretize(X, n_scale=1):

python pandas dataframe parallel-processing dask 2016-08-08

---

2Hitze

1Antwort

Wie vermeidet man ein leeres Ergebnis mit `Bag.take (n)` bei Verwendung von DASK?

Kontext: Dask Dokumentation besagt eindeutig, dass Bag.take() nur von der ersten Partition sammeln. Bei Verwendung eines Filters kann es jedoch vorkommen, dass die erste Partition leer ist, andere nic

python bag dask 2016-07-07

---

8Hitze

1Antwort

beeinflusst npartitions das Ergebnis von dask.dataframe.head()?

Wenn der folgende Code ausgeführt wird, das Ergebnis von dask.dataframe.head() hängt von nPartitionen: import dask.dataframe as dd import pandas as pd df = pd.DataFrame({'A': [1,2,3], 'B': [2,3,4]})

python pandas dask 2016-07-09

---

0Hitze

1Antwort

Speichern von dask dataframe im bcolz-Format

Die Dokumentation von DASK besagt: "BColz ist ein auf Festplatte, Chunked, komprimiert, column-store. Diese Attribute machen es sehr attraktiv für dask.dataframe, die besonders gut darauf funktioniere

python dask bcolz 2016-07-11

---

2Hitze

1Antwort

Wie kann ich Daten aus einem DASK-Datenframe anhand einer Liste von Indizes auswählen?

Sagen wir, ich habe den folgenden dask Datenrahmen. dict_ = {'A':[1,2,3,4,5,6,7], 'B':[2,3,4,5,6,7,8], 'index':['x1', 'a2', 'x3', 'c4', 'x5', 'y6', 'x7']} pdf = pd.DataFrame(dict_) pdf = pdf.set_ind

python indexing dask 2016-07-12

---

2Hitze

1Antwort

dask verteilte Speicherfehler

Ich habe die folgende Fehlermeldung auf dem Planer während Dask auf einem verteilten Job ausgeführt wird: distributed.core - ERROR - Traceback (most recent call last): File "/usr/local/lib/pytho

python dask 2016-07-23

---

7Hitze

2Antwort

Erstellen Sie eine if-else-Bedingung Spalte in dask Dataframe

Ich muss eine Spalte erstellen, die auf einer Bedingung auf dask Dataframe basiert. In Pandas ist es ziemlich einfach: ddf['TEST_VAR'] = ['THIS' if x == 200607 else 'NOT THIS' if x == 200608 e

python pandas dask 2016-07-27

---

1Hitze

1Antwort

Python-Paket verteilt, erhalten Sie die Adresse der Web-UI mit einfacher Einrichtung

Ich verwende derzeit das Python-Paket verteilt, weiß jemand, wie man die Adresse der Web-UI erhalten, wenn mit Python API eingerichtet? Testamentsvollstrecker = Executor() Oder ich muss immer mit der

dask 2016-08-01

---

2Hitze

2Antwort

Wie kopiere ich einen dask Datenframe?

Bei einer Pandas df man es vor etwas zu tun über kopieren: df.copy() Wie kann ich das mit einem dask Datenrahmen Objekt?

python dask 2016-08-03

---