This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from eb460a524f Docs: Add HadoopTables lock configuration to Hadoop
configuration section (#15520)
add 22c788afb9 Flink: Allow arbitrary post-commit maintenance tasks via
IcebergSink Builder (#15566)
No new revisions were added by this update.
Summary of changes:
docs/docs/flink-maintenance.md | 126 ++++++++++--
.../org/apache/iceberg/flink/FlinkWriteConf.java | 18 ++
.../apache/iceberg/flink/FlinkWriteOptions.java | 16 +-
.../flink/maintenance/api/DeleteOrphanFiles.java | 26 ++-
.../maintenance/api/DeleteOrphanFilesConfig.java | 216 +++++++++++++++++++++
.../flink/maintenance/api/ExpireSnapshots.java | 14 ++
.../maintenance/api/ExpireSnapshotsConfig.java | 151 ++++++++++++++
.../maintenance/api/FlinkMaintenanceConfig.java | 8 +
.../flink/maintenance/api/TableMaintenance.java | 12 ++
.../iceberg/flink/sink/IcebergCommitter.java | 8 +-
.../org/apache/iceberg/flink/sink/IcebergSink.java | 147 +++++++++++---
.../api/TestDeleteOrphanFilesConfig.java | 91 +++++++++
.../maintenance/api/TestExpireSnapshotsConfig.java | 84 ++++++++
...t.java => TestIcebergSinkTableMaintenance.java} | 167 +++++++++++++++-
14 files changed, 1033 insertions(+), 51 deletions(-)
create mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/DeleteOrphanFilesConfig.java
create mode 100644
flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshotsConfig.java
create mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestDeleteOrphanFilesConfig.java
create mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestExpireSnapshotsConfig.java
rename
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/{TestIcebergSinkCompact.java
=> TestIcebergSinkTableMaintenance.java} (53%)
