Flink Tabellen-API DataSet Datastream zu konvertieren

Question

Ich verwende Flink Tabellen-API unter Verwendung von Java nicht in der Lage, wo ich DataSet Datastream konvertieren möchten .... Im Anschluss ist mein Code:

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

Aber wenn ich versuche, ausführen dieses Programm, wirft es Ausnahme folgende:

org.apache.flink.api.table.ExpressionException: Ungültige Root für JavaStreamingTranslator: Root (ArraySeq ((related_value, Doppel), (REF_ID, String))). Haben Sie versucht, eine Tabelle basierend auf einem DataSet in einen DataStream umzuwandeln oder umgekehrt? Ich möchte wissen, wie wir DataSet mit Flink Table API in DataStream konvertieren können ??

Eine andere Sache möchte ich wissen, dass für die Mustererkennung, gibt es Flink CEP-Bibliothek zur Verfügung.Aber ist es möglich, Flink Table API für Pattern-Matching zu verwenden?

Answer 1

Die API von Flink's Table wurde nicht entwickelt, um eine DataSet in eine DataStream umzuwandeln und umgekehrt. Dies ist mit der Tabellen-API nicht möglich und es gibt auch keine andere Möglichkeit, dies momentan mit Flink zu tun.

Verbindende das DataStreamDataSet und APIs (Batch-Verarbeitung als ein Spezialfall des Streamings der Handhabung, das heißt, als begrenzt Ströme) an dem langfristigen Fahrplan von Flink.