reduce

6Ciepło

3Odpowiedz

Korzystanie z funkcji zmniejszenia w celu zwrócenia tablicy

Dlaczego, gdy chcę użyć funkcji wypychania wewnątrz funkcji zmniejszania, aby zwrócić nową tablicę, pojawia się błąd. Jednakże, gdy używam metody concat w funkcji zmniejszenia, zwraca ona nową tablicę

6Ciepło

1Odpowiedz

Zapytanie rekursywne w ulu

Ula obsługuje klauzulę, ale gałąź nie obsługuje zapytań cyklicznych. W relacyjnych bazach danych istnieje funkcja rekursywna, procedura składowana do kwerendy rekursywnej, ale gałąź nie obsługuje proc

11Ciepło

2Odpowiedz

Spark: różnica semantyki między redukuj i redukujByKey

W dokumentacji Sparka mówi, że metoda RDDs reduce wymaga asocjacyjnej i komutatywnej funkcji binarnej. Jednak metoda TYLKO wymaga reduceByKey asocjacyjnej funkcji binarnej. sc.textFile("file4kB", 4)

7Ciepło

4Odpowiedz

Korzystanie z Pythona Wyższe funkcje porządkowe do manipulowania listami

Zrobiłem tę listę; każdy element jest ciągiem znaków, który zawiera przecinki (w niektórych przypadkach) i jelita grubego (zawsze): dinner = [ 'cake,peas,cheese : No', 'duck,broccoli,onions

11Ciepło

1Odpowiedz

Java 8 strumienie - stackoverflow wyjątek

Running Poniższy przykładowy kod kończy się: "Wyjątek w wątku "main" java.lang.StackOverflowError" import java.util.stream.IntStream; import java.util.stream.Stream; public class TestStream {

11Ciepło

3Odpowiedz

Równoważnik składanki Scala w Javie 8

Co jest odpowiednikiem wspaniałego foldLeft Scali w Java 8? Kusiło mnie, aby pomyśleć, że to był reduce, ale zmniejszenie musi zwrócić coś identycznego do tego, na co się zmniejsza. Przykład: import j

12Ciepło

1Odpowiedz

Jak wywołać metodę redukcji w pustej tablicy Kotlin?

Proste zmniejszenie pustej tablicy spowoduje: Wyjątek w wątku "główny" java.lang.UnsupportedOperationException: Pusta iterable nie może być zmniejszona. Ten sam wyjątek podczas łączenia: val a = intAr

6Ciepło

3Odpowiedz

W jaki sposób Stream.reduce (BinaryOperator <T> akumulator)

Poniższy kod działa idealnie bez potrzeby inicjowania go. int sum=Stream.of(2,3).reduce((Integer a,Integer b)->a+b).get(); // sum = 5 int sum=Stream.of(2,3).reduce((Integer a,Integer b)->a*b).get();

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

5Ciepło

1Odpowiedz

Java 8: Wykonywanie operacji na zmniejszenie Stream

Mam java.util.stream.Stream zawierający pary wartość klucza jak: <1,3> <1,5> <3,1> <4,2> <4,7> <4,8> teraz chciałbym, aby połączyć wszystkie wpisy, które posiadają takie same klucz: <1,[3,5]> <3,[1]