问题标签 [collect]

我正在使用 Java 8 按数据分组。但是得到的结果并不是按顺序形成的。

在这里，我正在使用我的类 groupingKey，我通过它动态地从 ux 传递。如何以排序形式获取此 groupByColumns？

我一直在尝试在我的应用程序中使用 ActiveRecord::Base 方法，例如 .each 和 .collect ，但我不断收到未定义的方法错误！也许我对 Ruby 的了解不够深入。好像我不能在我的控制器、方法或视图中使用这些方法？

例如，下面的代码会给我一个未定义的方法“收集”：

另一个例子也会报错：

我不能在我的控制器、模型或视图中使用这些方法。我可以在哪里使用它们？谁能告诉我我的基本 Ruby/Rails 代码是否错误？

我正在使用 Rails 4.20 和 Ruby 2.1.5p273

我已经从单个 RDD 中的某个目录“上传”了 N 个文件

例如，我的 2 个文件每个包含 5 行。

文件 1

文件 2

如果我将 sortBy 添加到我的代码中：

我没有得到我的排序数据，而只是一个随机的 RDD：

收集可以帮助我，但是

1）它不适合大型RDD

2）而不是RDD，它返回一个数组（我应该重新并行化）

提前致谢

法郎

我有Stream<String>一个文件，现在我想将相等的单词组合成一个Map<String, Integer>重要的，这个单词在Stream<String>.

我知道我必须使用collect(Collectors.groupingBy(..))，但我不知道如何使用它。

如果有人可以提供一些提示如何解决这个问题，那就太好了！

我正在尝试提高我的 Spark 应用程序代码对“收集”的理解，并且我正在处理以下代码：

基本上我正在创建一个 [String,String,String] RDD，其中包含一个不必要的（恕我直言）收集/并行化步骤（原始 RDD 中的 200k 个元素）。

Spark 指南说：“收集：在驱动程序中将数据集的所有元素作为数组返回。这通常在过滤或其他返回足够小的数据子集的操作之后很有用。”

顺便说一句：200k足够小吗？

我觉得这段代码应该“更轻”（没有收集并行）：

但是在多次运行（本地未分发）同一个应用程序之后，我总是使用第一个代码获得更快的时间，在我看来这是一项额外的工作（首先收集然后并行化）。

整个应用程序（不仅仅是这个代码片段）在第一种情况下平均需要 48 秒，在第二种情况下至少需要 52 秒。

这怎么可能？

提前致谢

我正在开发一个 shopify 应用程序，我想在其中运行 Ruby 中的脚本。我想根据此链接https://docs.shopify.com/api/collect更新收集对象的“位置”和“排序值” 。每次我尝试这样做时，都会出现 ActiveResource 错误。

这是我在 irb 中的代码：

我已经尝试了下面给出的代码，它在 irb 中运行良好

我收到了这个错误：

ActiveResource::ResourceNotFound：失败。响应代码 = 404。响应消息 = 未找到

我们可以在 Collect 对象上发送 http PUT 请求来更新位置吗？提前致谢..

我有一张这样的桌子：

我想做以下事情：

1. 按工作分组
2. 获取学校列表和计数，像这样[(school1, 2), (school2, 1)]
3. 学校列表按计数排序，所以不能是 [(school1, 1), (school1, 2)]

该示例的结果是：

我是 Scala 的新手，并试图找出过滤和映射集合的最佳方法。这是一个玩具示例来解释我的问题。

方法 1：这很糟糕，因为我要遍历列表两次并在每次迭代中计算相同的值。

方法2：这稍微好一点，但我仍然需要计算(x * x)两次。

那么，是否可以在不迭代集合两次并避免重复相同计算的情况下计算它？

我的代码应该显示一个带有字符串列表的警报对话框。一旦用户选择了一个，我需要使用该字符串。

我在调用getTagSelectionFromDialogBox（）的主要活动中有函数handleIt（）。有 public String selectedTitle 和 public integer title_position。

我看到一个问题，从 handleIt() 调用 getTagSelectionFromDialogBox() 之后，我调用 Toast 来打印 selectedTitle。

我在这里看到的问题是警报对话框和 Toast 都在执行，并且 Toast 显示 null（因为它被初始化为 null）而不是 Toast 等待 getTagSelectionFromDialogBox() 完成。这是我的代码

我需要一些机制来等到 alert 得到结果和（这里是一个字符串），我需要在 getTagSelectionFromDialogBox() 之后对那个字符串做很多工作，我不想在 onClick 中做() 的 DialogInterface.OnClickListener()。

下面是代码片段公共类 MainActivity 扩展 ActionBarActivity NavigationDrawerFragment.FragmentDrawerListener{

}

敬酒后，我必须使用 selectedTitile 并执行一些我不想在 onClick() 中执行的数据库操作

我怎样才能做到这一点？

我刚刚启动并运行了 ELK-stack（Elastic、Logstash 和 Kibana）。现在我准备开始处理日志了。

我的问题是：收集日志以使用 logstash 处理的常用方法是什么？

场景：我在服务器上有一些日志，我需要转移到 logstash-server。

提前致谢

回答（据我了解）

由我来决定如何收集日志以供 logstash 处理。如果您还在要从中收集日志的服务器上安装 logstash，logstash 有许多输入（用于在本地处理日志）和输出插件（用于发送日志），可以将日志发送到中央 logstash 服务器(s)。