- 应用开发
- Table API & SQL
- SQL
- INSERT 语句
INSERT 语句
本文档是 Apache Flink 的旧版本。建议访问 最新的稳定版本。
INSERT 语句用来向表中添加行。
执行 INSERT 语句
可以使用 TableEnvironment
中的 sqlUpdate()
方法执行 INSERT 语句,也可以在 SQL CLI 中执行 INSERT 语句。sqlUpdate()
方法执行 INSERT 语句时时懒执行的,只有当TableEnvironment.execute(jobName)
被调用时才会被执行。
以下的例子展示了如何在 TableEnvironment
和 SQL CLI 中执行一个 INSERT 语句。
Back to top
将 SELECT 查询数据插入表中
通过 INSERT 语句,可以将查询的结果插入到表中,
语法
OVERWRITE
INSERT OVERWRITE
将会覆盖表中或分区中的任何已存在的数据。否则,新数据会追加到表中或分区中。
PARTITION
PARTITION
语句应该包含需要插入的静态分区列与值。
示例
将值插入表中
通过 INSERT 语句,也可以直接将值插入到表中,
语法
OVERWRITE
INSERT OVERWRITE
将会覆盖表中的任何已存在的数据。否则,新数据会追加到表中。
示例
Back to top