FlatMap可遍历的错误

文章/答案/技术大牛

发布

1回答

scala、apache-spark、spark-dataframe

"select * from test_table where date ='20160721' LIMIT 300")val row = df.flatMap(row => ((row.get(0), row.get(1), row.get(2)), 1))Type mismatch, expected: (Row) =>Traversable[NotInferedU], actual : (Row

浏览 3提问于2016-08-17得票数 0

回答已采纳

1回答

Scala集合可选元组flatMap

collections、tuples、option-type

虽然我似乎不知道如何键入匹配的flatMap时，地图将正确地映射到一个列表。我知道还有其他的方法(跳到结尾)，只是好奇它是如何工作的。{ case (k,v) => greaterTuple(k,v) } //worksfours.map(greaterTuple) 或者在别人建议之前:把整件事都列在一起，

浏览 3提问于2017-07-05得票数 0

回答已采纳

1回答

清单Monad:签署List.flatMap的后果(f：(A)⇒GenTraversableOnce[B])

list、scala、functional-programming、monads

但是，考虑到清单是一元论的，并且应该是这种形式的，它不应该起作用： def flatMap[B](f:A => M[B]):M[B]l.flatMap(elem => isEven(elem)) 它的类型是：List[Int].<em

浏览 1提问于2014-05-29得票数 2

回答已采纳

1回答

是否有可能将canBuildFrom传递给理解？

scala、for-comprehension

我希望避免使用压缩的理解方式创建中间Seq，如下所示： (a,b) <- (as, bs).zipped} yield a + b + c + d 但是压缩(Tuple2Zipped) flatMap在默认情况下返回可遍历的，而不是Seq。如果我使用显式映射和flatMap

浏览 0提问于2018-06-05得票数 0

回答已采纳

1回答

Spark streaming和在流式字典上执行操作

python、apache-spark、spark-streaming

奇怪的是，我想检查一下我正在输入的一系列字典中k，v对的数量，但我发现我似乎无法做到这一点。lines = ssc.socketTextStream("127.0.0.1", 5006) dict_format = json_format.flatMap(lambda x : len(x) ).reduce(lambda a, b: a+b) 例如，我

浏览 2提问于2016-07-02得票数 1

1回答

Scala -- Flatmap是选项和可遍历的集合

scala、flatmap

考虑一下在某些情况匹配上编写的flatMap。如果seq是全部OptionInt或所有SeqInt，那么flatMap就能工作。但如果Seq是选项和Seq的混合体，则不是这样。为何会有这样的限制呢？这是否解决了我现在无法想到的一种特殊的模糊性。a.flatMap(x=>x)res24: Seq[Int] = L

浏览 4提问于2015-12-08得票数 1

回答已采纳

3回答

在使用flatMap时，是什么导致了这个错误？

scala

此代码：导致工作表中的此错误：- type mismatch; found此代码的行为与预期相同：1 until 3 flatMap (x => x + 1) 所有适用于map的集合是否也适用于flatMap？

浏览 10提问于2013-11-09得票数 0

回答已采纳

1回答

在级联中调用RXJava2可完成

android、rx-java2

通常，为了实现级联任务，我们使用flatMap。然而，我有一种情况，在这种情况下，我希望有两个相互依存的可完成任务。可完全OperationA；可完全OperationB；我需要OperationB只在操作A之后执行，因为没有可完成的平面图操作符，我应该如何处理这种情况？

浏览 1提问于2018-09-10得票数 0

回答已采纳

2回答

flatMap不适用于纱线测试javascript

javascript、reactjs、unit-testing、ecmascript-6、yarnpkg

我在我的组件方法中有一些代码。代码在浏览器中工作得很好，但是当使用flatMap运行代码时，yarn test方法并不存在。以前有人见过这样的东西吗？● Click Events › should copy table data | ^ 编辑-可复制的示例:创建了一个C

浏览 1提问于2018-08-17得票数 16

回答已采纳

1回答

如何在发生错误时停止反应器flatMap

java、spring-webflux、project-reactor

database here );concatMap(this::createReport)可能会产生错误为了提高加载速度，我决定用flatMap替换这个flatMap。但flatMap并不是那么可预测的。现在，如果出现错误，app将继续发送来自其他线程的请求，而忽略了某些id已经在retry中使用的事实，并且在超时活动之前，我将继续从服务

