基于优先级或循环方式从两个flink dataStream中使用
我有两个flinkDatastream。例如:datastream1和datastream2。我想将这两个流合并成1个流，这样我就可以使用与DataStream的dag相同的处理函数来处理它们。
共有1个答案
这个问题最简单的解决方案可能是连接两个流，但不完全是最有效的，这取决于数据源的确切规范。在这个解决方案中，您可以使用coprocessfunction，它将为每个连接的流调用单独的方法。
在这个解决方案中，您可以简单地缓冲一个流的元素，直到它们可以生成（例如，以循环方式）。但是请记住，如果源产生事件的频率之间有很大的差异，这可能是非常低效的。
-
非常感谢您抽出时间！
-
问题内容： 我有这个表达： 这些元素的（，，）有优先权？ 您能用方括号显示操作顺序吗？ 问题答案： 首先，然后，然后。 您的表情将被评估为。 https://docs.oracle.com/javase/tutorial/java/nutsandbolts/operators.html
-
我有一个这样的df： 对于每个ID，我有5列A1到A5（实际上我有更多），并且这些值是特定ID的最高优先级。 例如：ID 1将A1、A3和A5作为优先级，ID 3只有2个A2和A1，ID 5没有优先级 合成DF 我尝试使用和使用这个和这个以及更多的方法来实现相同的功能，但无法获得相同的结果df。 这方面的任何帮助或我这边的清晰度！！
-
问题内容： 我想知道如何或/和如何工作？ 例如，如果我想获取display = 1的所有行 我可以做 如果我想要显示= 1或2的所有行 我可以做 但是，如果我想获取display = 1或2的所有行，并且其中 任何 内容，标签或标题包含 逻辑将如何发挥作用？ 是我的猜测。但是我可以通过几种方式阅读。 它的读数是否为： 或作为 等等 问题答案： MySQL文档有一个很好的页面，其中包含有关哪些运算符
-
在抢占式优先级调度中，在进程到达就绪队列时，其优先级与就绪队列中存在的其他进程的优先级以及CPU在该点执行的优先级进行比较。 在所有可用的进程中具有最高优先级的那个将被赋予CPU。 抢先优先级调度和非抢占优先级调度之间的区别在于，在抢先优先级调度中，正在执行的作业可以在更高优先级作业到达时停止。 一旦所有作业在就绪队列中可用，算法将表现为非抢占式优先级调度，这意味着计划的作业将运行直至完成并且不会
-
我正在研究一种算法，在该算法中，我希望在从该优先级队列中删除元素时，保持优先级队列中具有相同优先级的元素的FIFO顺序。 虽然，我已经看到了将自动递增的序列号作为辅助键的解决方案，并使用它来打破联系，但我需要类似的链接，但我面临的问题是，我想要比较的元素-TestItemChange（下面示例中的类）没有实现Compariable，我无法（也不想）修改它以使其实现。所以现在，在优先级队列中没有FI