W Scala, w jaki sposób można rozpakować tekst zawarty w file.gz, aby można było go przetworzyć? Byłbym zadowolony z posiadania zawartości pliku przechowywanego w zmiennej lub zapisywania go jako pliku
Więc moje dane wejściowe ma dwa pola/kolumny: ID1 & ID2, a mój kod jest następujący: TextLine(args("input"))
.read
.mapTo('line->('id1,'id2)) {line: String =>
val fields = line.split("\t")
W powłoce wpisałem gradle cleanJar w katalogu Impatient/part1. Wynik jest poniżej. Błąd to "plik klasy dla org.apache.hadoop.mapred.JobConf nie znaleziono". Dlaczego nie udało się skompilować? :clean
Czy dane, takie jak: pid recom-pid
1 1
1 2
1 3
2 1
2 2
2 4
2 5
trzeba zrobić to: pid, recommendations
1 2,3
2 1,4,5
Znaczenie ignorować siebie od 2 kolumny, i sprawiają, że spoczywaj w ci