Tag: 聚合

这是聚合吗?

我有以下代码 public static void main(String[] args) { Engine engine = new Engine(“This Engine!”); Car b = new Car(engine); b = null; } 这是聚合吗? 我总是认为聚合是指即使另一个类被“摧毁”,某些东西仍然可以“生存”……例如Car and Engine。 如果我删除Car实例,引擎仍然可以存在。 它是否正确?

ElasticSearch仅返回具有不同值的文档

假设我有这个给定的数据 { “name” : “ABC”, “favorite_cars” : [ “ferrari”,”toyota” ] }, { “name” : “ABC”, “favorite_cars” : [ “ferrari”,”toyota” ] }, { “name” : “GEORGE”, “favorite_cars” : [ “honda”,”Hyundae” ] } 每当我在搜索最喜欢的汽车是丰田的人时查询这些数据,它就会返回这些数据 { “name” : “ABC”, “favorite_cars” : [ “ferrari”,”toyota” ] }, { “name” : “ABC”, “favorite_cars” : [ “ferrari”,”toyota” ] } 结果是两个名称为ABC的记录。 如何仅选择不同的文档? 我想得到的结果只是这个 […]

Camel 2.11批量聚合如何与单独的路由一起工作?

首先,有一个类似的未回答的问题将路由连接到单个聚合器 我们有一些消费者路线(ftp,file,smb)从远程系统读取文件。 使用直接路由进行简化测试,但与批量使用者的行为类似: from(“direct:”+routeId).id(routeId) .setProperty(AGGREGATION_PROPERTY, constant(routeId)) .log(String.format(“Sending (${body}) to %s”, “direct:start1”)) .to(“direct:aggregate”); 转换后,一次轮询的所有结果将在一个单独的路径中按批次聚合: from(“direct:aggregate”) .aggregate(property(AGGREGATION_PROPERTY), new BodyInAggregatingStrategy()) .completionFromBatchConsumer() .to(“log:result”, “mock:result”); 如果每个消费者分开运行,一切正常。 但如果多个消费者并行运行,聚合将拆分民意调查。 例如,如果文件消费者轮询500条消息,而第二条路线开始从ftp读取6个文件,那么我们得到2个聚合1,其中500条来自文件,1条来自ftp的6条消息。 测试用例: public void testAggregateByProperty() throws Exception { MockEndpoint result = getMockEndpoint(“mock:result”); result.expectedBodiesReceived(“A+A+A”, “B+B”, “A”, “Z”); template.sendBodyAndProperty(“direct:A”, “A”, Exchange.BATCH_SIZE, 3); template.sendBodyAndProperty(“direct:A”, “A”, Exchange.BATCH_SIZE, 3); template.sendBodyAndProperty(“direct:B”, “B”, Exchange.BATCH_SIZE, 2); template.sendBodyAndProperty(“direct:A”, “A”, Exchange.BATCH_SIZE, 3); template.sendBodyAndProperty(“direct:B”, […]

Maven – 聚合的“全部”或“父母”项目?

出于教育目的,我已经建立了一个像这样的项目布局(为了更好地适应日食): -product | |-parent |-core |-opt |-all Parent包含一个包含core,opt和all的聚合项目。 Core实现了应用程序的强制部分。 Opt是可选部分。 所有这些都应该将core与opt结合起来,并将这两个模块列为依赖项。 我现在正在尝试制作以下工件: 产品core.jar添加 产品核心src.jar 产品的核心与 – dependencies.jar 产品opt.jar 产品-OPT-src.jar 产品选择与 – dependencies.jar 产品all.jar在 产品全src.jar 产品全有,dependencies.jar 他们中的大多数生产相当简单。 我确实有一些聚合工件的问题。 我已经设法在’all’模块中使用自定义程序集描述符生成product-all-src.jar,该模块下载所有非传递deps的源代码,这样可以正常工作。 这项技术还允许我使用all-with-dependencies.jar。 然而,我最近发现您可以在源插件中使用source:aggregate目标来聚合整个聚合项目的源。 对于javadoc插件也是如此,它也通过父项目的使用进行聚合。 所以我在’all’模块方法和放弃’all’模块之间徘徊,只使用’parent’模块进行所有聚合。 在’父’中产生一些聚合工件并且在’all’中产生其他产品感觉不干净。 有没有办法在父项目中制作’product-all’jar,或者在’all’项目中聚合javadoc? 或者我应该保留两者? 谢谢

流Java 8 api中是否有aggregateBy方法?

浏览Brian Goetz这篇非常有趣但却有一年历史的演示文稿 – 在幻灯片链接中他提出了一个假设在Stream API中的aggregateBy()方法,该方法应该将列表(?)的元素聚合到一个映射中(给定一个默认初始值和操纵值的方法(对于重复键也是如此) – 请参阅演示文稿中的下一张幻灯片)。 显然, Stream API中没有这样的方法。 还有另一种方法可以在Java 8中做类似的事情吗?