我想在ApacheFlink中做流媒体工作，做Kafka->Flink->HIVE

Question

我想在Apache Flink中做流媒体工作来做Kafka-

这应该是流式处理。

Answer 1

为了帮助您开始使用表应用编程接口，您可以使用表应用编程接口的实时报告教程。它在Java，但是Scala应用编程接口没有太大不同。

这是一个使用SQL从Kafka读取数据并写入Hive的示例。要在Scala中执行同样的操作，可以使用tablenv包装SQL语句。executeSql（…） ，如中所示

tableEnv.executeSql("CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...)")

或

val tableResult1 = tEnv.executeSql("INSERT INTO ...")

如果需要执行多个插入，则需要使用语句集以稍微不同的方式执行。有关详细信息，请参阅下面链接到的文档。

请参见运行CREATE语句、运行INSERT语句、Apache KafkaSQL连接器和写入Hive。

如果你陷入困境，告诉我们你尝试了什么，以及它是如何失败的。