Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(九))

电子书 Flink原理与实战(java版)专栏文章入口:电子书 Flink原理与实战(java版)- 目录结构


本章分为如下几篇:

Flink原理与实战(java版)#第11章Flink的应用(第一节Flink的CDC)

Flink原理与实战(java版)#第11章Flink的应用(第二节通过Flink CDC将MySQL的user表数据同步至Elasticsearch表(一))

Flink原理与实战(java版)#第11章Flink的应用(第二节通过Flink CDC将MySQL的user表数据同步至Elasticsearch表(二))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(一))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(二))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(三))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(四))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(五))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(六))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(七))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(八))

Flink原理与实战(java版)#第11章Flink的应用(第三节Table & SQL 连接器之Hive(九))

Flink原理与实战(java版)#第11章Flink的应用(整章)


文章目录

    • 11.4 本章小结

3.写入hive数据

Flink 支持批和流两种模式向 Hive 中写入数据。当作为批处理程序时,只有在作业完成时,Flink 写入到 Hive 表的数据才能被看到。批模式写入支持追加到现有的表或者覆盖现有的表。

1)Insert into 示例

示例代码如下。

# ------ INSERT INTO 将追加到表或者分区,保证数据的完整性 ------ 
Flink SQL> INSERT INTO mytable SELECT 'Tom', 25;
# ------ INSERT OVERWRITE 将覆盖表或者分区中所有已经存在的数据 ------ 
Flink SQ
© 版权声明

相关文章