aggregator

2热度

2回答

我想了解聚合器的基础知识。下面是使用情况下，我想实现：从队列 1）读消息（订单详细信息）。 <?xml version="1.0" encoding="UTF-8"?> <order xmlns="http://www.example.org/orders"> <orderItem> <isbn>12333454443</isbn> <quantity>4</qua

1热度

1回答

Apache Camel：文件到BeanIO并基于ID合并beanIO对象

我有用于并行读取员工，地址和联系人文件的用例，并将其转换为beanIO对象并合并beanIO对象以生成完整的employeeDetails对象。的Emp文件： 1 Foo Engineer 2 Bar AssistantEngineer 的Emp联系人文件： 1 8912345678 [email protected] 2 7812345678 [email protected] 的

0热度

1回答

Apache的骆驼：GroupedExchangeAggregationStrategy组DefaultExchange代替消息主体

在继续给其他线程， Apache Camel : File to BeanIO and merge beanIO objects based on id 试图组使用GroupedExchangeAggregationStrategy的EmployeeDetails如下 from("seda:aggregate").aggregate(simple("${body.id}"), new Merge

0热度

2回答

是总是排序的informatica聚合器的输出？

Informatica中的聚合器组件的输出是否总是按指定的组进行排序，当输入排序框未勾选且组件是否自行分组时？还是没有保证？

0热度

1回答

不允许使用空关联。也许CorrelationStrategy失败？

我正在使用弹簧集成，我使用的是默认关联策略，也就是我没有明确地写关联策略的代码，一切正常，直到分离器，分离器之后有一个服务激活器，它执行一些处理，然后放置该消息放入聚合器必须从中选择它的通道中，但聚合器不会选择它，所以我放置了一个拦截器来查明发生了什么，并且发现在将消息放入聚合器通道之前，聚合相关头文件像相关ID等存在，但一旦其放入通道的标题丢失。现在我不知道为什么聚合器或通道之前，是失去了标题。

0热度

2回答

只汇总具有相同关联密钥的连续交换

我使用的是Apache Camel并获取一个大文件以进行输入，我必须逐行处理。内容已经排序，我必须使用相同的关联关键字聚合所有连续的行。如果相关键发生变化，则必须完成前一个聚合。如果文件结束，最后的聚合也已完成。我有一些限制： - 由于传入文件相当大，我们希望以流式处理它。 - 因为结果赋予同步端点，所以我不想使用超时完成谓词。否则，我将失去调节数据源消耗速度的背压，并且交换将积累在Aggreg

-2热度

1回答

FluentD Aggregator - 何时使用？

我们正在考虑使用FluentD将代理& dhcp服务器的Blue Coat日志事件发送到弹性服务器。其中一个关键要求是尽快标出异常值&异常。对于这样的要求，使用FluentD Aggregator从多个（可能是数百个）FluentD收集器代理接收事件是否合理？或者，让FluentD代理将事件发送到写入Elastic的Kafka集群会更好吗？如果我能得到关于何时使用FluentD Aggreg

0热度

1回答

骆驼聚合器不聚合所有

我分裂一些Java对象，然后聚合。我有点困惑这个完成策略如何与骆驼（2.15.2）。我正在使用完成大小和完成超时。如果我理解正确，完成超时并没有太大的影响。因为，这里没有太多的等待。总而言之，我有3000多个对象。但是，似乎只有它的一部分被汇总。但是，如果我改变完成规模值，情况会发生变化。如果大小为100，则它大约为800，如果它是200，则它总计大约为1600.但是，我不知道事物的大小，因此不

0热度

1回答

使用弹性搜索API汇总过滤结果

我想根据我的过滤规则对文档数量进行汇总和计数。我看着从他们的网站的API：https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-bucket-filters-aggregation.html ，并与该出来了： { "size": 0, "aggregations": {

1热度

1回答

Apache Camel：构建XML解析批处理的正确方法？

我想编写一个骆驼批：过程的特定目录内，每个文件中的所有文件：验证XML与XSD架构和解组不同的部分和处理数据没有停止对异常如果发生至少一个错误，将失败dirrectory末，移动到完成，否则个的困难，我遇到：文件组件允许自动移动上完成文件/失败目录，但只要你使用分流/聚合器，该文件是总是在做，唐迁甚至不会等待聚合完成。管理的例外是不直观斯普利特和aggretors是噩梦并没有