scala

5Ciepło

2Odpowiedz

Próbuję wdrożyć konsumenta kafka w scala. Widziałem milion samouczków, jak to zrobić w Javie, a nawet niektóre (like this one), które mówią, że jest to scala, ale jest napisane w Javie. Czy ktoś wie,

6Ciepło

2Odpowiedz

Czy w RDD są jakieś działania dotyczące zamówienia?

Chcę wykonać działanie w trybie RDD, takie jak reduce, ale nie trzeba, aby operator był przemienny. tj. chcę, aby result na następnej stronie zawsze będzie "123456789". scala> val rdd = sc.parallelize

7Ciepło

1Odpowiedz

Gradle-android-scala-plugin daje "Nie można znaleźć pasujący konstruktor" Błąd

Importowanie this przykładowy kod do Androida Studio daje ten błąd: Error:(17, 0) Could not find matching constructor for: org.gradle.api.internal.tasks.DefaultScalaSourceSet(java.lang.String, org.gra

8Ciepło

3Odpowiedz

Reading JSON z Apache Spark - `corrupt_record`

Mam plik json, nodes, który wygląda tak: [{"toid":"osgb4000000031043205","point":[508180.748,195333.973],"index":1} ,{"toid":"osgb4000000031043206","point":[508163.122,195316.627],"index":2} ,{"toid

13Ciepło

1Odpowiedz

Definiowanie UDF, który akceptuje Array obiektów w Spark DataFrame?

Podczas pracy z DataFrames Sparka, funkcje zdefiniowane przez użytkownika (UDF) są wymagane do mapowania danych w kolumnach. UDF wymagają, aby typy argumentów były jawnie określone. W moim przypadku p

6Ciepło

1Odpowiedz

Przyspieszenie filtrowania grupowego dla dużego zestawu danych w Spark MLLib

Używam współczynnika macierzy MLlib do polecania produktów użytkownikom. Mam na myśli dużą niejawną matrycę interakcji M = 20 milionów użytkowników i N = 50 000 elementów. Po szkoleniu modelu chcę uzy

9Ciepło

1Odpowiedz

skolemizacja z egzystencjalnie wpisywanych wyrażeń

w Scala, następujące wyrażenie zgłasza błąd typu: val pair: (A => String, A) forSome { type A } = ({ a: Int => a.toString }, 19) pair._1(pair._2) Jak wspomniano w SI-9899 i to answer ta jest popraw

11Ciepło

4Odpowiedz

Scala typu badania z wzbogacaniem

stałem dołączone do wzbogacenia typu, na przykład object MyImplicits{ implicit class RichInt(i: Int){ def complexCalculation: Int = i * 200 } } którego używam w kodzie jak tego objec

7Ciepło

5Odpowiedz

Usuń białe spacje ze stringami ze Scala

Chcę usunąć białe znaki w ciągu znaków. Input: "le ngoc ky quang" Output: "lengockyquang" Próbowałem replace i replaceAll metod ale did't pracy.

5Ciepło

2Odpowiedz

Zrozumienie deklaracji flatMap na liście

Po prostu spojrzałem na deklarację List.flatMap i byłem trochę zaskoczony tym. final override def flatMap[B, That](f: A => GenTraversableOnce[B]) (implicit bf: CanBuildFrom[List[A], B, That]):