This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch 
dependabot/gradle/io.netty-netty-buffer-4.1.101.Final
in repository https://gitbox.apache.org/repos/asf/iceberg.git


 discard ba6a34b474 Build: Bump io.netty:netty-buffer from 4.1.68.Final to 
4.1.101.Final
     add fd4231f5e2 API: Optimize equals in CharSequenceWrapper (#9035)
     add 930750d3e2 Build: Bump software.amazon.awssdk:bom from 2.21.15 to 
2.21.21 (#9044)
     add 7ece5faaf8 Build: Bump orc from 1.9.1 to 1.9.2 (#9045)
     add 28a9565254 Build: Bump arrow from 14.0.0 to 14.0.1 (#9043)
     add 7f21b538f3 Build: Bump net.snowflake:snowflake-jdbc from 3.14.2 to 
3.14.3 (#9039)
     add 9476f62ff2 Build: Bump junit from 5.10.0 to 5.10.1 (#9037)
     add 7ff8f26458 Build: Bump com.google.cloud:libraries-bom from 26.26.0 to 
26.27.0 (#9036)
     add fd00207cdd Build: Bump org.xerial:sqlite-jdbc from 3.43.2.1 to 
3.44.0.0 (#9051)
     add efa5945f12 Add dependabot to automatically update the site (#9004)
     add 9cfbbdc9ef Build: Bump mkdocs-macros-plugin from 1.0.4 to 1.0.5 (#9058)
     add 9c51427f18 Build: Bump datamodel-code-generator from 0.22.0 to 0.23.0 
(#9054)
     add 75ff4a99a9 Build: Bump mkdocs-material-extensions from 1.1.1 to 1.3 
(#9052)
     add 69025712b4 Build: Bump mkdocs-material from 9.1.21 to 9.4.8 (#9055)
     add 1888474283 Build: Bump software.amazon.awssdk:bom from 2.21.21 to 
2.21.22 (#9053)
     add fba7d61253 GCP: Use correct Guava imports (#9067)
     add 6ec3de390d Core: Enable column statistics filtering after planning 
(#8803)
     add bfe1d03c75 Spark 3.5: Support metadata columns in staged scan (#8872)
     add 72da856b3c Docs: Fix parquet default compression codec (#9096)
     add 798f1c8abe Azure: Allow shared-key auth for testing purposes (#9068)
     add ccaeb2f4d5 Core: Disallow setting equality field IDs for data (#8970)
     add 2e2ac8dfd2 Core: Fix split size calculations in file rewriters (#9069)
     add 3d6072ad4d API: Add CharSequenceMap (#9047)
     add 1e2a71398f Parquet: Add log entry when Bloom filters are used (#9010)
     add 17c7815d43 GCS: Allow no-auth for testing purposes (#9061)
     add abbfdae108 Spark 3.4, 3.3: Support metadata columns in staged scans 
(#9098)
     add e69418ae8d Spark 3.5: Extend action for rewriting manifests to support 
deletes (#9020)
     add b6b5d4473f Build: Bump datamodel-code-generator from 0.23.0 to 0.24.2 
(#9109)
     add 8c7ebeee82 Build: Bump openapi-spec-validator from 0.5.2 to 0.7.1 
(#9057)
     add 9e94dc8576 Open-API: Remove pydantic pin (#9110)
     add 573f3f30da Build: Bump com.fasterxml.jackson.core:jackson-annotations 
(#9106)
     add a3bf0c7e32 Build: Bump org.testcontainers:testcontainers from 1.19.1 
to 1.19.2 (#9103)
     add 04d1a9d85e Build: Bump 
com.fasterxml.jackson.dataformat:jackson-dataformat-xml (#9107)
     add c193de9e8f Spark: Fix metadata delete check with branches (#9102)
     add f8d21116b1 Build: Bump software.amazon.awssdk:bom from 2.21.22 to 
2.21.26 (#9105)
     add 3f90a23c1a Build: Bump mkdocs-material from 9.4.8 to 9.4.10 (#9114)
     add 7320899dea Spark 3.3, 3.4: Backport fix for metadata delete condition 
check for branches (#9115)
     add 506cdbfd53 Spark: Add SQL config to control locality (#9101)
     add 42614cc8d6 Core: Remove synchronization from BitmapPositionDeleteIndex 
(#9119)
     add c61c3ca017 Data: Always use delete index for position deletes (#9117)
     add 229a243dda Core: Lazily create LocationProvider in SerializableTable 
(#9029)
     add 0831eb03b0 Flink: Emit watermarks from the IcebergSource (#8553)
     add c119099076 Docs: Remove UNIQUE keyword as it is not supported in Flink 
(#9046)
     add 13fcf62b87 Spark: Fix Fast forward before/after snapshot output for 
non-main branches (#8854)
     add c817c8503d Hive: Refactor HiveTableOperations with common code for 
View. (#9011)
     add c427a5628b Flink: Create JUnit5 version of FlinkTestBase (#9120)
     add b20d30ca04 Spark: Create base classes for migration to JUnit5 (#9129)
     add 10a856e0f4 Flink: Proper backport for #8852 (#9146)
     add 1a073ddc47 Flink: Backport #8803 to v1.16 and v1.15 (#9144)
     add f246614ed9 Flink: Backport #9078 to v1.16 and v1.15 (#9151)
     add 6fc5be738d API, Core: Fix naming in fastForwardBranch/replaceBranch 
APIs (#9134)
     add 4e62b58f04 AWS, Core, Dell, Spark: Use Strings to verify null and 
empty string (#9090)
     add b21a8ce249 API: add StructTransform base class for PartitionKey and 
SortKey. add SortOrderComparators (#7798)
     add 5fb26f8394 Build: Bump org.testcontainers:testcontainers from 1.19.2 
to 1.19.3 (#9155)
     add 5e059c1bfb Flink: Backport #8553 to v1.15, v1.16 (#9145)
     add d2ab70927c Build: Bump nessie from 0.73.0 to 0.74.0 (#9153)
     add aead1e46da Build: Bump io.netty:netty-buffer from 4.1.68.Final to 
4.1.101.Final

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (ba6a34b474)
            \
             N -- N -- N   
refs/heads/dependabot/gradle/io.netty-netty-buffer-4.1.101.Final (aead1e46da)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

No new revisions were added by this update.

Summary of changes:
 .github/dependabot.yml                             |   6 +
 .palantir/revapi.yml                               |   5 +
 .../java/org/apache/iceberg/BatchScanAdapter.java  |   5 +
 .../main/java/org/apache/iceberg/ContentFile.java  |  15 +
 .../java/org/apache/iceberg/ManageSnapshots.java   |  22 +-
 .../main/java/org/apache/iceberg/PartitionKey.java |  97 +---
 api/src/main/java/org/apache/iceberg/Scan.java     |  14 +
 api/src/main/java/org/apache/iceberg/SortKey.java  |  56 +++
 .../org/apache/iceberg/SortOrderComparators.java   | 105 +++++
 .../java/org/apache/iceberg/StructTransform.java   | 149 +++++++
 .../org/apache/iceberg/util/CharSequenceMap.java   | 220 +++++++++
 .../apache/iceberg/util/CharSequenceWrapper.java   |   9 +
 .../test/java/org/apache/iceberg/TestHelpers.java  |   6 +
 .../apache/iceberg/TestSortOrderComparators.java   | 489 +++++++++++++++++++++
 .../apache/iceberg/util/TestCharSequenceMap.java   | 202 +++++++++
 .../iceberg/aws/dynamodb/DynamoDbCatalog.java      |   3 +-
 .../org/apache/iceberg/aws/glue/GlueCatalog.java   |   6 +-
 .../org/apache/iceberg/azure/AzureProperties.java  |  19 +
 .../apache/iceberg/azure/AzurePropertiesTest.java  |  41 ++
 .../apache/iceberg/BaseDistributedDataScan.java    |   7 +-
 .../src/main/java/org/apache/iceberg/BaseFile.java |  30 +-
 .../apache/iceberg/BaseIncrementalAppendScan.java  |   3 +-
 .../iceberg/BaseIncrementalChangelogScan.java      |   3 +-
 .../src/main/java/org/apache/iceberg/BaseScan.java |  18 +
 .../java/org/apache/iceberg/ContentFileParser.java |   1 -
 .../main/java/org/apache/iceberg/DataFiles.java    |  11 +-
 .../src/main/java/org/apache/iceberg/DataScan.java |   3 +-
 .../java/org/apache/iceberg/DataTableScan.java     |   3 +-
 .../java/org/apache/iceberg/GenericDataFile.java   |  22 +-
 .../java/org/apache/iceberg/GenericDeleteFile.java |  19 +-
 .../apache/iceberg/IncrementalDataTableScan.java   |   3 +-
 .../java/org/apache/iceberg/ManifestGroup.java     |  21 +-
 .../java/org/apache/iceberg/SerializableTable.java |  22 +-
 .../java/org/apache/iceberg/SnapshotManager.java   |   8 +-
 .../java/org/apache/iceberg/TableScanContext.java  |  14 +
 .../iceberg/UpdateSnapshotReferencesOperation.java |  35 +-
 .../main/java/org/apache/iceberg/V1Metadata.java   |   6 +
 .../main/java/org/apache/iceberg/V2Metadata.java   |   6 +
 .../iceberg/actions/SizeBasedFileRewriter.java     |  16 +-
 .../iceberg/deletes/BitmapPositionDeleteIndex.java |   2 +-
 .../org/apache/iceberg/hadoop/HadoopCatalog.java   |   3 +-
 .../java/org/apache/iceberg/jdbc/JdbcCatalog.java  |   3 +-
 .../{LocationUtil.java => ContentFileUtil.java}    |  30 +-
 .../java/org/apache/iceberg/util/LocationUtil.java |   4 +-
 .../org/apache/iceberg/util/SerializableMap.java   |  17 +
 .../org/apache/iceberg/TestContentFileParser.java  |   6 +-
 .../apache/iceberg/TestManifestWriterVersions.java |   2 +-
 .../apache/iceberg/TestScanDataFileColumns.java    |  56 ++-
 .../org/apache/iceberg/TestSnapshotManager.java    |  28 +-
 .../iceberg/actions/TestSizeBasedRewriter.java     | 100 +++++
 .../java/org/apache/iceberg/data/DeleteFilter.java |  18 +-
 .../apache/iceberg/data/GenericAppenderHelper.java |   5 +
 .../org/apache/iceberg/dell/ecs/EcsCatalog.java    |   3 +-
 docs/configuration.md                              |   2 +-
 docs/flink-writes.md                               |   2 +-
 .../iceberg/flink/source/FlinkSplitPlanner.java    |   4 +
 .../apache/iceberg/flink/source/IcebergSource.java |  68 ++-
 .../apache/iceberg/flink/source/ScanContext.java   |  17 +
 .../reader/ColumnStatsWatermarkExtractor.java      |  98 +++++
 .../flink/source/reader/IcebergSourceReader.java   |   3 +-
 .../source/reader/SerializableRecordEmitter.java}  |  24 +-
 ...rdEmitter.java => SplitWatermarkExtractor.java} |  18 +-
 .../reader/WatermarkExtractorRecordEmitter.java    |  67 +++
 .../flink/source/split/SplitComparators.java       |  19 +-
 .../iceberg/flink/MiniFlinkClusterExtension.java   |  53 +++
 .../java/org/apache/iceberg/flink/TestBase.java    | 130 ++++++
 .../iceberg/flink/TestCatalogTableLoader.java      |  21 +-
 .../flink/source/TestIcebergSourceFailover.java    |  13 +-
 ...cebergSourceFailoverWithWatermarkExtractor.java | 112 +++++
 .../TestIcebergSourceWithWatermarkExtractor.java   | 481 ++++++++++++++++++++
 .../flink/source/TestStreamingMonitorFunction.java |  16 +-
 .../source/assigner/SplitAssignerTestBase.java     |  21 +-
 .../TestFileSequenceNumberBasedSplitAssigner.java  |  10 +-
 .../assigner/TestWatermarkBasedSplitAssigner.java  | 146 ++++++
 .../enumerator/TestContinuousSplitPlannerImpl.java | 143 +++++-
 .../iceberg/flink/source/reader/ReaderUtil.java    |   8 +-
 .../reader/TestColumnStatsWatermarkExtractor.java  | 178 ++++++++
 .../source/reader/TestIcebergSourceReader.java     |   7 +-
 .../iceberg/flink/source/FlinkSplitPlanner.java    |   4 +
 .../apache/iceberg/flink/source/IcebergSource.java |  68 ++-
 .../apache/iceberg/flink/source/ScanContext.java   |  17 +
 .../reader/ColumnStatsWatermarkExtractor.java      |  98 +++++
 .../flink/source/reader/IcebergSourceReader.java   |   3 +-
 .../source/reader/SerializableRecordEmitter.java}  |  24 +-
 ...rdEmitter.java => SplitWatermarkExtractor.java} |  18 +-
 .../reader/WatermarkExtractorRecordEmitter.java    |  67 +++
 .../flink/source/split/SplitComparators.java       |  19 +-
 .../iceberg/flink/MiniFlinkClusterExtension.java   |  53 +++
 .../java/org/apache/iceberg/flink/TestBase.java    | 130 ++++++
 .../iceberg/flink/TestCatalogTableLoader.java      |  21 +-
 .../flink/source/TestIcebergSourceFailover.java    |  13 +-
 ...cebergSourceFailoverWithWatermarkExtractor.java | 112 +++++
 .../TestIcebergSourceWithWatermarkExtractor.java   | 451 +++++++++++++++++++
 .../flink/source/TestStreamingMonitorFunction.java |  15 +-
 .../source/assigner/SplitAssignerTestBase.java     |  21 +-
 .../TestFileSequenceNumberBasedSplitAssigner.java  |  10 +-
 .../assigner/TestWatermarkBasedSplitAssigner.java  | 146 ++++++
 .../enumerator/TestContinuousSplitPlannerImpl.java | 143 +++++-
 .../iceberg/flink/source/reader/ReaderUtil.java    |   8 +-
 .../reader/TestColumnStatsWatermarkExtractor.java  | 178 ++++++++
 .../source/reader/TestIcebergSourceReader.java     |   7 +-
 .../iceberg/flink/source/FlinkSplitPlanner.java    |   4 +
 .../apache/iceberg/flink/source/IcebergSource.java |  68 ++-
 .../apache/iceberg/flink/source/ScanContext.java   |  17 +
 .../reader/ColumnStatsWatermarkExtractor.java      |  98 +++++
 .../flink/source/reader/IcebergSourceReader.java   |   3 +-
 ...Emitter.java => SerializableRecordEmitter.java} |  24 +-
 ...rdEmitter.java => SplitWatermarkExtractor.java} |  18 +-
 .../reader/WatermarkExtractorRecordEmitter.java    |  67 +++
 .../flink/source/split/SplitComparators.java       |  19 +-
 .../iceberg/flink/MiniFlinkClusterExtension.java   |  53 +++
 .../java/org/apache/iceberg/flink/TestBase.java    | 130 ++++++
 .../iceberg/flink/TestCatalogTableLoader.java      |  21 +-
 .../flink/source/TestIcebergSourceFailover.java    |  12 +-
 ...cebergSourceFailoverWithWatermarkExtractor.java | 112 +++++
 .../TestIcebergSourceWithWatermarkExtractor.java   | 451 +++++++++++++++++++
 .../source/assigner/SplitAssignerTestBase.java     |  21 +-
 .../TestFileSequenceNumberBasedSplitAssigner.java  |  10 +-
 .../assigner/TestWatermarkBasedSplitAssigner.java  | 146 ++++++
 .../enumerator/TestContinuousSplitPlannerImpl.java | 143 +++++-
 .../iceberg/flink/source/reader/ReaderUtil.java    |   8 +-
 .../reader/TestColumnStatsWatermarkExtractor.java  | 178 ++++++++
 .../source/reader/TestIcebergSourceReader.java     |   7 +-
 .../java/org/apache/iceberg/gcp/GCPProperties.java |  14 +
 .../java/org/apache/iceberg/gcp/gcs/GCSFileIO.java |   9 +
 .../org/apache/iceberg/gcp/gcs/GCSInputStream.java |   2 +-
 .../apache/iceberg/gcp/gcs/GCSOutputStream.java    |   2 +-
 .../org/apache/iceberg/gcp/GCPPropertiesTest.java  |  50 +++
 gradle/libs.versions.toml                          |  22 +-
 .../java/org/apache/iceberg/hive/HiveCatalog.java  |   2 +-
 .../apache/iceberg/hive/HiveOperationsBase.java    | 184 ++++++++
 .../apache/iceberg/hive/HiveTableOperations.java   | 149 ++-----
 open-api/requirements.txt                          |   6 +-
 .../parquet/ParquetBloomRowGroupFilter.java        |  16 +-
 site/requirements.txt                              |   6 +-
 .../SparkRowLevelOperationsTestBase.java           |   2 +-
 .../SparkRowLevelOperationsTestBase.java           |   4 +-
 .../iceberg/spark/extensions/TestDelete.java       |   3 +-
 .../TestMetaColumnProjectionWithStageScan.java     | 127 ++++++
 .../org/apache/iceberg/spark/SparkReadConf.java    |   7 +-
 .../apache/iceberg/spark/SparkSQLProperties.java   |   3 +
 .../iceberg/spark/source/SparkStagedScan.java      |  10 +-
 .../spark/source/SparkStagedScanBuilder.java       |  52 ++-
 .../apache/iceberg/spark/source/SparkTable.java    |   2 +-
 .../org/apache/iceberg/spark/data/TestHelpers.java |   2 +-
 .../SparkRowLevelOperationsTestBase.java           |   2 +-
 .../iceberg/spark/extensions/TestDelete.java       |   3 +-
 .../TestMetaColumnProjectionWithStageScan.java     | 127 ++++++
 .../org/apache/iceberg/spark/SparkReadConf.java    |   7 +-
 .../apache/iceberg/spark/SparkSQLProperties.java   |   3 +
 .../iceberg/spark/source/SparkStagedScan.java      |  10 +-
 .../spark/source/SparkStagedScanBuilder.java       |  52 ++-
 .../apache/iceberg/spark/source/SparkTable.java    |   2 +-
 .../org/apache/iceberg/spark/data/TestHelpers.java |   2 +-
 .../SparkRowLevelOperationsTestBase.java           |   2 +-
 .../iceberg/spark/extensions/TestDelete.java       |   3 +-
 .../extensions/TestFastForwardBranchProcedure.java |  59 +++
 .../TestMetaColumnProjectionWithStageScan.java     | 127 ++++++
 .../{SparkDataFile.java => SparkContentFile.java}  |  75 ++--
 .../org/apache/iceberg/spark/SparkDataFile.java    | 192 +-------
 .../org/apache/iceberg/spark/SparkDeleteFile.java  |  28 +-
 .../org/apache/iceberg/spark/SparkReadConf.java    |   7 +-
 .../apache/iceberg/spark/SparkSQLProperties.java   |   3 +
 .../spark/actions/RewriteManifestsSparkAction.java | 237 +++++++---
 .../procedures/FastForwardBranchProcedure.java     |  11 +-
 .../iceberg/spark/source/SparkStagedScan.java      |  10 +-
 .../spark/source/SparkStagedScanBuilder.java       |  52 ++-
 .../apache/iceberg/spark/source/SparkTable.java    |   2 +-
 .../org/apache/iceberg/spark/CatalogTestBase.java  |  51 +++
 .../apache/iceberg/spark/SparkTestHelperBase.java  |  19 +-
 .../java/org/apache/iceberg/spark/TestBase.java    | 287 ++++++++++++
 .../apache/iceberg/spark/TestBaseWithCatalog.java  | 131 ++++++
 .../spark/actions/TestRewriteManifestsAction.java  | 318 ++++++++++++++
 .../spark/actions/TestSparkFileRewriter.java       | 109 +++--
 .../org/apache/iceberg/spark/data/TestHelpers.java |   2 +-
 .../iceberg/spark/source/TestSparkDataFile.java    | 194 ++++++--
 176 files changed, 8650 insertions(+), 1045 deletions(-)
 create mode 100644 api/src/main/java/org/apache/iceberg/SortKey.java
 create mode 100644 
api/src/main/java/org/apache/iceberg/SortOrderComparators.java
 create mode 100644 api/src/main/java/org/apache/iceberg/StructTransform.java
 create mode 100644 
api/src/main/java/org/apache/iceberg/util/CharSequenceMap.java
 create mode 100644 
api/src/test/java/org/apache/iceberg/TestSortOrderComparators.java
 create mode 100644 
api/src/test/java/org/apache/iceberg/util/TestCharSequenceMap.java
 copy core/src/main/java/org/apache/iceberg/util/{LocationUtil.java => 
ContentFileUtil.java} (53%)
 create mode 100644 
core/src/test/java/org/apache/iceberg/actions/TestSizeBasedRewriter.java
 create mode 100644 
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
 copy 
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceRecordEmitter.java
 => 
v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java}
 (61%)
 rename 
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/{IcebergSourceRecordEmitter.java
 => SplitWatermarkExtractor.java} (63%)
 create mode 100644 
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/TestBase.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
 create mode 100644 
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
 create mode 100644 
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
 copy 
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceRecordEmitter.java
 => 
v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java}
 (61%)
 rename 
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/{IcebergSourceRecordEmitter.java
 => SplitWatermarkExtractor.java} (63%)
 create mode 100644 
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/TestBase.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
 create mode 100644 
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
 create mode 100644 
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
 copy 
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/{IcebergSourceRecordEmitter.java
 => SerializableRecordEmitter.java} (61%)
 rename 
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/{IcebergSourceRecordEmitter.java
 => SplitWatermarkExtractor.java} (63%)
 create mode 100644 
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestBase.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
 create mode 100644 
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
 create mode 100644 
gcp/src/test/java/org/apache/iceberg/gcp/GCPPropertiesTest.java
 create mode 100644 
hive-metastore/src/main/java/org/apache/iceberg/hive/HiveOperationsBase.java
 create mode 100644 
spark/v3.3/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/TestMetaColumnProjectionWithStageScan.java
 create mode 100644 
spark/v3.4/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/TestMetaColumnProjectionWithStageScan.java
 create mode 100644 
spark/v3.5/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/TestMetaColumnProjectionWithStageScan.java
 copy 
spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/{SparkDataFile.java => 
SparkContentFile.java} (79%)
 copy core/src/main/java/org/apache/iceberg/util/LocationUtil.java => 
spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkDeleteFile.java 
(58%)
 create mode 100644 
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/CatalogTestBase.java
 create mode 100644 
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBase.java
 create mode 100644 
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBaseWithCatalog.java

Reply via email to