scala

5Ciepło

1Odpowiedz

Google Cloud Platform: nie można uzyskać dostępu do Pubsub z silnika kontenera

Próbuję opublikować istniejący temat pubsub z aplikacji Scala działającej w Google Container Engine (np. Działa w Kubernetes). mam włączony (chyba) odpowiednie uprawnienia do bazowego klastra: Jednak

6Ciepło

1Odpowiedz

Podpisywanie między typami funkcji

W kursie programowania funkcjonalnego coursera natknąłem się na subtelną koncepcję. Jeśli A2 <: A1 i B1 <: B2, następnie (A1 => B1) <: (A2 => B2) Uzasadnienie kiedy przekazujemy argument do A2 i ze wz

5Ciepło

3Odpowiedz

Jak zdobyć dzisiaj - "1 dzień" w sparksql?

Jak uzyskać current_date - 1 dzień w sparksql, tak samo jak cur_date()-1 w mysql.

7Ciepło

2Odpowiedz

scala 2.12.1 ClassNotFoundException wyrobów $ klasa

Niedawno zaktualizowane Scala z v2.11.8 do 2.12.1 i dostał wyjątek CNF: java.lang.ClassNotFoundException: scala.Product$class Widziałam klasa jest dostarczany przez scala-library.jar. Błąd występuje

13Ciepło

1Odpowiedz

Scala Spark: DataFrames + dołącz: java.util.concurrent.TimeoutException: Futures przekroczono limit czasu po [300 sekundach]

Używam Spark 1.5. Mam dwa dataframes postać: scala> libriFirstTable50Plus3DF res1: org.apache.spark.sql.DataFrame = [basket_id: string, family_id: int] scala> linkPersonItemLessThan500DF res2: org

8Ciepło

2Odpowiedz

Jak korzystać z HTTP Akka do generowania treści przez strumień wyjściowy

Jestem całkiem początkującym dla Akka Streams i Akka HTTP. Chciałbym wygenerować prosty serwer HTTP, który może wygenerować plik zip z zawartości folderu i wysłać go do klienta. Plik org.zeroturnaroun

5Ciepło

1Odpowiedz

Co oznaczają parametry typu dla źródła <Out,Mat>?

Próbuję zrozumieć typ źródła dla strumieni Akka, określony here. Niestety, dokumentacja i przykłady, które znalazłem, nie wyjaśniają, co właściwie oznaczają poszczególne parametry. Zgaduję, że Out jes

5Ciepło

2Odpowiedz

islowe okno funkcji sql opóźnienie

Patrzę na funkcję przesuwania okna dla Spark DataFrame w Spark SQL, Scala. Mam ramkę danych z kolumnami Col1, Col1, Col1, data. Col1 Col2 Col3 date volume new_col 201601 100.5 201

5Ciepło

1Odpowiedz

błąd kompilacji Akka http

Jestem nowy w środowisku akka, a teraz spróbuj skonfigurować prosty serwis z tą strukturą. napisać prostą aplikację Akka-http: import akka.actor.ActorSystem import akka.http.scaladsl.Http import akk

14Ciepło

2Odpowiedz

Różnica Await.ready i Await.result

Wiem, że to dość otwarte pytanie i przepraszam. widzę, że Await.ready powraca Awaitable.type podczas gdy Await.result zwraca T ale nadal je pomylić. Jaka jest różnica między tymi dwoma? Czy jedno blok