我有一些能源表，它会不断产生一个累积的计数器值。即保持递增，直到计数器复位。有一个实时ETL作业，用于在事件时间内进行两个连续值之间的减法。此外，有时事件可能不会按顺序接收。 如何使用Apache Flink Streaming API实现？在Java中使用示例更好。
浏览 251提问于2020-09-12得票数 0
回答已采纳
对于曲柄节奏，这是：
我想了解最后一次曲柄事件时间是如何定义的。文档使得它听起来像一个时间戳，但是由于它是一个16位整数，在1/1024秒时，它会在大约1分钟后溢出。所以我怀疑这实际上是一个时间间隔。下面是一个时间尺度上的一系列事件。消息B向n+2发送曲柄旋转<
浏览 5提问于2020-10-31得票数 1
回答已采纳
1回答
我希望找到每两个连续输入事件之间的事件时间差。如果时差高于某一阈值，那么我希望输出一个事件，发出信号表示该阈值已被打破。我还希望流的第一个事件始终输出这个中断信号，以指示它没有以前的事件来计算时间差。
我尝试使用Flink的CEP库，因为它确保事件按事件时间
浏览 10提问于2022-08-15得票数 0
回答已采纳
我想在processwindowfunction中设置状态的TTL。此状态在窗口之间共享。此TTL需要基于事件本身中的属性。所以我不能计算状态描述符中的TTL。
浏览 15提问于2021-04-08得票数 0
回答已采纳
我正在编写一个Flink应用程序，它使用kafka主题中的时间序列数据。时间序列数据包含指标名称、标记键值对、时间戳和值等组件。我已经创建了一个滚动窗口，用于根据指标键(指标名称、键值对和时间戳的组合)聚合数据。我还想检查上面窗口之外是否有任何延迟到达的指标。我想要检查有多少指标延迟到达，并计算与原始指标相比延迟指标的百分比。我正在考虑使用flink的"allowedLa
浏览 17提问于2021-08-09得票数 0
回答已采纳
1回答
我是新的flink和寻求建立一个实时事件相关系统的建议。我有两个主要用途：
事件关联逻辑包括基于输入流中的事件类型的静态规则。最后，根据这些规则，将不同事件类型的事件与具有业务价值的事件输出数据进行关联。对于利益/业务价值的事件，计算最后X分钟的</em
浏览 2提问于2021-03-17得票数 0
回答已采纳
4回答
同步两DateTimes
、、、
我希望将远程设备的时钟与另一个设备同步，而不连续请求远程设备的时间。
我想知道我的设备上的时间和远程设备的时间之间的区别，所以我可以将远程设备的时间戳添加到一个事件中。到目前为止，我的解决方案是:获取远程设备的时间，并通过比较来计算差异。我的</em
浏览 4提问于2018-02-01得票数 2
回答已采纳
我正在使用Flink，我正在使用Kafka连接器。我从flink收到的消息是一个逗号分隔的项目列表。"'a'，'b'，‘c’，1，0.1....‘12:01:00.000’“其中一个包含事件时间，我想将此事件时间用于每个分区的水印(在kafka源代码中)，然后使用此事件时间进行会话窗口。我的情况与往常有点不同，因为
浏览 69提问于2020-10-24得票数 1
回答已采纳
我在我的设计窗体上有一个文本框，它有多个双精度数据类型的数字。我有一个类，它有一个方法来计算两个连续数字之间的最小差值(正或负)。public decimal FindSmallestPriceChange()在我的表单上，有一个用于显示结果的标签和一个按钮事件，该事件调用上述方法来计算和显示文本框中连续数字之间<e
浏览 5提问于2019-11-12得票数 0
考虑以下检查点：2019-02-27 15:35:46,342 INFO org.apache.flink.runtime.state.DefaultOperatorStateBackendTask Threads] took 2 ms.
2019-02-27 15:35:46,346 INFO
浏览 3提问于2019-02-27得票数 2
回答已采纳
我有一个特定的任务，使用Apache Flink和一些额外的逻辑将两个数据流连接到一个聚合中。事件数据流( Data of events )开始根据某些
浏览 6提问于2020-07-06得票数 0
回答已采纳
在Apache中，setAutoWatermarkInterval(interval)向下游操作符生成水印，以便他们提前事件时间。如果水印在指定的时间间隔内没有更改(没有到达事件)，运行时将不会发出任何水印？我很好奇什么是最好的配置AutoWatermarkInterval (特别是对于高速率源而言)：这个值越小，处理时间和事件时间之间的延迟就越小，但是在发送水印时使用更多BW<e
浏览 5提问于2020-08-29得票数 2
回答已采纳
2回答
这是为了防止在元素超时之前处理重复项，之后我可以再次处理相同的元素。我 我已经编写了以下代码来测试计时器，但似乎计时器是在所有3个元素都通过第一个ProcessFunction之后触发的。在第一个ProcessFunction中，我按原样发送了前两个元素，但将第三个元素延迟了10秒。 在第二个ProcessFunction中，它根据是否为元素存储状态来过滤元素。我添加了一些日志记录，以便更好地了解执行时间。58,896] [Process -> Sink: Unnamed (1/12)] INFO Fli
浏览 17提问于2019-02-20得票数 1
回答已采纳
例如，假设预订了一个会议室，用于下午12-1点的会议。当天上午9点，一位用户取消了会议，腾出了会议室。有没有办法以编程方式运行一个脚本，如果在上午10点运行，它会指示房间在一小时前就可以使用了？
浏览 0提问于2019-12-10得票数 0
我对Apache Flink和它的API.I非常陌生。我想创建Java程序，它将与翻滚窗口进行基于事件时间的处理。我想计算给定窗口中元素的数量。然而，我不知道该怎么做。
浏览 24提问于2019-12-08得票数 0
1回答
我试图创建一个Access数据库中的计算字段，但我有问题，如何最好地做到这一点。该字段是“Duration”，它需要是两个“SecsLapsed”值之间的差值。这些值都被分配了一个“顺序”，它是数据/观测事件的顺序，即1、2、3、4等。顺序一将始终是Secslapsed =0(因为它是记录的开始)以下记录需要根据secslapsed值之间的差值计算持续<
浏览 21提问于2019-01-20得票数 0
我有以下代码... case MotionEvent.ACTION_DOWN: { } - - }
浏览 0提问于2011-08-16得票数 0
回答已采纳
我集成了两个工具Apache NiFi和Apache Flink。NiFi获取事件并将它们发送到Flink，之后Flink将这些事件经过一些处理返回给相同的NiFi。我在Flink中构建了Nifi的源代码和接收器。整个过程可以工作，但是接收器的性能非常差(大约每秒10个事件)。
如果我移除接收器(仅打印输出)，处理速度会快得多。可能我的问题<em
浏览 3提问于2018-07-24得票数 1
1回答
我有一份事件清单每个事件都有一个动作和应该激活此操作的时间。此列表已排序，但连续事件之间的时间间隔可能很大或很小。我认为应该有一个单独的with循环线程，但由于时间间隔可能很大，所以效率不高。其中一个改进可能是这样的：
2.1过程事件
2.2从列表中删除事件</e
浏览 2提问于2015-05-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
