在Apache Flink中动态添加模式而不重新启动作业
我的用例是，我想对同一个数据流应用不同的CEP模式。CEP模式是动态的&我希望它们被添加到flink，而不必重新启动作业。虽然所有条件都可以通过实现IterativeCondition的自定义类来处理,但我的主要问题是时间条件只接受TimeWindow；无法处理。有什么方法可以根据输入元素来设置传递给.winn（）的值吗？
原因是我使用：PatternStream matchStream=cep.pattern（tmatchStream,pattern）将流应用到pattern；
但是流“tMatchStream”不会在Co-FlatMap中定义。我是不是漏了什么？？？如有任何帮助，将不胜感激。
共有1个答案
不幸的是，相关问题的答案仍然有效。Flink CEP目前不支持动态模式。但是已经有一张JIRA的票:FLINK-7129
该特性最早的合理目标版本是1.6.0
-
我有一个活动，我们称之为FirstActivity.java，它有一个带有通过片段实例化的导航抽屉的actionBar。在这个片段NavigationDrawerFragment.java中，为了实例化ActionBar，我将方法onCreateOptionsMenu（菜单菜单，MenuInflater inflater)、onOptionsItemSelected（MenuItem项）和onPr
-
我用Inno Setup做了一个安装程序，在一些文件运行后我需要重启电脑，所以我用了这篇文章中的解决方案。 inno安装示例“CodePrepareToInstall”。iss运行良好，所以我使用了代码进行测试安装，但计算机重新启动后安装程序无法启动。 两个安装程序（inno demo和我的测试）都在“HKLM\Software\Microsoft\Windows\CurrentVersion\R
-
问题内容： 我正在尝试为我的Java游戏添加重启/重播功能。当前在我的Game类（GUI和游戏被初始化的地方）中，我有： 游戏对象包含整个游戏窗口的GUI，并包含各种对象（例如实际游戏窗口，计分板，倒数计时器等）。 我想添加一个功能，如果他们单击GUI上的重新启动按钮或游戏结束后，游戏将重新启动（以及倒计时和计分）。我确实意识到最好重新实例化对象（计分，倒数），但是一旦实例化，它们便成为我的GUI
-
问题内容： 我正在尝试从骆驼路线中删除一些样板。 例如，让我们考虑两条路线，它们是相似的，并且它们的大部分内部物质都可以生成。我已经创建了一个组件“模板”，该模板创建了，并修改了XML配置以使用模板组件。 正在从中定义自定义方法（添加路线定义）。因此，在启动Camel上下文时，路由定义会出现在上下文中，但是框架不会为其创建路由服务，因此它们不会启动。 如何开始添加路线？ 可能我遇到了XY问题，您可
-
docker守护进程在我的计算机（Linux/Centos 7）上不再启动了，我强烈怀疑在这种情况下是一个设置为自动重启的容器造成的。如果我手动启动守护进程，我看到的最后一行是“装载容器：启动”，然后它只是挂起。 我想做的是在不启动任何容器的情况下启动守护进程。但我找不到任何选择。在docker中是否有任何选项可以启动守护进程而不将启动容器设置为自动重启？如果没有，是否有一种方法可以手动移除容器，
-
在我的情况下，有可能，例如，一个新的设备被启动，因此必须处理另一个流。但是如何动态添加这个新流呢？