val map1 = Map(1 -> 9 , 2 -> 20) val map2 = Map(1 -> 100, 3 -> 300) Chcę je scalić i zsumować wartości tych samych kluczy. Wynik będzie więc: Map(2->20, 1->109, 3->300) Teraz mam 2 rozwiązania: val list = map1.toList ++ map2.toList val merged = list.groupBy ( _._1) .map {...
Wolę Pythona od Scali. Ale ponieważ Spark jest natywnie napisany w Scali, spodziewałem się, że mój kod będzie działał szybciej w Scali niż wersja Python z oczywistych powodów. Mając to założenie, pomyślałem, że powinienem nauczyć się i napisać wersję Scala jakiegoś bardzo powszechnego kodu do...
Kiedy elastyczny rozproszony zestaw danych (RDD) jest tworzony z pliku tekstowego lub kolekcji (lub z innego RDD), czy musimy jawnie wywoływać „pamięć podręczną” lub „utrwalanie”, aby przechowywać dane RDD w pamięci? A może dane RDD są domyślnie przechowywane w pamięci w sposób rozproszony? val...
Widziałem funkcję o nazwie implicitlyużywaną w przykładach Scala. Co to jest i do czego służy? Przykład tutaj : scala> sealed trait Foo[T] { def apply(list : List[T]) : Unit }; object Foo { | implicit def stringImpl = new Foo[String] { | def apply(list : List[String]) = println("String") |...
Jaki jest dobry sposób logowania się w aplikacji Scala? Coś, co jest zgodne z filozofią języka, nie zaśmieca kodu, jest łatwe w utrzymaniu i dyskretne. Oto lista podstawowych wymagań: prosty nie zaśmieca kodu. Scala jest świetna ze względu na swoją zwięzłość. Nie chcę, aby połowa mojego kodu...
Jeśli mam kolekcję ctypu Ti nie ma właściwość pna T(typu P, powiedzmy), co jest najlepszym sposobem, aby zrobić MAP-by-wydobycia kluczu ? val c: Collection[T] val m: Map[P, T] Jeden sposób jest następujący: m = new HashMap[P, T] c foreach { t => m add (t.getP, t) } Ale teraz potrzebuję...
Jedną z przydatnych funkcji Scali jest to lazy val, że ocena a valjest opóźniona do momentu, gdy będzie to konieczne (przy pierwszym dostępie). Oczywiście lazy valmusi mieć pewien narzut - gdzieś Scala musi śledzić, czy wartość została już oszacowana, a ocena musi zostać zsynchronizowana, ponieważ...
Jaki jest standardowy sposób pracy z datami i godzinami w Scali? Czy powinienem używać typów Java, takich jak java.util.Date, czy istnieją natywne alternatywy dla
W obecnym stanie to pytanie nie pasuje do naszego formatu pytań i odpowiedzi. Oczekujemy, że odpowiedzi będą poparte faktami, referencjami lub ekspertyzą, ale to pytanie prawdopodobnie będzie wymagało debaty, argumentów, ankiet lub rozszerzonej dyskusji. Jeśli uważasz, że to...
To prawda ... dużo o tym dyskutowano. Istnieje jednak wiele niejasności, a niektóre z udzielonych odpowiedzi ... w tym powielanie odniesień do jar w konfiguracji lub opcjach jars / executor / sterownik. Niejednoznaczne i / lub pominięte szczegóły W związku z niejednoznacznością, niejasnymi i /...
Zastanawiam się, czy istnieje sposób na wykonywanie asynchronicznych wywołań do bazy danych? Na przykład wyobraź sobie, że mam duże żądanie, którego przetworzenie zajmuje bardzo dużo czasu, chcę wysłać żądanie i otrzymać powiadomienie, gdy żądanie zwróci wartość (przekazując Listener / callback...
class Person(val name:String,var age:Int ) def person = new Person("Kumar",12) person.age = 20 println(person.age) Te wiersze kodu wyjściowego 12, mimo że person.age=20zostały pomyślnie wykonane. Okazało się, że dzieje się tak, ponieważ użyłem def w def person = new Person("Kumar",12). Jeśli...
Do czytania przydatna jest abstrakcja Source. Jak mogę zapisać linie do pliku
W Javie odczyt zmiennych środowiskowych odbywa się za pomocą System.getenv(). Czy jest na to sposób w
Przeciążanie operatorów w C ++ jest przez wielu uważane za złą rzecz (tm) i błąd, który nie powinien być powtarzany w nowszych językach. Z pewnością była to jedna z funkcji, która została specjalnie usunięta podczas projektowania języka Java. Teraz, gdy zacząłem czytać w Scali, stwierdziłem, że...
Jestem nowy w grze! Framework 2.1 (wersja java) i nie mam doświadczenia ze scala. Nie rozumiem, co to jest, co oznacza %i %%oznacza w Build.scala. Poszukałem ich w Google, ale nie mogłem znaleźć ich znaczenia. W moim pliku Build.scala mam: "org.hibernate" % "hibernate-entitymanager" %...
Próbuję przedstawić funkcję, która nie przyjmuje argumentów i nie zwraca wartości (symuluję funkcję setTimeout w JavaScript, jeśli musisz wiedzieć). case class Scheduled(time : Int, callback : => Unit) nie kompiluje się, mówiąc, że „parametry val mogą nie być wywołane przez nazwę” case class...
Czasami napotykam na pół tajemniczą notację def f[T](..) = new T[({type l[A]=SomeType[A,..]})#l] {..} w postach na blogu Scali, które dają mu falę ręczną „użyliśmy tego typu sztuczki lambda”. Chociaż mam pewne wyobrażenia na ten temat (uzyskujemy anonimowy parametr typu Abez konieczności...
Załóżmy, że robię coś takiego: val df = sqlContext.load("com.databricks.spark.csv", Map("path" -> "cars.csv", "header" -> "true")) df.printSchema() root |-- year: string (nullable = true) |-- make: string (nullable = true) |-- model: string (nullable = true) |-- comment: string...
W bezkształtnym typ Nat reprezentuje sposób kodowania liczb naturalnych na poziomie typu. Jest to używane na przykład w przypadku list o stałym rozmiarze. Możesz nawet wykonać obliczenia na poziomie typu, np. Dołączyć listę Nelementów do listy Kelementów i otrzymać listę, która w czasie kompilacji...