各位好:
请教一下,用FlinkKafkaConsumer API的话,如何支持SQL的方式,和维表关联。(之前用Kafka
API&StreamTableDescriptor API是可以的)
"select a.id,b.name from kafka_table a "
+ "join dim_table FOR SYSTEM_TIME AS OF a.proctime as b on a.id =
b.user_id";thanks & Regards
各位好:
请教一下,用FlinkKafkaConsumer API的话,如何支持SQL的方式,和维表关联。(之前用Kafka
API&StreamTableDescriptor API是可以的)
"select a.id,b.name from kafka_table a "
+ "join dim_table FOR SYSTEM_TIME AS OF a.proctime as b on a.id =
b.user_id";thanks & Regards