前言 使用 flink 很长一段时间了，突然发现竟然没有计算过 pv uv，这可是 flink 常见的计算场景了，面试时也是常问题之一。故自己想了一个场景来计算一下。 基于 Flink 1.12 场景 外卖员听单的信息会…

是否有可能在flink流中知道本地窗口属于哪个子任务？我想在TriggerPolicy实现中使用getRuntimeContext().getIndexOfThisSubtask()方法. 最佳答案 目前无法获得运行Tr…

在我的应用程序中,我想丰富无限的事件流.流本身通过Id的散列来并行化.对于每个事件,可能会调用外部源(例如REST,DB).此呼叫本质上是阻止的.必须维护一个流分区中的事件顺序. 我的想法是创建一个RichMapFunc…

处理数据的模式是我有一个记录流,它们通过一些信息A得到丰富.记录按一些ID进行分片.此信息A取决于当前记录,先前计算的结果和大型查找表.查找表不会经常更改,更改也很小.我知道我可以使用mapWithState / fla…

我们有两种消息传到Flink >控制信息 – >仅滚动文件>数据信息 – >将使用sink存储在S3中 我们为这两个消息提供了单独的源流.我们已经为这两个流附加了相同的接收器.我们想要做的是广播控…