InfoSphere/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

评论

登录后参与评论

正在加载评论…