scala

21Ciepło

1Odpowiedz

build.sbt: jak dodać zależności zapłonowe

Witam Próbuję pobrać spark-core, spark-streaming, twitter4j i spark-streaming-twitter w pliku build.sbt poniżej: name := "hello" version := "1.0" scalaVersion := "2.11.8" libraryDependencies +=

5Ciepło

3Odpowiedz

Jak ustawić nazwy kolumn do funkcji toDF() w iskrowym modelu danych przy użyciu tablicy łańcuchów?

Na przykład val columns=Array("column1", "column2", "column3") val df=sc.parallelize(Seq( (1,"example1", Seq(0,2,5)), (2,"example2", Seq(1,20,5)))).toDF(columns) jaki sposób można ustawić nazwę ko

8Ciepło

1Odpowiedz

Gdy mapa nad funkcją jest przydatna, kiedy już ją posiadasz, a następnie

W programie Scalaz można odwzorować funkcję na inną funkcję. Kiedy chciałbym użyć map przez andThen? Czy istnieje wyraźna przewaga przy użyciu map? Dzięki Na przykład val f: Int => Int = (a) => a + 10

13Ciepło

3Odpowiedz

Opcja Scala [Przyszłość [T]] do przyszłości [Opcja [T]]

Jak mogę przekonwertować Option[Future[T]] na Future[Option[T]] w scala? chcę go używać w: val customerAddresses = for { a <- addressDAO.insert(ca.address) // Future[Address] ia <- ca.invoic

5Ciepło

1Odpowiedz

Jak określić wiele tabel w Spark SQL?

Mam kod, w którym muszę ustawić trzy tabele. Aby to zrobić, muszę wywołać funkcję jdbc trzy razy dla każdej tabeli. Zobacz kod poniżej: val props = new Properties props.setProperty("user", "root"

7Ciepło

2Odpowiedz

Strumień zdarzeń Akka Persistence Query i CQRS

Próbuję zaimplementować stronę odczytu w mojej architekturze ES-CQRS. Powiedzmy mam uporczywe aktora tak: object UserWrite { sealed trait UserEvent sealed trait State case object Unini

5Ciepło

1Odpowiedz

Play Scala: Jak przesyłać żądania treściowe

Buduję mikro-usługę za pomocą Play Framework 2.3.x za pomocą Scala (w obu jestem początkujący), ale nie mogę znaleźć sposobu na przesłanie żądania ciało. Oto problem: muszę punkt końcowy /transform gd

8Ciepło

2Odpowiedz

jak przekonwertować ciąg json do ramek danych na iskrze

Chcę przekonwertować zmienną ciąg poniżej do ramek danych na iskrze. val jsonStr = "{ "metadata": { "key": 84896, "value": 54 }}" wiem jak stworzyć dataframe z pliku JSON. sqlContext.read.json("file

6Ciepło

1Odpowiedz

jak zignorować metody narzędzia testowego, gdy skalatest wykryje awarie?

mam tej metody wygody moich testów: def assertFormat[T: SexpFormat](start: T, expect: Sexp): Unit = { val sexp = start.toSexp assert(sexp === expect, s"${sexp.compactPrint} was not ${expect.

6Ciepło

2Odpowiedz

Konwertuj Js Definicja na ciąg

Używam biblioteki json do odtwarzania obiektów json w Scali. W celu uzyskania równych id od obiektu json, uruchomić ten kod: val id = json \ "id" Następnie chcę przekonwertować id na łańcuch. Próbował