KnowForge/Apache Iceberg 1.4.0
Flink

Flink Actions

qianmoQqianmoQ· 更新于 2026-09-20· 阅读 2 分钟· 0 次阅读
登录后可跨设备保存划线和私人笔记登录

Flink Actions

Rewrite files action.

Iceberg provides API to rewrite small files into large files by submitting Flink batch jobs. The behavior of this Flink action is the same as Spark's rewriteDataFiles.

import org.apache.iceberg.flink.actions.Actions;

TableLoader tableLoader = TableLoader.fromHadoopTable("hdfs://nn:8020/warehouse/path");
Table table = tableLoader.loadTable();
RewriteDataFilesActionResult result = Actions.forTable(table)
        .rewriteDataFiles()
        .execute();

For more details of the rewrite files action, please refer to RewriteDataFilesAction

评论

登录后参与评论

正在加载评论…