scalding

10calore

1risposta

decomprimi e leggi il file gzip in scala

In Scala, come si può decomprimere il testo contenuto in file.gz in modo che possa essere elaborato? Sarei felice di avere il contenuto del file memorizzato in una variabile o di salvarlo come file lo

scala gzip scalding 2013-07-02

---

6calore

1risposta

Scottatura: come conservare l'altro campo, dopo un groupBy ('campo) {. Dimensione}?

Quindi il mio dati di input ha due campi/colonne: id1 & ID2, e il mio codice è il seguente: TextLine(args("input")) .read .mapTo('line->('id1,'id2)) {line: String => val fields = line.split("\t

twitter cascading scalding 2013-07-06

---

42calore

5risposta

Gli esempi a cascata non sono stati compilati?

Nella shell ho digitato il gradle cleanJar nella directory Impatient/part1. L'output è sotto. L'errore è "file di classe per org.apache.hadoop.mapred.JobConf non trovato". Perché non è riuscito a comp

java hadoop gradle cascading scalding 2012-09-20

---

5calore

4risposta

(scottatura) groupBy foldLeft utilizzando il gruppo dal valore nella piega

dispone di dati come: pid recom-pid 1 1 1 2 1 3 2 1 2 2 2 4 2 5 necessario rendere: pid, recommendations 1 2,3 2 1,4,5 Significato ignorare auto dal 2 ° colonna, e rendere il riposa in un

scalding 2015-10-04

---