浏览 2提问于2020-11-11得票数 0

回答已采纳

1回答

内部映射在Rxjs中没有被调用

typescript、rxjs、nestjs

如果加载播放列表时出现错误，则属性设置为null： return this.internalFindOne(productId).pipe( return this.productPlaylistService.getProductPlaylist然而，我认为flatMap不适合这里。没有编译器

浏览 1提问于2020-06-04得票数 1

回答已采纳

1回答

rx-java2异常处理

rx-java2

我正在使用可流动迭代器，并处理来自可迭代器的每个项目的请求。如果抛出任何异常，如何找出发生异常的输入。例如： .flatMap(d -> Flowable.fromCallable(() -> getClaimStatusSystem.out.println("Processed"), err -> System.err.println(er

浏览 0提问于2018-06-21得票数 0

1回答

为什么在flatMap中调用可完成的方法不起作用？

swift、rx-swift、rx-cocoa

var bag = DisposeBag() requestCreateTodoRelay }) }为什么此函数todoUseCase.add() ->可完成，但不返回任何内容我希望当这个todoUseCase.add调用时，调用订阅的onCompleted闭包。我试着调查这个 debug#1返回

浏览 1提问于2020-11-30得票数 1

回答已采纳

2回答

选项平面图(GenTraversableOnce)

scala

这不管用：但这是肯定的：您不认为flatMap on Options应该像Seq那样使用GenTraversableOnce吗？或者这段代码不利于可读性，我应该使用match或map/getOrElse 编辑:我们在for/yield上也有同样的</

浏览 1提问于2016-02-26得票数 0

回答已采纳

2回答

RxSwift:将可完成的映射为单个可观测的？

ios、rx-swift

问题是返回一个可观察到的Single，其中成功/错误取决于Completable调用是成功还是失败。我的代码尝试大致如下所示： return repository.replace(with: value) // replace() returns a completable .flatMap</

浏览 0提问于2017-05-28得票数 8

回答已采纳

2回答

如何将其转换为使用期货，不确定如何使用Future.Traverse

scala、future

我有以下的旧代码，以前没有返回期货，但现在是这样了： val pm = securityService.generateABCresult <- Future.traverse(effectedRoleGroups)(rg -> securityService.generateABC(rg.id)但我不知道如何利用这种情况下的结果来传递给我的其他服务

浏览 3提问于2015-12-24得票数 0

回答已采纳

2回答

如何组合平面图，使其只需使用一次

swift

我有一个类，需要它为数据集中的不同变量找到最小/最大值。data.flatMap({$0.profitLoss}).min() else {return}guard let minValOther = data.flatMap({$0.other}).min() else {return} guard let minVal = data.flatMap({$0.value

浏览 0提问于2018-02-26得票数 2

回答已采纳

1回答

正确使用flatMap

csv、apache-spark、pyspark、bigdata

为什么每次我尝试我的RDD操作时都会得到这个错误&如何修复它？RDD以及它的ratingByUser，这表明问题出在flatMap中。我正在尝试做的是，我将CSV与( userID，movieID，rating)一起使用，并且我希望为每个userID创建唯一的movieID与rating的组合，但是不同的用户可以生成相同的movieID),(movie2,rating2)] ratingsPerUser = movieRati

浏览 0提问于2017-02-22得票数 0

2回答

为什么选项不继承Seq和Set？

scala、inheritance、scala-collections

我有两个问题，但我认为答案是交织在一起的。所以我在玩flatMapping不同的参数类型。//> o : List[Option[String]] = List(Some(f2), None, None)但 val a2 = a.flatMap因此，我试图

浏览 3提问于2013-10-23得票数 3

回答已采纳

2回答

Scala类型与Traversable不匹配

scala

我正在尝试编写一个函数，该函数接受可遍历的函数和可遍历的值，并返回应用于这些值的可遍历函数。当我试图调用列表和向量上的函数时，我会得到一个类型错配错误。这是我的代码： for (ys然后我尝试使用以下方法

浏览 4提问于2017-02-23得票数 1

回答已采纳

点击加载更多