java - Flink Table API 无法将 DataSet 转换为 DataStream

Question

我正在使用使用 Java 的 Flink Table API，我想将 DataSet 转换为 DataStream ....以下是我的代码:

TableEnvironment tableEnvironment=new TableEnvironment();
Table tab1=table.where("related_value < 2014").select("related_value,ref_id");
DataSet<MyClass>ds2=tableEnvironment.toDataSet(tab1, MyClass.class);
DataStream<MyClass> d=tableEnvironment.toDataStream(tab1, MyClass.class);

但是当我尝试执行这个程序时，它抛出以下异常:

org.apache.flink.api.table.ExpressionException:JavaStreamingTranslator 的根无效:Root(ArraySeq((related_value,Double), (ref_id,String)))。您是否尝试过将基于 DataSet 的表转换为 DataStream，反之亦然？ 我想知道我们如何使用 Flink Table API 将 DataSet 转换为 DataStream ??

我想知道的另一件事是，对于模式匹配，有可用的 Flink CEP 库。但是使用 Flink Table API 进行模式匹配是否可行？

Answer 1

Flink 的 Table API 并非旨在将 DataSet 转换为 DataStream，反之亦然。使用 Table API 无法做到这一点，目前 Flink 也没有其他方法可以做到这一点。

统一 DataStream 和 DataSet API(处理批处理作为流的特殊情况，即，作为有界流)是 Flink 的长期路线图。