我正在使用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进行模式匹配?