《欢聚集团》专题

当我尝试使用Hive执行非聚合命令时，查询似乎可以正常工作，如下所示： 从Airlines_Analysis.Airline中选择*；从Airlines_Analysis.Airline中选择Airlines.Month； org.apache.hive.service.cli.hivesqlexception：处理语句时出错：失败：执行错误，从org.apache.hive.service.cl

有没有办法将弹性搜索GeoHash转换为具有适当缩放级别的bing地图图钉？ https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-bucket-geohashgrid-aggregation.html

我正在尝试使用Elasticsearch（2.4）聚合对使用该查询的多个索引按“productId”分组 1） 我想按分数排序，所以我尝试使用 哪个返回 2） 此外，我正在尝试使用分页，“size”键实际起作用，但“from”键不起作用 **更新-聚合结果示例** 希望有人能帮忙

我有一个elasticsearch请求如下： 我想在这个请求中添加分页，就像 我搜索了很多，找到了一个关于它的链接：https://github.com/elastic/elasticsearch/issues/4915. 但我仍然没有得到实现方法。 有没有办法通过Elasticsearch本身而不是我的应用程序来实现它？

我是Elasticsearch的新手，我希望在Elasticsearch 5的字段上执行某些聚合。x索引。我有一个索引，其中包含带有字段（具有嵌套结构）和字段（具有嵌套结构）的文档。这些是动态映射的字段。以下是示例文档 文件2： DOC 3： 我想在langs字段上执行总和聚合，这样对于每个键（X/Y）和每种语言，我都可以获得索引中所有文档的总和。此外，我还想从docLang字段生成每种语言类型的

我已经在按\u score desc排序的查询部分中获得了所需的查询结果。现在我需要提取每个文档的3个字段。我想实现如下目标： 我刚刚试过： 1）使用折叠删除重复的值 但问题是它只会保留filed1的不同值，而忽略field 2和field 3的值。例如，我们有2条记录，如下所示： 使用此方法，我们只能获得一条记录，因为它们具有相同的field1值。我想要这三个字段的不同组合值。我们可以使用int

我正在对文档中的“位置”字段进行聚合，在同一文档中还有一个“城市”字段。我正在查询“城市”字段上的文档，并聚合“位置”字段上的文档。 现在计数和聚合都很好，随着hits.but我的问题是，我想在“doc-count”设置为0的情况下进行聚合，聚合桶会返回所有计数为0的lcoations，这些lcoations甚至落在其他城市。我只想获得0个计数位置，只是为了city.want将0个计数位置的上下文

基本上，我试图通过名字和姓氏找到重复的联系人 我错过了什么吗？任何帮助都将不胜感激。 下面是示例文档之一 我试图对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的子聚合