Flink ProcessFunction onTimer第一个事件LONG.MIN_VALUE
我有一个用例：stepA-
public long extractTimestamp(
MyEvent event, long previousElementTimestamp) {
return event.getTimeStamp();
}
public Watermark checkAndGetNextWatermark(
MyEvent event, long extractedTimestamp) {
return new Watermark(extractedTimestamp);
}
但是我还能做什么呢？谢谢
共有1个答案
Flink应用水印的方式是，水印遵循用于创建水印的证据的事件。因此，当前水印将很长。在处理第一个事件期间的MIN\u值，之后将推进水印。
从您分享的内容来看，不清楚为什么这对您的应用程序来说是个问题。
顺便说一下，您的水印生成器假设您的事件严格按时间戳排序。这是真的吗？
-
> 我的客户第一次加入我们的订阅计划时，我创建了一个事务（称为启动事务），并使用Stripe的API创建新的订阅，并在上述事务中存储订阅对象返回。 我还使用webook来捕捉Stripe的事件。我最大的目的是处理经常性付款（发送收费成功或失败的通知，以及客户互动的东西）。我捕捉事件invoice.payment_succeeded检测它是一个重新计费。我也创建了一个事务（调用RECURRENCE）
-
事件系统是一个框架非常重要的部分，用于响应用户的各种行为。 浏览器提供了3个层次的api，用于响应用户的各种行为。 1.最原始的是写在元素标签内。 2.再次是脚本内，以el.onXXX = function绑定的方式，统称为DOM0事件系统。 3.最后是多投事件系统，一个元素的同一类型事件可以绑定多个回调，统常称为DOM2事件系统。 由于浏览器大战，现存两套API。 IE与opera： 绑定事件：
-
我正在尝试在我的应用程序中实现一个抽屉布局。我遵循android开发者网站上的教程，一切顺利。我只有一个“小”问题：我用午餐打开应用程序，打开抽屉布局，然后点击列表视图中的一个元素，一切都很顺利，但当我尝试打开另一个抽屉并点击他的一个元素时，我注意到我第一次点击的元素仍然被点击，而我无法点击其他任何元素。我的代码是：public class Eventi extends Activity{priv
-
我正在尝试过滤所有临时事件 输入是一个文本文件，由输入函数解析为流，输入文件的内容包括：- 第一个值是Rack_id第二个是温度 我在input stream和WarnigsStream上都发布了print（），如下所示 现在，问题来了，Flink CEP的输出如下所示 正如我们所看到的，第一个复杂事件（机架id=1和温度=98.0））以相同的顺序打印，但在此之后，所有其他复杂事件都具有温度 提前
-
我的项目中有：https://www.primefaces.org/primereact/#/fullcalendar 我一天有2个事件，我通过以下代码找到了第一个事件： 我需要找到第二个或更多的事件。 UPD如何在第二天工作//div[@class='fc-entent-bone eton'][.//td[@data-date='2019-09-03']]//tbody/tr/td[计数（//t