问题标签 [flatmap]

我正在阅读 Learning Spark 书，但无法理解以下对 rdd 转换。

它应用于 rdd {(1,2),(3,4),(3,6)}，转换的输出为{(1,2),(1,3),(1,4),(1,5),(3,4),(3,5)}

有人可以解释一下吗。

在打字稿中，RxJS Observable.flatMap 似乎与使用 Observable.fromPromise(promise) 创建的 Observable 的行为不正确。

我怀疑它不会触发更改检测。

我有这 2 个功能（在 _httpClient 类中）：

当我这样做时：

我的视图未更新，我需要单击某处（如按钮）以显示检索到的数据。

但是当我使用BasicObservable() 而不是ObservableFromPremise()时，我的视图会更新。

以下是我处理函数 get（在 UserConnector 类中）的方式：

在我的页面中：

这是模板：

在这两种情况下，我都在控制台中记录了检索到的数据，以及“获取已完成的项目”，但是使用 ObservableFromPremise()，数据不会在屏幕上更新（直到我单击一个按钮）。

我的配置：angular2 (2.0.0-rc.1), RxJS (5.0.0-beta.6), zone.js (0.6.12), e6-shim (0.35.00)

我能做些什么呢？这是我的代码中的错误吗？在 zone.js 中？在 RxJS 中？

谢谢你的帮助

编辑 1：正如@Richard-Silveira 所建议的，我将使用 NgZone 作为临时解决方法：

我希望有人能分享一个真正的解决方案=）

Scala 期货的新手我尝试调用一个网络服务，比如

使用ply-ws库

我验证并映射响应如下https://gist.github.com/geoHeil/943a18d43279762ad4cdfe9aa2e40770

主要的是：

奇怪的是，这在 repl 中工作得很好。但是，如果通过运行sbt run我会得到一个 NullPointer 异常。我已经手动验证了 JSON 响应。它像微风一样验证。甚至映射效果也很好。但是，我使用的期货肯定有问题。但我不确定出了什么问题。似乎在已经有结果之前调用了 flatMap 方法。

有趣的是，如果我不等待结果，则没有空指针异常，但解析的结果会正确显示（但是，程序不会退出）。但是在我真正使用此代码的地方，我不知何故需要等待成功完成以进一步处理它。

您将在下面找到问题的说明

我正在学习 Scala 并解决了 99 个 Scala 问题。对于以下练习：

展平嵌套列表结构。例子：

解决方案如下

但我想知道为什么以下不起作用？

IntellJ IDEA 告诉我问题出在flatten(ms)部件上，说“无法使用这样的签名解析引用变平”，并且在List类文档中flatten说“注意：编译器可能无法推断类型参数”。

任何想法为什么第二个代码不起作用？

我被要求检索作为树节点的 descandant 的每个叶节点。我很快就想到我可以在一条线上完成这项工作！

乍一看很好，但StackOverflowExcepetion如果树深度达到〜10，它很快就遇到了，这是我无法接受的。后来我开发了一个没有递归和流的实现（但是我的大脑被烤了），但我仍然想知道是否有办法flatMap用流做递归，因为我发现如果不接触流内部就不可能这样做。它需要一个新的操作，就像RecursiveOps这样做，否则我必须将所有结果收集到Set每一步中，然后再对其进行操作Set：

不像看起来那么好。流意味着是一个管道。在添加终端操作之前，不会计算其结果和中间结果。上述做法显然违反了这一原则。并行化也不像流那么容易。我可以在不手动计算所有中间结果的情况下递归 flatMap 吗？

PS1：TreeNode 声明：

我对这些代码感到困惑，为什么它们会有所作为？

更新：请看这些代码，我

我正面临这个错误，flatMap但不是map。转换不支持布尔运算flatMap吗？

我目前正在学习 XSLT，但是对于我来说做任何有用的事情仍然太模糊了。您能否给我一个提示（或者更好的是样式表）来转换所有这样的元素

进入这个？

谢谢你。

编辑：我正在学习并尝试使用 XSLT 1。

说我有以下代码。

问题：

1) 对于平面图中的每个 x，函数 f(x) 会被调用两次吗？因为我先调用了 f(x)._1，然后调用了 f(x)._2。

2）flapmap会并行执行（尤其是数据读取部分）吗？假设我有 3 个节点，每个节点有 32 个核心。我设置了--num-executors=2 和--executor-cores=32。另一个节点用作驱动节点。

为了回答上述问题，我在文档中搜索了很多 Spark/Scala，但没有从那里得到任何答案。我试图在我自己的系统上运行代码。看起来像这样

1) f(x) 被调用了两次，因为我发现数据分区被处理了两次。但是，我不确定。

2）我注意到在火花日志文件系统下创建了两个执行程序文件夹，每个执行程序也有一些标准输出。但是，我也不确定。

谢谢 ！

我正在尝试使用 flatMapResource<T>在 Swift 中构建一个，但不断收到一个奇怪的错误，并且仅在我强制转换时才有效。

Resource<T>：

工作代码：

上面的代码给出了强制转换总是成功的警告，这是真的。但是当我尝试像这样删除演员表时：

它给出以下错误：'flatMap' produces '[S.Generator.Element]', not the expected contextual result type 'T'?。

解析器是struct init这样的：

任何想法如何解决这个问题或不同的方法？这里的想法是将任何 CKRecord 轻松转换为结构，而无需编写大量样板代码。