如何连接一个流和两个静态配置单元表

Question

我是 Flink 新手，我正在使用 Flink 1.3（旧版本，但我公司已经使用此版本...）编写流应用程序。该应用程序涉及与一个流（来自kafka）和两个静态Hive表（每天更改一次，两个表大约1亿行）的连接，

我会问最好的方法是加入、Stream API 还是 SQL API？在我看来，Stream API 不支持从 Hive 读取。

此时，我想知道应该使用哪个API（数据流api或流sql api）。

谢谢！

Answer 1

我认为最适合您的情况是转换 stream to table

然后将这些数据与配置单元表数据连接起来。

// get StreamTableEnvironment 
 // registration of a DataSet in a BatchTableEnvironment is equivalent 
StreamTableEnvironment tableEnv = ...; // see "Create a TableEnvironment" section

DataStream<Tuple2<Long, String>> stream = ...

// Convert the DataStream into a Table with default fields "f0", "f1" 
Table table1 = tableEnv.fromDataStream(stream);

// Convert the DataStream into a Table with fields "myLong", "myString" 
Table table2 = tableEnv.fromDataStream(stream, "myLong, myString");