Вопросы по теме 'flatmap'

Почему flatMap реализован с объединением в RxJava?
Почему в RxJava 1.x оператор flatMap () реализован с помощью слияния? public final <R> Observable<R> flatMap(Func1<? super T, ? extends Observable<? extends R>> func) { if (getClass() ==...
1850 просмотров
schedule 13.09.2021

Использование плоской карты для функции поиска
У меня есть массив, который загружается в TableView. var sections = [ Section(sec: "One", subSec: ["A", "B", "C", "D", "E"], expanded: false), Section(sec: "Two", subSec: ["A", "B",...
265 просмотров
schedule 20.09.2021

Как использовать метод быстрого экземпляра с flatMap?
Я могу определить глобальную функцию, которая удваивает строки: func double(string: String) -> [String] { return [string, string] } И теперь можете использовать это с flatMap let animals = ["Ant", "Bear", "Cat"] print(...
250 просмотров
schedule 06.09.2021

Когда и как выполнять преобразование "один в 0..n" Stream mapMulti поверх flatMap начиная с Java 16
Я бегло просматривал новости и исходный код Java 16 и столкнулся с новым методом Stream под названием mapMulti . Ранний доступ JavaDoc говорит, что он похож на flatMap и уже одобрен для той же самой версии Java. <R> Stream<R>...
1027 просмотров
schedule 31.10.2021

Scala, почему flatMap обрабатывает (x => x) иначе, чем (identity)
Во-первых, map обрабатывает x => x так же, как identity List(1,2,3).map(x => x) //res0: List[Int] = List(1, 2, 3) List(1,2,3).map(identity) //res1: List[Int] = List(1, 2, 3) Теперь давайте преобразуем List[Option[Int]] в...
407 просмотров
schedule 12.06.2022

Разница между картой и плоской картой в дополнительной развертке в Swift 1.2
И map , и flatMap определены в ImplicitlyUnwrappedOptional , но они различаются (очевидно) по своему определению в соответствии с документацией: func map(f: @noescape (T) -> U) -> U! Если self == nil, возвращает nil. В противном случае...
3150 просмотров
schedule 24.06.2022

Возвратите необязательный параметр как есть, если возвращенный необязательный параметр имеет значение, иначе вызовите другую функцию
У меня есть два метода func1 и func2, которые возвращают необязательно. Возвратите необязательный как есть, если возвращенный необязательный из func1 имеет значение, в противном случае вызовите func2 и верните его необязательный. Один из способов —...
3614 просмотров
schedule 25.07.2022

Сделайте что-нибудь после успешного входа в систему, используя RxJava и Retrofit 2
Я реализовал сетевой вызов для проверки входа в систему, который работает нормально. Я просто столкнулся с проблемой при выполнении другого вызова для получения данных пользователя после успешного входа в систему. Вот вызов API: RestApi...
7145 просмотров
schedule 30.07.2022

Как связать Observable с Single в RxJava?
Я новичок в мире Rx, поэтому, пожалуйста, потерпите меня. Мой код на Kotlin, но код Java также поможет. У меня есть 2 метода, один из них загружает задачи из базы, если есть задачи, я хочу отправить их на сервер. fun getListFromDb():...
2249 просмотров

Почему Finatra использует flatMap, а не только карту?
Это может быть действительно глупый вопрос, но я пытаюсь понять логику использования #flatMap , а не только #map в этом определении метода в Finatra HttpClient definition : def executeJson[T: Manifest](request: Request, expectedStatus: Status =...
82 просмотров

flatten и flatMap в scala
Я хотел бы проверить, правильно ли я понял функции flatten и flatMap. 1) Правильно ли я понимаю, что flatten работает только тогда, когда коллекция состоит из других коллекций. Например, flatten будет работать со следующими списками. //list of...
535 просмотров
schedule 26.08.2022

FlatMap и карта в Apache Beam
Работают ли функции FlatMap и Map в Apache Beam для python параллельно? (p | 'GetJava' >> beam.io.ReadFromText(input) | 'GetImports' >> beam.FlatMap(lambda line: startsWith(line, keyword)) | 'PackageUse' >>...
569 просмотров
schedule 26.08.2022

искра использует подчеркивание в качестве параметра для RDD.flatmap или карты
Вот мой data:RDD[Array[String]] в искре. И я хочу подсчитать сумму всех длин элементов в данных. Например, data:(Array(1,2),Array(1,2,3)) . Я хочу получить сумму: 2+3=5; Сначала я использую : data.flatMap(_).count() , Ошибка :...
558 просмотров
schedule 06.09.2022

Swift Combine Conditional FlatMap Results (Условные результаты FlatMap)
Как вы можете иметь разные типы возвращаемых значений для flatMap при использовании Swift Combine? У меня есть первый издатель, который генерирует значение, а затем я картографирую его, чтобы преобразовать его в нового издателя. Однако, исходя из...
1283 просмотров

RxJS 6 - состояние плоской карты
У меня есть форма, которая создает элемент в бэкэнде и, возможно, другой ресурс в зависимости от того, устанавливает ли пользователь флажок. Второй ресурс должен быть создан только после создания первого. Я придумал этот код, но я не думаю, что это...
1858 просмотров
schedule 11.09.2022

Как вызывать функции Spark в Sparklyr с помощью вызова
Я пытаюсь использовать вызов в Sparklyr RStudio для простого подсчета слов в текстовом файле в HDFS и не разобрался с синтаксисом. Я могу вернуть весь файл в виде списка, используя (аналогично примеру count в документе SparklyR по расширениям —...
797 просмотров
schedule 23.09.2022

Akka Streams (Scala): фильтрация исключений
Одним из шагов в моем конвейере akka streams является преобразование, которое выдает исключение при получении недопустимого ввода. Я хотел бы отказаться от этих проблемных входных данных. Итак, я придумал следующее решение: ... .map( input =>...
45 просмотров
schedule 29.09.2022

Есть ли разница между flatten и flatMap(identity)?
scala> List(List(1), List(2), List(3), List(4)) res18: List[List[Int]] = List(List(1), List(2), List(3), List(4)) scala> res18.flatten res19: List[Int] = List(1, 2, 3, 4) scala> res18.flatMap(identity) res20: List[Int] = List(1, 2, 3, 4)...
8562 просмотров
schedule 17.01.2023

Использование Spark DataFrame.flatMap в java
Я работал с функцией RDD.flatMap в java. Теперь пробую свои силы в DataFrames. Они говорят: public <R> RDD<R> flatMap(scala.Function1<org.apache.spark.sql.Row, scala.collection.TraversableOnce<R>> f,...
4550 просмотров
schedule 19.03.2023

Рефакторинг вложенной FlatMap в RxJS
У меня есть itemsObservable , filtersObservable и queryObservable , и я передаю их значения функции, которая принимает список элементов, условия фильтрации и поисковый запрос и возвращает отфильтрованный список. Прямо сейчас мой код выглядит...
219 просмотров