DataSet を DataStream に変換したい Java を使用して Flink Table API を使用しています .... 以下は私のコードです:
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 に変換する方法を知りたいですか??
私が知りたいもう 1 つのことは、パターン マッチングのために、Flink CEP ライブラリが利用可能であることです。しかし、パターン マッチングに Flink テーブル API を使用することは可能ですか??