Flink表API无法将数据集转换为数据流

Question

我正在使用Flink表API，使用Java将数据集转换为数据流....以下是我的代码：

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);

ExpressionException：JavaStreamingTranslator的根无效：Root(ArraySeq((related_value,Double）,(ref_id,String)))。您尝试将基于数据集的表转换为数据流吗？我想知道我们如何使用Flink表API将DataSet转换为DataStream？？

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

Answer 1

Flink的表API不是为了将数据集转换为数据流而设计的，反之亦然。使用Table API是不可能做到这一点的，而且目前也没有其他方法使用Flink来做到这一点。

统一Datastream和DataSetAPI（将批处理作为流的一种特殊情况处理，即作为有界流处理）是Flink的长期发展方向。