问题标签 [flatmap]

我有这个方法：

toDigits 有这个签名：

在 flatMapToLong 线上，它给出了这个错误

类型不匹配：无法从 Stream< Long > 转换为 LongStream

当我将其更改为

我收到这个错误

类型不匹配：无法从 List< Long > 转换为 LongStream

唯一有效的是这个

这两个功能有什么区别吗？什么时候适合使用其中一种？有什么取舍吗？

我有 CSV 字符串，例如 HK1、Hk2、Hk3 ......、SG1、SG2 等等。根据列表的大小，我需要调用后端系统的 REST 调用，但问题是，如果 String 太长，后端系统需要多次调用，例如如果 String 有 8 个值，则分为 2 个调用。

所以我们决定在 play framework 中使用 flatMap，我们的问题是字符串是动态的，有时它有 10 个值，有时 20 有时 25，在这种情况下如何使用 flatMap。

我可以将列表划分为 4 的倍数，但我们需要如何动态调用 flatMap 以便覆盖所有子列表。

我刚开始使用 Spark 和 Scala

我有一个包含多个文件的目录，我使用成功加载它们

现在我想更上一层楼。我实际上有一个目录，其中包含包含文件的子目录。我的目标是获得一个，RDD[(String,String)]以便我可以继续前进，其中RDD代表文件的名称和内容。

我尝试了以下方法：

但我得到了Seq[RDD[(String,String)]] 如何将其Seq转换为RDD[(String,String)]？

或者也许我没有做正确的事情，我应该尝试不同的方法？

编辑：添加代码

让我们考虑一下我有以下课程：

其中i, j,k有一个已知范围：r_i, r_j, r_k. 现在我想A在这个范围内生成所有可能的实例。我可以想出类似的东西：

首先，它太冗长了。有没有办法缩短它？特别是我找不到range on Stream。其次，编译器无法确定返回类型的类型。它认为它 List<Object>而不是预期的List<A>。我该如何解决？

我将一组行作为输入并跟踪字长的分布。输入中包含换行符的额外空格无关紧要。输入结束后，输出是基于文本的字长分布直方图：例如：“嘿，你好吗，嘿，我很好”

输出：1 - 0, 2 - 1, 3 - 5, 4 - 1, 5 - 0

其中（第一个字符是单词的长度，第二个是没有该长度的单词）。我已经写了

我想将相同长度的单词分组，然后将它们存储在迭代器或映射中

没有给我想要的结果。有什么建议么？

我正在使用 RxJava 链接异步操作，我想向下游传递一些变量：

这似乎是一种常见的模式，但我找不到有关它的信息。

我有一个 hadoopFiles 对象，它是从sc.newAPIHadoopFile.

我打算使用操作遍历 hadoopFiles 中的所有行并对其进行过滤，其中if应用检查并将引发异常：

但是，如果我删除该if(pair.length == 2)部分，它会正常工作：

谁能告诉我这种现象的原因，并告诉我应用该if声明的正确方法。非常感谢！

PS我们可以用这个简化的例子来测试：

在这段代码中：

取自：如何列出 scala 子目录中的所有文件？

为什么要flatMap(recursiveListFiles)编译？asrecursiveListFiles接受File参数？文件参数是否隐式传递给recursiveListFiles？

我正在尝试使用以下 java 8 代码将aList函数“应用”到 a对象。ListFile

我得到的输出如下，

将函数列表应用于收集的所有文件......

问题 1：为什么我在第二个输出中得到一个列表列表，而在第一个输出中只有一个列表？他们都在集合流上使用平面图。

问题 2：在 Java 8 中是否有更好的方法来实现相同的目标？