Apache Flink：如何将模式从一个源应用到另一个数据流上？
我有一个事件数据流和另一个模式数据流。模式是由用户在运行时提供的，它们需要通过一个Kafka主题来提供。我需要使用flink-cep在事件流上应用每个模式。在我事先不知道模式的情况下，有没有办法从数据流中获取PatternStream？
共有1个答案
此时此刻是不可能的。FlinkCEP只能处理静态应用的一个模式。对此有一个JIRA罚单:https://issues.apache.org/JIRA/browse/flink-7129，但不能告诉该特性的ETA。
-
我有两个BigQuery数据集：和 这些数据集中的每一个都包含一个表，例如和 包含流数据，我想将数据从流式传输到。 我有类型的架构。如何将流行从一个表复制到另一个表并保留现有架构？ 到目前为止，我已经研究了BigQuery的insertAll方法，但是我有点不确定在哪个数据结构中获取行，以及在插入新表时如何指定TableSchema。 我希望能就如何做到这一点提供一些指导。谢谢
-
问题内容： 我有2个不同的表，但各列的命名略有不同。我想从一个表中获取信息，然后将其放入另一个表中。仅当表1中的“信息字段”不为null时，才需要将表1中的信息放入表2中。表2在创建任何东西时都有一个唯一的ID，因此插入的任何东西都需要获得下一个可用的ID号。 表格1 表2 问题答案： 这应该工作。您无需担心Table2中的identify字段。
-
没有开箱即用的解决方案可以将数据从一个Azure EventHub克隆到另一个EventHub。有什么可能的选择来实现这一点？
-
问题内容： 问：我怎样才能从读到的一切入的方式是不是一个手工制作的循环用我自己的字节的缓冲区？ 问题答案： 编写一个方法来执行此操作，然后从需要该功能的任何地方调用它。番石榴已经在中提供了代码。我敢肯定，几乎所有其他具有“通用” IO功能的库也都有它，但是Guava是我第一个“入门”库。它震撼了:)
-
问题内容： 我需要将表从一个数据库复制到另一个数据库。这将是一个cronjob。哪一种是最好的方法？PHP脚本或Shell脚本。PHP的问题是，两个数据库都有不同的用户名和密码，所以我不能这样做。 我应该只连接第一个DB以获得所有记录，然后使用WHILE循环将所有记录插入新数据库，还是有更好的方法？ 我更喜欢用shell脚本代替PHP脚本来执行此操作。 谢谢 问题答案： 我把它丢了。比任何基于PH
-
我目前正在尝试轻松地将消息从一个Kafka集群上的主题流式传输到另一个集群（远程）- 所以假设WordCount演示在另一台PC上的一个Kafka-Instance上，而不是我自己的PC上。我也有一个Kafka-Instance在我的本地机器上运行。 现在我想让WordCount演示在包含应该计算单词的句子的Topic（“远程”）上运行。 然而，计数应该写入我本地系统上的Topic而不是“远程”T