stream-processing

0热度

1回答

我试图找到关于此的信息，但我没有找到我要找的东西。我在Elasticsearch数据库中存储每分钟的指标。我的想法是，频率仅在短时间内很重要。例如，我想有我每次度量分钟，最后过去的一周，但后来我想，为了合并这些指标只有一个指标，每个过去几周的文件。因此，我有一个想法来实现这个与流处理框架，如火花流或Flink，但我的问题是：是否有一个本地方式/工具/技巧使它发生在Elasticsearch？

1热度

1回答

如何与Apache Flink会话流？

我想分享这个流：1,1,1,2,2,2,2,2,3,3,3,3,3,3,3,0,3,3,3,5，。 ..这些会话： 1,1,1 2,2,2,2,2 3,3,3,3,3,3,3 0 3,3,3 5 我已经写CustomTrigger检测何时流元素从1到2改变（2到3,3到0等），然后触发触发器。但这不是解决方案，因为当我处理2的第一个元素并触发触发器时，窗口将是[1,1,1,2]，但我

0热度

1回答

用于增量数据的Flink或Spark

我对Flink或Spark没有任何经验，并且我想将其中的一个用于我的用例。我想介绍一下我的使用案例，希望能够了解一下这两者是否可以完成，如果他们都可以这样做，哪一个最好。我有一堆存储在数据存储中的实体A（Mongo是精确的，但确实没关系）。我有一个Java应用程序，可以加载这些实体和运行一些逻辑他们生成一些数据类型的流E（要100％清除我没有Es在任何数据集中，我需要生成它们在Java中后，我加

0热度

1回答

发送到服务器的消息在源达到绑定后实现流处理会发生什么？

林学习阿卡流，但显然其相关的任何流框架:) 报价阿卡文档：无流仅仅是定义如何在异步边界移动数据没有一个共同的机制损失，缓冲或资源耗尽现在，从我的理解是，如果前，直到流，让我们例如http服务器，请求会来当接收方wasent完成了一个请求，所以新的请求将被收集到一个缓冲区中，该缓冲区将保存等待的请求，然后存在一个问题，即该缓冲区的大小未知，并且在某些时候如果服务器过载我们可以放弃正在等待的请

94热度

2回答

如何获得Postgres/SQL中两个整数的最小/最大值？

如何在Postgres/SQL中找到两个整数的最大值（或最小值）？其中一个整数不是列值。我举一个例子场景：我想从一列（在所有行）减去一个整数，但结果应不小于零。所以，首先，我有： UPDATE my_table SET my_column = my_column - 10; 但是，这可以使一些值为负。我想（在伪代码）是： UPDATE my_table SET my_column =

0热度

1回答

Dynemically时区不在laravel工作

我已经在我的应用程序中设置了动态时区，但它显示错误的结果。这里是我的代码 $timezone = [ 'asia_calcutta_time' => 'Asia/Calcutta', 'europe_madrid_time' => 'Europe/Madrid', 'us_eastern_time' => 'US/Eastern' ]; fo

4热度

1回答

Apache Apex与Apache Flink

由于两者都是一次处理事件的流式框架，这两种技术/流式框架之间的核心架构差异是什么？另外，哪一个比另一个更合适？

2热度

2回答

Camel-Kafka组件无法正常工作：“因为经纪人必须配置”

使用kafka组件为Apache Camel（版本2.19.1）发生错误，我只是试图在主题中打印传入消息，我的管道是这样构成的： ... context.addRoutes(new RouteBuilder() { public void configure() { from("kafka://localhost:9092?topic=test&groupId=te

0热度

3回答

我如何获得Alamofire编码以下链接 - 它持续下降参数

我试图让Alamofire这个URL编码如下使用url编码 https://domain.com/rest/api/2/search?query=assignment=user123()%20order%20by%20lastUp%20desc 我用下面的代码： let endpoint = "https://domain.com/rest/api/2/search/" let params:[

1热度

1回答

从云网关摄取物联网数据的方法

我想听听您对物联网数据摄取案例的见解。在AWS IoT中心，物体阴影是物理物体的虚拟表示。我从下图中了解到，无论什么时候通过消息代理发送数据到平台，事物阴影和规则引擎部分同时获得相同的传感器数据并处理它。我的结论是否正确？事情影子系统订阅消息代理并获取传感器数据，更新他们的影子参与者。影子侧还负责存储传感器数据，例如事件采购机制。事物影子系统不执行任何规则，它只是执行事件源并保持虚拟事件演员