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'srewriteDataFiles.
importorg.apache.iceberg.flink.actions.Actions;TableLoadertableLoader=TableLoader.fromHadoopTable("hdfs://nn:8020/warehouse/path");Tabletable=tableLoader.loadTable();RewriteDataFilesActionResultresult=Actions.forTable(table).rewriteDataFiles().execute();For more details of the rewrite files action, please refer toRewriteDataFilesAction