scala

7Ciepło

3Odpowiedz

Jak przekonwertować RDD z klasy na klasy do DataFrame?

W dokumencie Spark documentation pokazano, jak utworzyć obiekt DataFrame z RDD, używając klas przypadków Scala do wyprowadzania schematu. Próbuję odtworzyć tę koncepcję za pomocą sqlContext.createData

8Ciepło

1Odpowiedz

Circe instances do kodowania/dekodowania zaplombowanych instancji cechy arity 0?

Używam zapieczętowanych cech jako wyliczeń do wyczerpującego dopasowania wzorców. W przypadkach, w których mam obiekty sprawy, zamiast klas przypadków rozszerzających moją cechę, chciałbym kodować i d

9Ciepło

2Odpowiedz

RDD Agregacja w iskrze

Jestem uczniem Apache Spark i natknąłem się na RDD akcję aggregate, której nie mam pojęcia, jak to działa. Może ktoś przeliterować i szczegółowo wyjaśnić krok po kroku w jaki sposób dochodzimy do poni

15Ciepło

1Odpowiedz

Spark Scala: Jak przekształcić kolumnę w DF

Mam ramkę danych w Sparku z wieloma kolumnami i udf, które zdefiniowałem. Chcę ten sam ramka danych z powrotem, z wyjątkiem jednej przekształconej kolumny. Ponadto moje udf pobiera ciąg znaków i zwrac

5Ciepło

3Odpowiedz

Automatycznie wstrzykuj WebJarAssets w szablonie HTML Play 2.5?

W mojej sztuce szablonu HTML wewnątrz mojego modułu custom, mam następujący wiersz kodu: <script type="text/javascript" src="@controllers.core.routes.WebJarAssets.at(WebJarAssets.locate("jquery.min.js

5Ciepło

1Odpowiedz

Fold metoda z użyciem listy jako akumulatorze

Aby znaleźć czynniki pierwsze liczby używałem ten kawałek kodu: def primeFactors(num: Long): List[Long] = { val exists = (2L to math.sqrt(num).toLong).find(num % _ == 0) exists match {

5Ciepło

2Odpowiedz

Schemat iskrzenia: DateDiff dwóch kolumn według godziny lub minuty

Mam dwie kolumny timestamp w ramce danych, które chciałbym uzyskać różnicę minutową lub, alternatywnie, różnicę godzinową. Obecnie jestem w stanie uzyskać różnicę dzień, z zaokrągleniem, wykonując val

6Ciepło

2Odpowiedz

Co oznacza `<< =` w SBT?

Widzę ten symbol <<= w partii kodu SBT, ale nie wiem, co robi. Próbowałem googling dla tego symbolu, ale nie otrzymałem żadnych odpowiedzi. Czy możesz wskazać mi jakąś dokumentację lub przykład, który

8Ciepło

1Odpowiedz

Jak zmontować zlew w strumieniach Akka z wielu zapisów?

Próbuję zintegrować przepływ strumieniowy z akka w mojej aplikacji Play 2.5. Pomysł polega na tym, że można przesyłać strumieniowo na zdjęciu, a następnie zapisywać je na dysku jako surowy plik, minia

6Ciepło

1Odpowiedz

Czy koszt lambda typu Scala wywołania odblaskowego?

Pracuję z dużą ilością kodu z typem lambdas w tej chwili i zauważyłem, że IntelliJ ostrzega mnie, że jest to "Zaawansowana funkcja językowa: połączenie refleksyjne". Przykładowy kod: implicit def mono