《欢聚时代》专题

基本上，我试图通过名字和姓氏找到重复的联系人 我错过了什么吗？任何帮助都将不胜感激。 下面是示例文档之一 我试图对Elasticsearch进行如下查询：

我需要在其中一个索引中进行聚合排序分页。 我了解了弹性搜索的内部功能， 我总共有5个分片，它会对各个分片进行排序并获取结果，默认情况下每个分片将返回10条记录。然后再次对50条记录进行排序，它将获取前10条记录，因为默认大小为10。 输出： 聚合结果在名为“聚合”的单独字段中返回。为了在此聚合数据中进行分页，size和from不起作用。 厌倦了做termBuilder.size（500），现在逻辑

我有一些文件存储在Elasticsearch中，如下所示： 我想得到的是字段1、字段2或字段3对每个文档的最大次数的计数，按日期分组，即。期望结果如下： 我在date上使用了一个术语聚合，但不知道如何比较不同的字段，以便使用Elasticsearch聚合来执行此max and count类型的操作。有什么建议吗？

我们计划将Apache Flink与一个巨大的IOT设置一起使用。客户将向我们发送某种结构化的传感器数据（如sensor_id、sensor_type、sensor_value、timestamp）。我们没有控制每个客户何时发送这些数据，最有可能是实时的，但我们没有保证。我们将所有事件存储在RabbitMQ/Kafka中。更新：我们可以假设每个传感器的事件是按顺序来的。 在开始实施可能的流式管道之

我有一个表示为的自定义状态计算，当我的看到来自Kafka的新事件时，它将不断更新。现在，每次更新状态时，我都希望将更新后的状态打印到stdout。想知道怎么在Flink中做到这一点吗？与所有的窗口和触发器操作很少混淆，我一直得到以下错误。 我只想知道如何将我的聚合流打印到stdout或写回另一个kafka主题？ 下面是引发错误的代码片段。

我正试图弄清楚如何使用Spring Batch进行聚合。例如，我有一个带有姓名列表的CSV文件： 我想要文本文件中的姓名计数： 根据我从Spring Batch中学到的，ETL批处理过程（itemReader- Spring Batch是正确的工具吗？还是我应该用Spark？谢谢

我有一个具有以下模式的待售项目集合： 我继承了一个聚合查询，它返回匹配类别的项目，按商家分组，组按组中的最大评级排序： 在此之后，代码继续按评级对每组中的项目进行排序，并删除除每组中排名前2位之外的所有项目。 作为聚合函数的一部分，是否可以在组内执行此排序和限制，以便聚合只返回每组中评级最高的两个项目？

我知道Elasticsearch支持带bucketing的子聚合（其中bucketing聚合可以有bucketing或metric子聚合）。使用度量聚合无法进行子聚合。也许这是有道理的，但这里是用例。 作为家长，我有术语聚合。并将另一个术语聚合作为它的子项。子术语具有类型为top\u hits的子聚合

我想在JAVA API中编写elasticsearch聚合代码，以查找字段折叠和结果分组。 json聚合代码如下所示，我从elasticsearch文档中获得了这些代码 “dedup\u by\u score”聚合具有称为“top\u hit”聚合的子聚合，并将此聚合用于桶排序。 我想将这个json查询转换为JAVA 这是我已经在JAVA中尝试过的 但是我从Elasticsearch得到了如下错误

索引文档如下： 我想要的是按平台计数和输出统计信息。对于计数，我可以使用带有的术语聚合作为字段进行计数： 通过这种方式，我以多个bucket的形式接收统计数据，看起来就像预期的那样{key:8，doc\u count:162511}。 现在，我可以以某种方式将和（用于漂亮的统计输出）添加到这些桶中吗？我带来的最好的看起来像： 实际上，它可以工作，并在每个桶中返回非常复杂的结构： 当然，平台的名称和

我想要实现的是通过唯一对（城市、州）进行聚合。根据Elasticsearch文档，术语聚合不支持从同一文档中的多个字段收集术语。因此，我创建了一个嵌套的agg，如下所示： 作为这种聚合的结果，我得到了这样的响应： 问题是如何获得按最深doc\u计数排序的结果？ 预期的有序列表应如下所示： 内华达州拉斯维加斯（5840） 杰克逊维尔，佛罗里达州（2986） 北卡罗来纳州杰克逊维尔（1962） 亚利桑

我想根据组字段G对文档进行分组。我使用弹性文档中描述的“字段聚合”策略按包含文档的最大分数对存储桶进行排序（在弹性文档中称为“字段折叠示例”），如下所示： 此查询还包括每个存储桶中的最高命中数。如果存储桶的最大分数不是唯一的，我想指定一个二阶列。从应用程序上下文中，我知道在存储桶中，所有文档共享相同的字段F值。因此，该字段应用作二阶列。 如何在Elastic中实现这一点？有没有办法使顶部命中子聚合

我在使用聚合框架从MongoDB读取文档时遇到了问题：我的结果中总是得到空ID。这只发生在具有复合ID的文档中。我尝试了各种版本的spring-data-mongob（1.10.12, 2.0.7)，结果相同。 实体定义类 测试代码 输出 调试到以下方法MappingMongoConverter。read（final mongopersistenentity entity、final Docume

我一直在尝试使用聚合框架按对报告进行计数。尝试1： 这导致聚合框架抛出: 然后更改为使用而不是进行尝试#2: 最后，我在尝试#3中使用了lambda来实现接口： 这一尝试终于奏效了。 问题1：这是Hazelcast的一个bug吗？似乎聚合框架应该支持由或构建的？如果不是，那么应该创建一个新的类型（例如，)来避免这种混淆。 问题2（与问题1相关）：使用lambda会导致我创建的索引未被使用。相反，映

我需要计算15分钟内A发生的次数和B发生的次数。该流可能是A1，A2，B1，B2，A3，B3，B4，B5，A4，A5，A6，A7，B6 .在我的例子中，事件结果是A2，B1 A3，B3 A7，B6 .我需要接收匹配发生时的实时结果。我有点累了。我认为只有使用flink cep才能做到这一点.但是flink-sql-cep不支持聚合。它只计算发生的事件。在这种情况下，如何用一条SQL完成这项任务。