2回答
我正在尝试计数流中的元素，同时使用窗口的结束时间来丰富结果。 事件是使用flink提供的kafka10消费者从Kafka接收的。使用EventTime。一个简单的KeyedStream.count( ... )工作正常。该流的长度为4分钟。通过使用3分钟的时间窗口，仅接收到一个输出。应该有两个。结果是使用BucketingSink编写的。._2;
浏览 28提问于2019-01-17得票数 0
回答已采纳
水印允许使用窗口在一段时间内考虑将延迟到达的数据包含在已经计算的结果中。它的前提是跟踪到一个时间点，在这个时间点之前，假设不会有更多的延迟事件到达，但如果它们到达了，它们仍然是discarded。有没有办法存储丢弃的数据，以便稍后用于对帐？例如，在我的结构化流媒体中，我将水印设置为1小时。我每10分钟做一次窗口操作，并在20分钟
浏览 28提问于2019-07-03得票数 0
回答已采纳
假设我有一个命名的窗口：这里的关键是FieldA。因此，例如，如果增量事件出现在基本事件之前，则窗口中的行的状态将仅与基本事件相似，因为增量将被丢弃。
我的问题是，有没有办法捕获增量事件，如果它不能进入窗口</e
浏览 0提问于2012-10-12得票数 1
当向一个主题发布大量事件时(其中重试和生存时间以分钟为单位)，许多事件无法被交付到订阅的函数。有没有人知道任何设置或方法，以确保缩放快速反应，而不是全部丢弃？我正在创建一个Azure函数应用程序，它本质上是以高速率将事件传递到事件网格主题，而订阅主题的其他函数将处理事件。这些事件应该是短暂的，并且不会持续超过指
浏览 0提问于2019-04-25得票数 0
我对NSApplication进行了子类化，并拦截了sendEvent:，以查看我的应用程序在第一次单击事件期间是否获得了事件，而且确实如此。此外，我丢弃了响应链，并看到我的视图确实在链中，但窗口不是关键，直到第二次点击。我还注意到，当我收到第一个单击事件时，应用程序甚至没有活动。这怎麽可能？当应用程序接收到鼠标事件时，它不是应该成为活动的吗？鸡/蛋..
浏览 0提问于2011-12-22得票数 2
1回答
我的画布上有多个类型的对象。我可以在特定对象上进行缩放、旋转等所有操作。
但是当我选择一个特定的对象时，我想改变它的stroke颜色。但问题是stroke颜色或任何其他有效的property不能直接反映，这意味着我必须取消选择当前选定的对象才能看到其属性的变化。所以我的问题是哪里出了问题？如果这是我们必须取消选择/单击所选对象的常见行为，那么如何使用代码取消选择所选对象，即只使用代码片段而不使用鼠标单击。
浏览 2提问于2013-12-03得票数 4
关于事件时间处理，Flink中的水印是什么？为什么需要它？为什么在所有使用事件时间的情况下都需要它。不管怎么说，我的意思是，如果我不做一个窗口开放，那么为什么我们仍然需要一个水渍。我来自火花背景。在星星之火中，我们只需要在传入事件上使用窗口时才需要水印。把你的回复贴出来，我再读一遍。下面是一个更具
浏览 0提问于2020-02-18得票数 2
，但在运行其他应用程序时，无法获得任何其他鼠标事件，如鼠标移动。如果owner_events为False，则所有生成的指针事件都会针对grab_window报告，并且只有在event_mask选择时才会报告。如果owner_events为True，并且如果生成的指针事件通常会报告给此客户端，则它将如常报告。否则，该事件将针对grab_window进行报告，并且只有在event_mask选择时才会报告。对于owner_events的任何
浏览 16提问于2015-08-20得票数 2
我目前正在使用Kafka流式DSL抑制功能的日期窗口。我们可能会遇到这样一种情况，一些事件可能会很晚才发生，超过了宽限期。Apache flink确实提供了对这种非常晚的事件的控制，并想知道这种功能是否在流中可用。2)考虑到数百万
浏览 2提问于2019-05-15得票数 0
2回答
通常是，NSWindow的可点击区域是通过内容视图像素的透明度来定义的。然而，一旦NSWindow的内容视图成为层支持，透明区域也将收到点击，不幸的是。在我的例子中，这是一个严重的问题，因为我只想接收半径内的点击。但是现在，在窗口的正下方，但在圆圈半径之外，点击一下就会激活窗口(从而激活整个应用程序)，这是不应该的。此外，该<e
浏览 4提问于2014-03-13得票数 5
回答已采纳
约会可以保存在OWA中，如下所示。但它不会在OWA约会中作为发送或保存按钮单击事件自动关闭。
浏览 8提问于2019-07-26得票数 1
1回答
我正在尝试捕获拖拽和丢弃事件。现在，我正在捕获这些事件，将dom处理程序添加到我的RootLayoutPanel中：Event.ad
浏览 2提问于2012-10-16得票数 2
回答已采纳
在Flink中，有两件事提供了类似的行为。这两者之间有什么区别。
MaxOutOfOrderness：与BoundedOutOfOrdernessTimestampExtractor连用。通过将事件时间后面的水印延迟到maxOutOfOrdeness值，允许流的元素按MaxOutOfOrderness值的大小排序。AllowedLateness：在此参数定义的更长时间内保持窗口状态。既然您已经可以通过AllowedLateness实现相同的行为，那么为
浏览 5提问于2019-11-06得票数 4
回答已采纳
我试图用默认触发器实现默认窗口，以评估行为，但它不会产生任何结果。据阿帕奇·梁说：
-- PCollection的默认触发器是基于事件时间的，当波束的水印通过窗口的末端时，会发出窗口的结果，然后每次延迟数据到达时都会触发。--如果您同时使用默认窗口配置和默认触发器，则默认触发器只发出一次，而延迟数据将被丢弃。这是因为默认的窗口
浏览 1提问于2019-10-09得票数 1
回答已采纳
但是，当使用以下路径将数据存储到blobstorage中时：我似乎还能吃得下。在我的例子中，摄取的时间没有任何意义，我需要使用EventDate作为路径。这个是可能的吗？在Visual Studio中检查数据时，test和EventDate应该相等，但是结果如下所示：
EventDate
浏览 0提问于2020-04-03得票数 4
我有一个流管道，它使用带有时间戳的事件。我所要做的就是将它们批次到FixedWindows中，每次1分钟，然后将窗口中的所有事件写入一个GCS文件中。我可以使用FixedWindows，但从文档中可以看出，我需要一个GroupBy或Combine操作来应用窗口，但是对于我的用例，窗口已经完成了我所需要的所有分组。我认为有两种可能
浏览 1提问于2017-01-10得票数 1
我不知道该怎么问这个问题，所以这里有一个想法的图片。因此，例如，当您运行我的“自定义启动程序”时，它会显示一个窗口，旁边有几个按钮，您可以将值赋值给它。单击按钮时，适当的程序将在右侧的大面板中运行(在窗口模式下)。
当然，这都是从用户的角度来看的。他们只会看到他们想要运行的程序出现在面板中。实际的实现可能与“一个程序在另一个程序中运行
浏览 3提问于2013-12-09得票数 4
回答已采纳
根据，调用XSync(dpy, 1)会丢弃队列中的事件，但这到底意味着什么呢？如果它们没有被丢弃，它们是否被发送了两次(一次是通过XSync()调用，另一次是在队列正常清空时)？还是类似于垃圾收集器(这些事件在稍后才会被丢弃)？
浏览 3提问于2013-01-25得票数 5
1回答
我一直在阅读Dataflow SDK文档，试图找出当数据在流作业中超过水印时会发生什么。本页：
PCollection的默认触发器是基于事件时间的，并且在系统的水印(Dataflow关于何时“应该
浏览 3提问于2016-05-16得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
