Apache Flink度量来计算后期元素
我想测量有多少事件在允许的延迟内到达，按事件的特定特征分组。我们假设特定类型的事件有更多的延迟到达，并想验证这一点。
我想到的进行度量的地方是OneElement方法中的自定义触发器，因为这是我们知道事件是否延迟的地方。然而，在SlidingEventTimeWindow的情况下，这意味着如果单个元素延迟超过一张幻灯片，那么它可以被计算多次。
有什么建议吗？
共有1个答案
您可以在窗口中单独执行此操作。您可以将允许的延迟设置为零，并将所有延迟事件转移到侧输出。然后，您可以根据感兴趣的功能对延迟事件流进行键入，并使用RichFlatMapFunction或KeyedProcessFunction对事件进行计数，然后可以将其报告为自定义指标，或发送到接收器。
-
我的工作是做以下事情： 根据事件时间使用Kafka主题中的事件 计算7天的窗口大小，以1天的幻灯片显示 将结果放入Redis 我有几个问题： 如果它从最近的记录中消耗Kafka事件，在作业存活1天后，作业关闭窗口并计算7天窗口。问题是作业只有1天的数据，因此结果是错误的。 如果我尝试让它从7天前的时间戳中消耗Kafka事件，当作业开始时，它从第一天开始计算整个窗口，并且花费了很多时间。另外，我只想
-
问题内容： 我正在通过XML数据生成pdf文件。 我将段落元素的高度计算为： 但是这种方法不能正常工作。 你能给我个主意吗？ 问题答案： 您的问题很奇怪。根据您的问题的标题，您想知道字符串的高度，但是您的代码显示您要求的是字符串的宽度。 请看一下FoobarFilmFestival示例。 如果是实例，则可以使用： 当我们使用12号字体时，这将返回基线以上的高度和基线以下的高度。您可能知道，字体大小
-
所以这可能是一个愚蠢的问题，但我时不时地遇到这种语法错误，似乎无法吸取教训-因为我根本不明白为什么这不起作用。 由于某种原因，三元运算符不能处理增量或减量。 在控制台中，我发现了这些结果: 在搜索答案时，我发现另一个用户对意外行为有同样的体验。 经过更多的搜索，我发现前增量工作正常: 在试图确定预增量的工作原理时，遇到了这个答案。 这让我明白了为什么它能工作，而后增量不能。我想，如果三进制的操作顺
-
当我试图在Visual Studio 2013 for C#项目中运行代码度量（分析->计算解决方案的代码度量）时，我得到了以下错误： null
-
问题内容： 如何在Java中计算两个角度量度（以度为单位）的差，使结果在[0°，180°]范围内？ 例如： 问题答案： /* * Shortest distance (angular) between two angles. * It will be in range [0, 180]. / public static int distance(int alpha, int beta) { int
-
问题内容： 我目前正在编写一个单元测试，以查看给定方法的性能影响。从实践中我们观察到，当前在执行给定方法期间会发生大量的gc。我想知道是否有可能看到从Java运行方法期间发生了多少次gcs。 问题答案： 您可以使用GarbageCollectorMXBean来获取垃圾收集计数。 您可以执行以下操作：