This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/gradle/junit-5.10.2
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard fb78947866 Build: Bump junit from 5.10.1 to 5.10.2
add ba1cd36fbb OpenAPI: Fix additionalProperties for SnapshotSummary
(#9838)
add fab5e18d0d Hive, JDBC: Avoid NPE on Throwables without error msg
(#10082)
add 00f46ac096 Core: Introduce ConfigResponseParser (#9952)
add abf238abcc Build: Bump mkdocs-material from 9.5.15 to 9.5.17 (#10092)
add b3261d07fc AWS: Migrate tests to JUnit5 (#10086)
add cd707394dd Spec: Document support for binary in truncate transform
(#10079)
add a351e22b6d Docs: Add Upsolver to vendor list (#10096)
add 6f4e9c6a68 Docs: Update releases.md for Spark scala versions (#10104)
add 9bb86fa496 Docs: Fix spacing/descriptions on Branching and Tagging DDL
(#10091)
add 81bb0d4c9b Core: Add EnvironmentContext to commit summary (#9273)
add 96793bf621 docs: Fix links of `Get Started` and `Community` parts in
footer (#10098)
add 528b9b336c Core: Allow configuring socket/connection timeout in
HTTPClient (#10053)
add 0bc6dfa1bd Core: Extend HTTPClient Builder to allow setting a proxy
server (#10052)
add 290a6a0c5d Spark 3.4: Fix system function pushdown in CoW row-level
commands (#10119)
add ce7c2c150c API, Core, Kafka, Spark: Reduce enum array allocation
(#10126)
add 2025e79905 Spark: Test initialization improvements (#10131)
add 1e66657874 Spec: Make request bodies required (#10125)
add 81b3310ab4 Spark 3.5: Support preserving schema nullability in CTAS
and RTAS (#10074)
add 496b320985 Flink, Spark: Replace Boolean.getBoolean() with
Boolean.parseBoolean() (#10136)
add 2400aa5307 Build: Bump net.snowflake:snowflake-jdbc from 3.14.5 to
3.15.1 (#10095)
add 47825ffd8b Build: Bump software.amazon.awssdk:bom from 2.25.21 to
2.25.31 (#10138)
add dd74dd289e Build: Bump org.springframework:spring-web from 5.3.33 to
5.3.34 (#10139)
add fb657b413e Spark: Simplify SparkSchemaUtil#schemaForTable (#10137)
add 943321ee6d Flink: Migrate tests to JUnit5 (#10130)
add e6a1a45624 Core: Fix logging table name when scanning metadata table
(#10141)
add d067677df8 AWS: Close underlying scheduler for DynamoDbLockManager
(#10132)
add 78e8204c53 Spark 3.5: Add threshold for failed commits in data
rewrites (#9611)
add 97c5700ff5 Core: Fix JDBC Catalog table commit when migrating from
schema V0 to V1 (#10111)
add fc5b2b336c Core: Use 'delete' if RowDelta only has delete files
(#10123)
add fbcd142c5d Flink: Move flink/v1.18 to flink/v1.19
add f761d98a1d Flink: Recover flink/1.18 files from history
add b3ebcf109a Flink: Refactoring code and properties to make Flink 1.19
to work
add dd194b4391 Flink: Removes Flink version 1.16 (#10154)
add 0a4e6e6cfb Docs: Updates flink versioning information in our docs
(#10155)
add c41c599fe8 Flink: Backport Flink 1.18 JUnit5 migration to Flink 1.17
(#10163)
add 928888b579 OpenAPI: Renaming views should return 204 (#10166)
add 228fc9b41f Core: Fix namespace SQL statement using ESCAPE character
that works with MySQL/PostgreSQL (#10167)
add 8136463bd9 Flink: Don't fail to serialize IcebergSourceSplit when
there is too many delete files (#9464)
add 1f8cad3c71 Flink: port #9464 to v1.17 and v1.19 (#10177)
add efa14bfb29 Core: Improve size check in CatalogTests (#10182)
add ed2d0410c8 Kafka-connect: Update iceberg.hadoop-conf-dir config
description (#10184)
add 3ed04c16ec Build: Bump software.amazon.awssdk:bom from 2.25.31 to
2.25.35 (#10192)
add e468d02e4a Build: Bump io.netty:netty-buffer from 4.1.108.Final to
4.1.109.Final (#10191)
add 9664940ae4 Build: Bump org.roaringbitmap:RoaringBitmap from 1.0.5 to
1.0.6 (#10190)
add 2510ef861c Build: Bump mkdocs-material from 9.5.17 to 9.5.18 (#10189)
add 4261e18b7f Build: Bump
gradle.plugin.io.morethan.jmhreport:gradle-jmh-report (#10193)
add a23021d05d Core: Lazily compute & cache hashCode in
CharSequenceWrapper (#10023)
add e3b78be9ac AWS: Make sure Signer + User Agent config are both applied
(#10198)
add 866021d7d3 Hive: turn off the stats gathering when
iceberg.hive.keep.stats is false (#10148)
add 34e181b288 Docs: Don't check links on Release page (#10212)
add bfe0daadd5 Docs: Use `svn mv` when releasing the binaries (#9926)
add 53261312d6 Infra: Add 1.5.1 to issue template (#10214)
add 0f11f54c43 Update site to 1.5.1 docs (#10218)
add f460964e78 Core: Use 'delete' / 'append' if OverwriteFiles only
deletes/appends data files (#10150)
add 837a4aab37 AWS: Fix TestGlueCatalogTable#testCreateTable (#10221)
add 10ffc60621 Docs: Add 1.5.1 release notes (#10224)
add 5821efcdd5 Spec: Clarify missing fields when writing (#8672)
add c9f775b806 Flink: Move ParquetReader to LogicalTypeAnnotationVisitor
(#9719)
add b7d3a7f9d3 Flink: Fix bounded source state restore record duplication
(#10208)
add c9eed43816 REST: fix incorrect token refresh thread name (#10223)
add 21c0ec491d Flink: Backport #10208 to v1.18 and v1.17 (#10230)
add 646440abf6 Flink: Prevent setting endTag/endSnapshotId for streaming
source (#10207)
add 1e35bf96ec Flink: Backport #10207 to v1.18 and v1.17 (#10235)
add 01bc864b8e Build: Bump nessie from 0.79.0 to 0.80.0 (#10237)
add a0a6bcfe54 Build: Bump software.amazon.awssdk:bom from 2.25.35 to
2.25.40 (#10240)
add 9310bd4828 Spark: Bump minor version for Spark-3.4 (#10243)
add 6016110d94 Build: Bump
com.gorylenko.gradle-git-properties:gradle-git-properties (#10239)
add a55797d4ac Build: Bump com.google.errorprone:error_prone_annotations
(#10236)
add 426818bfe7 Core: Add property to disable table initialization for
JdbcCatalog (#10124)
add 6f0d9dd47c Flink: Migrate tests to JUnit5 (#10232)
add 96268505b4 Release: add instruction to update doap.rdf file as part of
release process (#9655)
add 5aa0d3bf27 Add stale PRs management (#10134)
add e785aa7faa Docs: Update doap.rdf (#10255)
add e85884d269 Build: Bump com.azure:azure-sdk-bom from 1.2.22 to 1.2.23
(#10238)
add 839f71c005 Build: Bump mkdocs-material from 9.5.18 to 9.5.19 (#10241)
add 8396097711 Build: Bump datamodel-code-generator from 0.25.5 to 0.25.6
(#10242)
add 1757577937 Flink: Apply DeleteGranularity for writes (#10200)
add aeb26820a8 Hive: Remove deprecated `setSchema(TableMetadata,
Map<String, String>)` (#10257)
add 0323308566 Flink: Backport #10200 to v1.19 and v1.17 (#10259)
add 7600ba74fa Core: Add pagination when listing namespaces/tables/views
(#9782)
add 51061511ed Docs: Update features for Hive 4.0 (#10162)
add be305b2910 Build: Bump org.xerial:sqlite-jdbc from 3.45.2.0 to
3.45.3.0 (#10194)
add 9cd5977e4e Build: Bump mkdocs-material from 9.5.19 to 9.5.21 (#10272)
add ed84ea0045 docs: Remove link to Flink unit test (#10160)
add 2857d3a927 Build: Bump nessie from 0.80.0 to 0.81.1 (#10267)
add ed0959257c MR: Fix using Date type as partition field (#10210)
add a5b85a7378 Docs: Update site to 1.5.2 docs (#10291)
add 5d3d647ead Build: Bump software.amazon.awssdk:bom from 2.25.40 to
2.25.45 (#10266)
add e6586e947f Infra: Add Iceberg 1.5.2 to issue template (#10296)
add b187b17f3f Update doap.rdf for 1.5.2 release (#10297)
add e10098b9ab Docs: Add release notes for 1.5.2 (#10295)
add 3c8e046978 Spec: Fix markdown for struct evolution default value rules
(#10290)
add 2b21020aed Core: Retry connections in JDBC catalog with user
configured error code list (#10140)
add e484f0d71b Build: Bump guava from 33.1.0-jre to 33.2.0-jre (#10271)
add 04792cf991 Spark 3.5: Remove obsolete conf parsing logic (#10309)
add 485ce3470b Build: Bump org.testcontainers:testcontainers from 1.19.7
to 1.19.8 (#10322)
add b752b742e4 docs: Update Quickstart to Hive 4.0.0 (#10325)
add d0dbc9cba2 Build: Bump software.amazon.awssdk:bom from 2.25.45 to
2.25.50 (#10323)
add b6236302c4 Parquet: Add Bloom filter FPP config (#10149)
add 02b1ff968d Spark 3.5: Add support for enums in SparkConfParser (#10311)
add d23c4902eb Spark: Backport tests for struct aggregation pushdown to
3.3/3.4, cleanup assertion (#10333)
add ea916c1700 Docs: Update vendor information for Cloudera (#10278)
add 5e08f886f3 Make proxy endpoint configurable for s3 Http clients
(#10332)
add a6fb9cd2d3 Spark 3.4: Add support for enums in SparkConfParser (#10330)
add 2058053b0c AWS: Retain Glue Catalog table description after updating
Iceberg table (#10199)
add 4c9f47d208 Kafka-connect: Handle namespace creation for auto table
creation (#10186)
add 2cd6d0d475 Avoid adding a closed client to the pool (#10337)
add 090fe2eca9 Build: Bump nessie from 0.81.1 to 0.82.0 (#10318)
add 788bea2695 Spark 3.5: Fix the setting of equalAuthorities in
RemoveOrphanFilesProcedure (#10334)
add f31315e935 Docs: Fix Apache Doris documentation link (#10263)
add f4aaa375e9 Build: Bump io.delta:delta-spark_2.12 from 3.1.0 to 3.2.0
(#10320)
add 139721fee6 Remove unused manifest predicate (#10339)
add bd046f844a Spark: Fix issue when partitioning by UUID (#8250)
add 6abb99f0a7 Spark 3.4, 3.3: Fix the setting of equalAuthorities in
RemoveOrphanFilesProcedure (#10342)
add 5f3d854cc1 Build: Bump junit from 5.10.1 to 5.10.2
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 (fb78947866)
\
N -- N -- N refs/heads/dependabot/gradle/junit-5.10.2
(5f3d854cc1)
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:
.baseline/checkstyle/checkstyle.xml | 4 +-
.github/ISSUE_TEMPLATE/iceberg_bug_report.yml | 4 +-
.github/workflows/flink-ci.yml | 2 +-
.github/workflows/stale.yml | 12 +-
.gitignore | 1 +
.../main/java/org/apache/iceberg/FileFormat.java | 4 +-
.../apache/iceberg/actions/RewriteDataFiles.java | 7 +
.../java/org/apache/iceberg/types/JavaHashes.java | 4 +
.../apache/iceberg/util/CharSequenceWrapper.java | 25 +-
.../apache/iceberg/util/TestCharSequenceMap.java | 7 +
.../apache/iceberg/util/TestCharSequenceSet.java | 6 +
.../iceberg/util/TestCharSequenceWrapper.java | 93 +++
.../aws/TestAssumeRoleAwsClientFactory.java | 23 +-
.../iceberg/aws/TestDefaultAwsClientFactory.java | 13 +-
.../iceberg/aws/dynamodb/TestDynamoDbCatalog.java | 127 ++--
.../aws/dynamodb/TestDynamoDbLockManager.java | 74 +-
.../org/apache/iceberg/aws/glue/GlueTestBase.java | 37 +-
.../aws/glue/TestGlueCatalogCommitFailure.java | 162 +++--
.../iceberg/aws/glue/TestGlueCatalogLock.java | 26 +-
.../iceberg/aws/glue/TestGlueCatalogNamespace.java | 68 +-
.../iceberg/aws/glue/TestGlueCatalogTable.java | 230 +++---
.../aws/lakeformation/LakeFormationTestBase.java | 15 +-
.../TestLakeFormationAwsClientFactory.java | 26 +-
.../TestLakeFormationDataOperations.java | 19 +-
.../TestLakeFormationMetadataOperations.java | 33 +-
.../iceberg/aws/s3/TestS3FileIOIntegration.java | 73 +-
.../iceberg/aws/s3/TestS3MultipartUpload.java | 35 +-
.../aws/ApacheHttpClientConfigurations.java | 10 +
.../apache/iceberg/aws/HttpClientProperties.java | 7 +
.../aws/UrlConnectionHttpClientConfigurations.java | 10 +
.../iceberg/aws/dynamodb/DynamoDbLockManager.java | 4 +-
.../iceberg/aws/glue/GlueTableOperations.java | 3 +
.../apache/iceberg/aws/s3/S3FileIOProperties.java | 20 +-
.../iceberg/aws/TestHttpClientConfigurations.java | 13 +
.../apache/iceberg/aws/TestS3FileIOProperties.java | 27 +
.../iceberg/aws/s3/TestS3FileIOProperties.java | 18 +-
build.gradle | 5 +-
.../apache/iceberg/BaseAllMetadataTableScan.java | 6 +-
.../src/main/java/org/apache/iceberg/BaseFile.java | 3 +-
.../org/apache/iceberg/BaseOverwriteFiles.java | 8 +
.../main/java/org/apache/iceberg/BaseRowDelta.java | 4 +
.../java/org/apache/iceberg/CachingCatalog.java | 3 +-
.../java/org/apache/iceberg/ClientPoolImpl.java | 41 +-
.../org/apache/iceberg/GenericManifestEntry.java | 3 +-
.../org/apache/iceberg/GenericManifestFile.java | 3 +-
.../java/org/apache/iceberg/ManifestGroup.java | 10 -
.../java/org/apache/iceberg/SnapshotProducer.java | 1 +
.../java/org/apache/iceberg/TableProperties.java | 4 +
.../apache/iceberg/actions/BaseCommitService.java | 6 +
.../deletes/SortingPositionOnlyDeleteWriter.java | 4 +
.../iceberg/hadoop/HadoopTableOperations.java | 4 +-
.../java/org/apache/iceberg/io/BaseTaskWriter.java | 42 +-
.../java/org/apache/iceberg/jdbc/JdbcCatalog.java | 11 +-
.../org/apache/iceberg/jdbc/JdbcClientPool.java | 44 +-
.../apache/iceberg/jdbc/JdbcTableOperations.java | 2 +-
.../java/org/apache/iceberg/jdbc/JdbcUtil.java | 49 +-
.../apache/iceberg/jdbc/JdbcViewOperations.java | 2 +-
.../org/apache/iceberg/rest/CatalogHandlers.java | 58 ++
.../java/org/apache/iceberg/rest/HTTPClient.java | 103 ++-
.../org/apache/iceberg/rest/RESTSerializers.java | 22 +-
.../apache/iceberg/rest/RESTSessionCatalog.java | 113 ++-
.../rest/responses/ConfigResponseParser.java | 72 ++
.../rest/responses/ListNamespacesResponse.java | 21 +-
.../iceberg/rest/responses/ListTablesResponse.java | 21 +-
.../java/org/apache/iceberg/util/JsonUtil.java | 20 +
.../org/apache/iceberg/TestClientPoolImpl.java | 150 ++++
.../org/apache/iceberg/TestCommitReporting.java | 2 +-
.../java/org/apache/iceberg/TestOverwrite.java | 46 +-
.../test/java/org/apache/iceberg/TestRowDelta.java | 12 +
.../org/apache/iceberg/TestSnapshotSummary.java | 7 +
.../org/apache/iceberg/catalog/CatalogTests.java | 8 +-
.../org/apache/iceberg/jdbc/TestJdbcCatalog.java | 235 +++++-
.../java/org/apache/iceberg/jdbc/TestJdbcUtil.java | 98 +++
.../apache/iceberg/jdbc/TestJdbcViewCatalog.java | 67 ++
.../apache/iceberg/rest/RESTCatalogAdapter.java | 32 +-
.../org/apache/iceberg/rest/TestHTTPClient.java | 166 +++++
.../org/apache/iceberg/rest/TestRESTCatalog.java | 145 ++++
.../apache/iceberg/rest/TestRESTViewCatalog.java | 85 +++
.../iceberg/rest/responses/TestConfigResponse.java | 9 +-
.../rest/responses/TestConfigResponseParser.java | 138 ++++
.../rest/responses/TestListNamespacesResponse.java | 29 +-
.../rest/responses/TestListTablesResponse.java | 29 +-
.../java/org/apache/iceberg/util/TestJsonUtil.java | 47 ++
.../java/org/apache/iceberg/RecordWrapperTest.java | 4 +-
.../java/org/apache/iceberg/data/DataTest.java | 10 +-
.../apache/iceberg/data/avro/TestGenericData.java | 7 +-
.../apache/iceberg/data/orc/TestGenericData.java | 81 ++-
.../iceberg/data/parquet/TestGenericData.java | 20 +-
.../TestParquetEncryptionWithWriteSupport.java | 41 +-
.../iceberg/io/TestTaskEqualityDeltaWriter.java | 108 ++-
dev/stage-binaries.sh | 2 +-
doap.rdf | 6 +-
docs/docs/aws.md | 9 +-
docs/docs/configuration.md | 3 +-
docs/docs/flink-writes.md | 2 -
docs/docs/hive.md | 297 +++++++-
docs/docs/spark-configuration.md | 1 +
docs/docs/spark-ddl.md | 12 +-
docs/mkdocs.yml | 2 +-
flink/build.gradle | 7 +-
.../org/apache/iceberg/flink/FlinkCatalog.java | 806 ---------------------
.../iceberg/flink/FlinkDynamicTableFactory.java | 209 ------
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 181 -----
.../org/apache/iceberg/flink/FlinkTypeToType.java | 199 -----
.../flink/sink/IcebergFilesCommitterMetrics.java | 96 ---
.../source/assigner/DefaultSplitAssigner.java | 112 ---
.../flink/source/assigner/SplitAssigner.java | 118 ---
.../enumerator/AbstractIcebergEnumerator.java | 173 -----
.../enumerator/ContinuousIcebergEnumerator.java | 178 -----
.../source/reader/IcebergSourceSplitReader.java | 156 ----
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 42 --
.../org/apache/iceberg/flink/FlinkTestBase.java | 129 ----
.../apache/iceberg/flink/MiniClusterResource.java | 53 --
.../iceberg/flink/data/TestFlinkParquetReader.java | 138 ----
.../flink/sink/TestCompressionSettings.java | 254 -------
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 361 ---------
.../flink/sink/TestFlinkPartitioningWriters.java | 66 --
.../source/TestFlinkInputFormatReaderDeletes.java | 70 --
.../flink/source/TestFlinkReaderDeletesBase.java | 89 ---
.../flink/source/TestStreamingMonitorFunction.java | 401 ----------
.../enumerator/TestContinuousSplitPlannerImpl.java | 688 ------------------
.../iceberg/flink/IcebergConnectorSmokeTest.java | 10 +-
.../iceberg/flink/data/FlinkParquetReaders.java | 183 +++--
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 3 +-
.../apache/iceberg/flink/source/FlinkSource.java | 9 +-
.../apache/iceberg/flink/source/IcebergSource.java | 9 +-
.../apache/iceberg/flink/source/ScanContext.java | 11 +-
.../flink/source/split/IcebergSourceSplit.java | 47 +-
.../source/split/IcebergSourceSplitSerializer.java | 6 +-
.../flink/source/split/SerializerHelper.java | 206 ++++++
.../flink/AvroGenericRecordConverterBase.java | 2 +-
.../org/apache/iceberg/flink/FlinkTestBase.java | 129 ----
.../org/apache/iceberg/flink/SimpleDataUtil.java | 6 +-
.../apache/iceberg/flink/TestCatalogLoader.java | 26 +-
.../apache/iceberg/flink/TestChangeLogTable.java | 73 +-
.../iceberg/flink/TestDataFileSerialization.java | 14 +-
.../iceberg/flink/TestFlinkAnonymousTable.java | 13 +-
.../iceberg/flink/TestFlinkCatalogFactory.java | 20 +-
.../org/apache/iceberg/flink/TestFlinkFilters.java | 87 ++-
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 30 +-
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 40 +-
.../apache/iceberg/flink/TestIcebergConnector.java | 81 +--
.../flink/TestManifestFileSerialization.java | 17 +-
.../apache/iceberg/flink/TestRowDataWrapper.java | 18 +-
.../iceberg/flink/TestTableSerialization.java | 18 +-
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 125 +++-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 5 +-
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 35 +
.../flink/source/ChangeLogTableTestBase.java | 24 +-
.../apache/iceberg/flink/source/SplitHelpers.java | 71 ++
.../flink/source/TestBoundedTableFactory.java | 30 +-
.../iceberg/flink/source/TestFlinkInputFormat.java | 20 +
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/source/TestFlinkSourceConfig.java | 16 +-
.../iceberg/flink/source/TestFlinkTableSource.java | 403 ++++++-----
.../flink/source/TestIcebergSourceBounded.java | 20 +
.../flink/source/TestIcebergSourceContinuous.java | 15 +
.../flink/source/TestIcebergSourceFailover.java | 107 ++-
...cebergSourceFailoverWithWatermarkExtractor.java | 15 +-
.../TestRowDataToAvroGenericRecordConverter.java | 5 +-
.../iceberg/flink/source/TestScanContext.java | 111 +++
.../iceberg/flink/source/TestStreamScanSql.java | 2 +
.../split/TestIcebergSourceSplitSerializer.java | 20 +
.../iceberg/flink/util/TestFlinkPackage.java | 11 +-
.../iceberg/flink/IcebergConnectorSmokeTest.java | 10 +-
.../iceberg/flink/data/FlinkParquetReaders.java | 183 +++--
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 3 +-
.../apache/iceberg/flink/source/FlinkSource.java | 9 +-
.../apache/iceberg/flink/source/IcebergSource.java | 9 +-
.../apache/iceberg/flink/source/ScanContext.java | 11 +-
.../flink/source/split/IcebergSourceSplit.java | 47 +-
.../source/split/IcebergSourceSplitSerializer.java | 6 +-
.../flink/source/split/SerializerHelper.java | 206 ++++++
.../flink/AvroGenericRecordConverterBase.java | 2 +-
.../org/apache/iceberg/flink/FlinkTestBase.java | 129 ----
.../org/apache/iceberg/flink/SimpleDataUtil.java | 6 +-
.../apache/iceberg/flink/TestCatalogLoader.java | 26 +-
.../apache/iceberg/flink/TestChangeLogTable.java | 73 +-
.../iceberg/flink/TestDataFileSerialization.java | 14 +-
.../iceberg/flink/TestFlinkAnonymousTable.java | 13 +-
.../iceberg/flink/TestFlinkCatalogFactory.java | 20 +-
.../org/apache/iceberg/flink/TestFlinkFilters.java | 87 ++-
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 30 +-
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 40 +-
.../apache/iceberg/flink/TestIcebergConnector.java | 81 +--
.../flink/TestManifestFileSerialization.java | 17 +-
.../apache/iceberg/flink/TestRowDataWrapper.java | 18 +-
.../iceberg/flink/TestTableSerialization.java | 18 +-
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 125 +++-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/data/TestRowProjection.java | 280 +++----
.../iceberg/flink/data/TestStructRowData.java | 2 +-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 5 +-
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 35 +
.../flink/source/ChangeLogTableTestBase.java | 24 +-
.../apache/iceberg/flink/source/SplitHelpers.java | 71 ++
.../flink/source/TestBoundedTableFactory.java | 30 +-
.../iceberg/flink/source/TestFlinkInputFormat.java | 20 +
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/source/TestFlinkSourceConfig.java | 16 +-
.../iceberg/flink/source/TestFlinkTableSource.java | 403 ++++++-----
.../flink/source/TestIcebergSourceBounded.java | 20 +
.../flink/source/TestIcebergSourceContinuous.java | 15 +
.../flink/source/TestIcebergSourceFailover.java | 107 ++-
...cebergSourceFailoverWithWatermarkExtractor.java | 15 +-
.../TestRowDataToAvroGenericRecordConverter.java | 5 +-
.../iceberg/flink/source/TestScanContext.java | 111 +++
.../iceberg/flink/source/TestStreamScanSql.java | 2 +
.../split/TestIcebergSourceSplitSerializer.java | 20 +
.../iceberg/flink/util/TestFlinkPackage.java | 11 +-
flink/{v1.16 => v1.19}/build.gradle | 36 +-
flink/{v1.16 => v1.19}/flink-runtime/LICENSE | 0
flink/{v1.16 => v1.19}/flink-runtime/NOTICE | 0
.../iceberg/flink/IcebergConnectorSmokeTest.java | 10 +-
.../sink/shuffle/MapRangePartitionerBenchmark.java | 0
.../org/apache/iceberg/flink/CatalogLoader.java | 0
.../org/apache/iceberg/flink/FlinkCatalog.java | 0
.../apache/iceberg/flink/FlinkCatalogFactory.java | 2 +-
.../org/apache/iceberg/flink/FlinkConfParser.java | 0
.../apache/iceberg/flink/FlinkConfigOptions.java | 0
.../iceberg/flink/FlinkDynamicTableFactory.java | 0
.../iceberg/flink/FlinkEnvironmentContext.java | 0
.../org/apache/iceberg/flink/FlinkFilters.java | 0
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 0
.../org/apache/iceberg/flink/FlinkReadConf.java | 0
.../org/apache/iceberg/flink/FlinkReadOptions.java | 0
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 0
.../apache/iceberg/flink/FlinkSourceFilter.java | 0
.../org/apache/iceberg/flink/FlinkTypeToType.java | 0
.../org/apache/iceberg/flink/FlinkTypeVisitor.java | 0
.../org/apache/iceberg/flink/FlinkWriteConf.java | 0
.../apache/iceberg/flink/FlinkWriteOptions.java | 0
.../org/apache/iceberg/flink/IcebergTableSink.java | 0
.../org/apache/iceberg/flink/RowDataWrapper.java | 0
.../java/org/apache/iceberg/flink/TableLoader.java | 0
.../org/apache/iceberg/flink/TypeToFlinkType.java | 0
.../org/apache/iceberg/flink/actions/Actions.java | 0
.../flink/actions/RewriteDataFilesAction.java | 0
.../flink/data/AvroWithFlinkSchemaVisitor.java | 0
.../apache/iceberg/flink/data/FlinkAvroReader.java | 0
.../apache/iceberg/flink/data/FlinkAvroWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcReader.java | 0
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 0
.../iceberg/flink/data/FlinkParquetReaders.java | 183 +++--
.../iceberg/flink/data/FlinkParquetWriters.java | 0
.../iceberg/flink/data/FlinkSchemaVisitor.java | 0
.../iceberg/flink/data/FlinkValueReaders.java | 0
.../iceberg/flink/data/FlinkValueWriters.java | 0
.../flink/data/ParquetWithFlinkSchemaVisitor.java | 0
.../iceberg/flink/data/RowDataProjection.java | 0
.../org/apache/iceberg/flink/data/RowDataUtil.java | 0
.../apache/iceberg/flink/data/StructRowData.java | 0
.../sink/AvroGenericRecordToRowDataMapper.java | 0
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 3 +-
.../flink/sink/BucketPartitionKeySelector.java | 0
.../iceberg/flink/sink/BucketPartitioner.java | 0
.../iceberg/flink/sink/BucketPartitionerUtil.java | 0
.../iceberg/flink/sink/CachingTableSupplier.java | 0
.../apache/iceberg/flink/sink/CommitSummary.java | 0
.../apache/iceberg/flink/sink/DeltaManifests.java | 0
.../flink/sink/DeltaManifestsSerializer.java | 0
.../flink/sink/EqualityFieldKeySelector.java | 0
.../iceberg/flink/sink/FlinkAppenderFactory.java | 0
.../iceberg/flink/sink/FlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/FlinkManifestUtil.java | 0
.../org/apache/iceberg/flink/sink/FlinkSink.java | 0
.../iceberg/flink/sink/IcebergFilesCommitter.java | 0
.../flink/sink/IcebergFilesCommitterMetrics.java | 0
.../iceberg/flink/sink/IcebergStreamWriter.java | 0
.../flink/sink/IcebergStreamWriterMetrics.java | 0
.../flink/sink/ManifestOutputFileFactory.java | 0
.../iceberg/flink/sink/PartitionKeySelector.java | 0
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 0
.../flink/sink/RowDataTaskWriterFactory.java | 0
.../iceberg/flink/sink/TaskWriterFactory.java | 0
.../flink/sink/UnpartitionedDeltaWriter.java | 0
.../flink/sink/shuffle/AggregatedStatistics.java | 0
.../sink/shuffle/AggregatedStatisticsTracker.java | 0
.../iceberg/flink/sink/shuffle/DataStatistics.java | 0
.../sink/shuffle/DataStatisticsCoordinator.java | 0
.../shuffle/DataStatisticsCoordinatorProvider.java | 0
.../flink/sink/shuffle/DataStatisticsEvent.java | 0
.../flink/sink/shuffle/DataStatisticsOperator.java | 0
.../flink/sink/shuffle/DataStatisticsOrRecord.java | 0
.../shuffle/DataStatisticsOrRecordSerializer.java | 0
.../flink/sink/shuffle/DataStatisticsUtil.java | 0
.../flink/sink/shuffle/MapDataStatistics.java | 0
.../sink/shuffle/MapDataStatisticsSerializer.java | 0
.../flink/sink/shuffle/MapRangePartitioner.java | 0
.../flink/sink/shuffle/SortKeySerializer.java | 0
.../AvroGenericRecordFileScanTaskReader.java | 0
.../apache/iceberg/flink/source/DataIterator.java | 0
.../iceberg/flink/source/DataTaskReader.java | 0
.../iceberg/flink/source/FileScanTaskReader.java | 0
.../iceberg/flink/source/FlinkInputFormat.java | 0
.../iceberg/flink/source/FlinkInputSplit.java | 0
.../apache/iceberg/flink/source/FlinkSource.java | 9 +-
.../iceberg/flink/source/FlinkSplitPlanner.java | 0
.../apache/iceberg/flink/source/IcebergSource.java | 9 +-
.../iceberg/flink/source/IcebergTableSource.java | 0
.../flink/source/RowDataFileScanTaskReader.java | 0
.../iceberg/flink/source/RowDataRewriter.java | 0
.../RowDataToAvroGenericRecordConverter.java | 0
.../apache/iceberg/flink/source/ScanContext.java | 11 +-
.../apache/iceberg/flink/source/SourceUtil.java | 0
.../flink/source/StreamingMonitorFunction.java | 0
.../flink/source/StreamingReaderOperator.java | 0
.../flink/source/StreamingStartingStrategy.java | 0
.../source/assigner/DefaultSplitAssigner.java | 0
.../flink/source/assigner/GetSplitResult.java | 0
.../assigner/OrderedSplitAssignerFactory.java | 0
.../assigner/SimpleSplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssigner.java | 0
.../source/assigner/SplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssignerType.java | 0
.../enumerator/AbstractIcebergEnumerator.java | 0
.../enumerator/ContinuousEnumerationResult.java | 0
.../enumerator/ContinuousIcebergEnumerator.java | 0
.../source/enumerator/ContinuousSplitPlanner.java | 0
.../enumerator/ContinuousSplitPlannerImpl.java | 0
.../source/enumerator/EnumerationHistory.java | 0
.../enumerator/IcebergEnumeratorPosition.java | 0
.../IcebergEnumeratorPositionSerializer.java | 0
.../source/enumerator/IcebergEnumeratorState.java | 0
.../IcebergEnumeratorStateSerializer.java | 0
.../source/enumerator/StaticIcebergEnumerator.java | 0
.../flink/source/reader/ArrayBatchRecords.java | 0
.../reader/ArrayPoolDataIteratorBatcher.java | 0
.../reader/AvroGenericRecordReaderFunction.java | 0
.../reader/ColumnStatsWatermarkExtractor.java | 0
.../flink/source/reader/DataIteratorBatcher.java | 0
.../source/reader/DataIteratorReaderFunction.java | 0
.../flink/source/reader/IcebergSourceReader.java | 0
.../source/reader/IcebergSourceReaderMetrics.java | 0
.../source/reader/IcebergSourceSplitReader.java | 0
.../flink/source/reader/ListBatchRecords.java | 0
.../source/reader/ListDataIteratorBatcher.java | 0
.../source/reader/MetaDataReaderFunction.java | 0
.../flink/source/reader/ReaderFunction.java | 0
.../flink/source/reader/RecordAndPosition.java | 0
.../iceberg/flink/source/reader/RecordFactory.java | 0
.../flink/source/reader/RowDataReaderFunction.java | 0
.../flink/source/reader/RowDataRecordFactory.java | 0
.../source/reader/SerializableRecordEmitter.java | 0
.../source/reader/SplitWatermarkExtractor.java | 0
.../reader/WatermarkExtractorRecordEmitter.java | 0
.../flink/source/split/IcebergSourceSplit.java | 47 +-
.../source/split/IcebergSourceSplitSerializer.java | 6 +-
.../source/split/IcebergSourceSplitState.java | 0
.../source/split/IcebergSourceSplitStatus.java | 0
.../flink/source/split/SerializableComparator.java | 0
.../flink/source/split/SerializerHelper.java | 206 ++++++
.../flink/source/split/SplitComparators.java | 0
.../flink/source/split/SplitRequestEvent.java | 0
.../iceberg/flink/util/ElapsedTimeGauge.java | 0
.../iceberg/flink/util/FlinkAlterTableUtil.java | 0
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 0
.../apache/iceberg/flink/util/FlinkPackage.java | 0
.../org.apache.flink.table.factories.Factory | 0
.../org.apache.flink.table.factories.TableFactory | 0
.../flink/AvroGenericRecordConverterBase.java | 2 +-
.../org/apache/iceberg/flink/CatalogTestBase.java | 0
.../org/apache/iceberg/flink/DataGenerator.java | 0
.../org/apache/iceberg/flink/DataGenerators.java | 0
.../iceberg/flink/HadoopCatalogExtension.java | 0
.../iceberg/flink/HadoopCatalogResource.java | 0
.../apache/iceberg/flink/HadoopTableResource.java | 0
.../apache/iceberg/flink/MiniClusterResource.java | 0
.../iceberg/flink/MiniFlinkClusterExtension.java | 0
.../org/apache/iceberg/flink/RowDataConverter.java | 0
.../org/apache/iceberg/flink/SimpleDataUtil.java | 6 +-
.../java/org/apache/iceberg/flink/TestBase.java | 20 +-
.../apache/iceberg/flink/TestCatalogLoader.java | 26 +-
.../iceberg/flink/TestCatalogTableLoader.java | 0
.../apache/iceberg/flink/TestChangeLogTable.java | 77 +-
.../iceberg/flink/TestDataFileSerialization.java | 14 +-
.../org/apache/iceberg/flink/TestFixtures.java | 0
.../iceberg/flink/TestFlinkAnonymousTable.java | 13 +-
.../iceberg/flink/TestFlinkCatalogDatabase.java | 8 +-
.../iceberg/flink/TestFlinkCatalogFactory.java | 22 +-
.../iceberg/flink/TestFlinkCatalogTable.java | 313 +++++++-
.../flink/TestFlinkCatalogTablePartitions.java | 5 +-
.../apache/iceberg/flink/TestFlinkConfParser.java | 0
.../org/apache/iceberg/flink/TestFlinkFilters.java | 87 ++-
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 32 +-
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 43 +-
.../apache/iceberg/flink/TestFlinkTableSink.java | 2 +-
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 2 +-
.../java/org/apache/iceberg/flink/TestHelpers.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 99 ++-
.../flink/TestManifestFileSerialization.java | 17 +-
.../apache/iceberg/flink/TestRowDataWrapper.java | 18 +-
.../org/apache/iceberg/flink/TestTableLoader.java | 0
.../iceberg/flink/TestTableSerialization.java | 18 +-
.../flink/actions/TestRewriteDataFilesAction.java | 2 +-
.../apache/iceberg/flink/data/RandomRowData.java | 0
.../iceberg/flink/data/RowDataToRowMapper.java | 0
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 239 ++++++
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/data/TestRowDataProjection.java | 0
.../iceberg/flink/data/TestRowProjection.java | 280 +++----
.../iceberg/flink/data/TestStructRowData.java | 2 +-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 5 +-
.../flink/sink/TestBucketPartitionKeySelector.java | 0
.../iceberg/flink/sink/TestBucketPartitioner.java | 0
.../TestBucketPartitionerFlinkIcebergSink.java | 0
.../flink/sink/TestBucketPartitionerUtil.java | 0
.../flink/sink/TestCachingTableSupplier.java | 0
.../flink/sink/TestCompressionSettings.java | 0
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 0
.../flink/sink/TestFlinkAppenderFactory.java | 0
.../flink/sink/TestFlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 0
.../flink/sink/TestFlinkIcebergSinkBase.java | 0
.../flink/sink/TestFlinkIcebergSinkBranch.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 35 +
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 0
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 0
.../iceberg/flink/sink/TestFlinkManifest.java | 0
.../flink/sink/TestFlinkPartitioningWriters.java | 0
.../flink/sink/TestFlinkPositionDeltaWriters.java | 0
.../flink/sink/TestFlinkRollingFileWriters.java | 0
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 0
.../flink/sink/TestIcebergFilesCommitter.java | 0
.../flink/sink/TestIcebergStreamWriter.java | 0
.../flink/sink/TestRowDataPartitionKey.java | 0
.../apache/iceberg/flink/sink/TestTaskWriters.java | 0
.../sink/shuffle/TestAggregatedStatistics.java | 0
.../shuffle/TestAggregatedStatisticsTracker.java | 0
.../shuffle/TestDataStatisticsCoordinator.java | 0
.../TestDataStatisticsCoordinatorProvider.java | 0
.../sink/shuffle/TestDataStatisticsOperator.java | 4 +-
.../flink/sink/shuffle/TestMapDataStatistics.java | 0
.../sink/shuffle/TestMapRangePartitioner.java | 0
.../sink/shuffle/TestSortKeySerializerBase.java | 0
.../shuffle/TestSortKeySerializerNestedStruct.java | 0
.../shuffle/TestSortKeySerializerPrimitives.java | 0
.../iceberg/flink/source/BoundedTableFactory.java | 0
.../iceberg/flink/source/BoundedTestSource.java | 0
.../flink/source/ChangeLogTableTestBase.java | 24 +-
.../apache/iceberg/flink/source/SplitHelpers.java | 71 ++
.../apache/iceberg/flink/source/SqlHelpers.java | 0
.../flink/source/TestBoundedTableFactory.java | 30 +-
.../iceberg/flink/source/TestFlinkInputFormat.java | 20 +
.../source/TestFlinkInputFormatReaderDeletes.java | 0
.../flink/source/TestFlinkMergingMetrics.java | 0
.../flink/source/TestFlinkMetaDataTable.java | 2 +-
.../flink/source/TestFlinkReaderDeletesBase.java | 0
.../apache/iceberg/flink/source/TestFlinkScan.java | 0
.../iceberg/flink/source/TestFlinkScanSql.java | 0
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/source/TestFlinkSourceConfig.java | 16 +-
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../iceberg/flink/source/TestFlinkTableSource.java | 426 +++++------
.../flink/source/TestIcebergSourceBounded.java | 20 +
.../TestIcebergSourceBoundedGenericRecord.java | 0
.../flink/source/TestIcebergSourceBoundedSql.java | 0
.../flink/source/TestIcebergSourceContinuous.java | 52 +-
.../flink/source/TestIcebergSourceFailover.java | 107 ++-
...cebergSourceFailoverWithWatermarkExtractor.java | 15 +-
.../source/TestIcebergSourceReaderDeletes.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 0
.../TestIcebergSourceWithWatermarkExtractor.java | 0
.../source/TestMetadataTableReadableMetrics.java | 2 +-
.../flink/source/TestProjectMetaColumn.java | 0
.../TestRowDataToAvroGenericRecordConverter.java | 5 +-
.../iceberg/flink/source/TestScanContext.java | 111 +++
.../iceberg/flink/source/TestSourceUtil.java | 0
.../apache/iceberg/flink/source/TestSqlBase.java | 0
.../iceberg/flink/source/TestStreamScanSql.java | 4 +-
.../flink/source/TestStreamingMonitorFunction.java | 0
.../flink/source/TestStreamingReaderOperator.java | 0
.../source/assigner/SplitAssignerTestBase.java | 0
.../source/assigner/TestDefaultSplitAssigner.java | 0
.../TestFileSequenceNumberBasedSplitAssigner.java | 0
.../assigner/TestWatermarkBasedSplitAssigner.java | 0
.../enumerator/ManualContinuousSplitPlanner.java | 0
.../TestContinuousIcebergEnumerator.java | 0
.../enumerator/TestContinuousSplitPlannerImpl.java | 0
...estContinuousSplitPlannerImplStartStrategy.java | 0
.../source/enumerator/TestEnumerationHistory.java | 0
.../TestIcebergEnumeratorStateSerializer.java | 0
.../source/reader/ReaderFunctionTestBase.java | 0
.../iceberg/flink/source/reader/ReaderUtil.java | 0
.../flink/source/reader/TestArrayBatchRecords.java | 0
.../TestArrayPoolDataIteratorBatcherRowData.java | 0
.../reader/TestColumnStatsWatermarkExtractor.java | 0
.../source/reader/TestIcebergSourceReader.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 20 +
.../iceberg/flink/util/TestFlinkPackage.java | 11 +-
.../org.apache.flink.table.factories.Factory | 0
format/spec.md | 9 +-
gradle.properties | 4 +-
gradle/libs.versions.toml | 52 +-
.../org/apache/iceberg/hive/HiveClientPool.java | 3 +-
.../apache/iceberg/hive/HiveOperationsBase.java | 8 -
.../apache/iceberg/hive/HiveTableOperations.java | 1 +
.../org/apache/iceberg/hive/TestHiveCatalog.java | 2 +-
.../apache/iceberg/hive/TestHiveClientPool.java | 45 ++
.../org/apache/iceberg/connect/events/Event.java | 3 +-
.../apache/iceberg/connect/IcebergSinkConfig.java | 8 +-
.../iceberg/connect/data/IcebergWriterFactory.java | 24 +
.../connect/data/IcebergWriterFactoryTest.java | 19 +-
.../iceberg/mr/hive/HiveIcebergRecordWriter.java | 5 +-
.../hive/TestHiveIcebergStorageHandlerNoScan.java | 4 +-
.../TestHiveIcebergStorageHandlerWithEngine.java | 51 ++
.../TestHiveIcebergWithHiveAutogatherEnable.java | 185 +++++
open-api/requirements.txt | 2 +-
open-api/rest-catalog-open-api.py | 1 -
open-api/rest-catalog-open-api.yaml | 16 +-
.../java/org/apache/iceberg/parquet/Parquet.java | 26 +
settings.gradle | 18 +-
site/docs/hive-quickstart.md | 6 +-
site/docs/how-to-release.md | 25 +-
site/docs/multi-engine-support.md | 5 +-
site/docs/releases.md | 35 +-
site/docs/vendors.md | 29 +-
site/mkdocs.yml | 2 +-
site/nav.yml | 2 +
site/overrides/partials/footer.html | 24 +-
site/requirements.txt | 2 +-
.../SparkRowLevelOperationsTestBase.java | 17 +-
.../iceberg/spark/extensions/TestDelete.java | 32 +-
.../extensions/TestRemoveOrphanFilesProcedure.java | 83 +++
.../iceberg/spark/source/WritersBenchmark.java | 9 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../procedures/RemoveOrphanFilesProcedure.java | 2 +-
.../apache/iceberg/spark/source/BaseReader.java | 4 +-
.../iceberg/spark/source/InternalRowWrapper.java | 26 +-
.../spark/source/SparkPartitionedFanoutWriter.java | 2 +-
.../spark/source/SparkPartitionedWriter.java | 2 +-
.../spark/source/SparkPositionDeltaWrite.java | 5 +-
.../apache/iceberg/spark/source/SparkWrite.java | 2 +-
.../spark/source/TestInternalRowWrapper.java | 3 +-
.../spark/source/TestSparkAppenderFactory.java | 2 +-
.../spark/source/TestSparkFileWriterFactory.java | 2 +-
.../spark/source/TestSparkPartitioningWriters.java | 2 +-
.../source/TestSparkPositionDeltaWriters.java | 2 +-
.../spark/source/TestSparkReaderDeletes.java | 3 +-
.../spark/source/TestStructuredStreamingRead3.java | 27 +-
.../iceberg/spark/sql/TestAggregatePushDown.java | 122 ++++
.../apache/iceberg/spark/sql/TestCreateTable.java | 27 +
.../catalyst/optimizer/ReplaceStaticInvoke.scala | 49 +-
.../iceberg/spark/extensions/SparkPlanUtil.java | 48 ++
.../SparkRowLevelOperationsTestBase.java | 16 +-
.../iceberg/spark/extensions/TestDelete.java | 32 +-
.../extensions/TestRemoveOrphanFilesProcedure.java | 83 +++
...SystemFunctionPushDownInRowLevelOperations.java | 354 +++++++++
.../iceberg/spark/source/WritersBenchmark.java | 9 +-
.../org/apache/iceberg/spark/SparkConfParser.java | 37 +
.../org/apache/iceberg/spark/SparkContentFile.java | 4 +-
.../org/apache/iceberg/spark/SparkReadConf.java | 14 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/functions/BaseScalarFunction.java | 0
.../iceberg/spark/functions/BucketFunction.java | 3 +-
.../iceberg/spark/functions/DaysFunction.java | 3 +-
.../iceberg/spark/functions/HoursFunction.java | 5 +-
.../spark/functions/IcebergVersionFunction.java | 3 +-
.../iceberg/spark/functions/MonthsFunction.java | 3 +-
.../iceberg/spark/functions/TruncateFunction.java | 3 +-
.../iceberg/spark/functions/YearsFunction.java | 3 +-
.../procedures/RemoveOrphanFilesProcedure.java | 2 +-
.../apache/iceberg/spark/source/BaseReader.java | 4 +-
.../iceberg/spark/source/InternalRowWrapper.java | 26 +-
.../spark/source/SparkPartitionedFanoutWriter.java | 2 +-
.../spark/source/SparkPartitionedWriter.java | 2 +-
.../spark/source/SparkPositionDeltaWrite.java | 5 +-
.../apache/iceberg/spark/source/SparkWrite.java | 2 +-
.../spark/source/TestInternalRowWrapper.java | 3 +-
.../spark/source/TestSparkAppenderFactory.java | 2 +-
.../spark/source/TestSparkFileWriterFactory.java | 2 +-
.../spark/source/TestSparkPartitioningWriters.java | 2 +-
.../source/TestSparkPositionDeltaWriters.java | 2 +-
.../spark/source/TestSparkReaderDeletes.java | 3 +-
.../spark/source/TestStructuredStreamingRead3.java | 27 +-
.../iceberg/spark/sql/TestAggregatePushDown.java | 122 ++++
.../apache/iceberg/spark/sql/TestCreateTable.java | 26 +
.../spark/extensions/ExtensionsTestBase.java | 3 +
.../SparkRowLevelOperationsTestBase.java | 17 +-
.../iceberg/spark/extensions/TestDelete.java | 31 +-
.../extensions/TestRemoveOrphanFilesProcedure.java | 83 +++
.../extensions/TestRewriteDataFilesProcedure.java | 17 +
.../TestRewritePositionDeleteFilesProcedure.java | 22 +
.../iceberg/spark/source/WritersBenchmark.java | 9 +-
.../java/org/apache/iceberg/spark/BaseCatalog.java | 20 +
.../org/apache/iceberg/spark/SparkCatalog.java | 2 +
.../org/apache/iceberg/spark/SparkConfParser.java | 65 +-
.../org/apache/iceberg/spark/SparkContentFile.java | 4 +-
.../org/apache/iceberg/spark/SparkReadConf.java | 16 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../apache/iceberg/spark/SparkSessionCatalog.java | 2 +
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/actions/RewriteDataFilesSparkAction.java | 36 +-
.../procedures/RemoveOrphanFilesProcedure.java | 2 +-
.../apache/iceberg/spark/source/BaseReader.java | 4 +-
.../iceberg/spark/source/InternalRowWrapper.java | 26 +-
.../spark/source/SparkPartitionedFanoutWriter.java | 2 +-
.../spark/source/SparkPartitionedWriter.java | 2 +-
.../spark/source/SparkPositionDeltaWrite.java | 5 +-
.../apache/iceberg/spark/source/SparkWrite.java | 2 +-
.../org/apache/iceberg/spark/CatalogTestBase.java | 4 -
.../apache/iceberg/spark/TestBaseWithCatalog.java | 2 +-
.../iceberg/spark/TestSparkCatalogOperations.java | 102 +++
.../iceberg/spark/TestSparkExecutorCache.java | 4 +-
.../apache/iceberg/spark/TestSparkWriteConf.java | 9 +
.../spark/actions/TestRewriteDataFilesAction.java | 48 +-
.../iceberg/spark/data/TestSparkParquetWriter.java | 35 +
.../spark/source/TestInternalRowWrapper.java | 3 +-
.../spark/source/TestSparkAppenderFactory.java | 2 +-
.../spark/source/TestSparkFileWriterFactory.java | 2 +-
.../spark/source/TestSparkPartitioningWriters.java | 2 +-
.../source/TestSparkPositionDeltaWriters.java | 2 +-
.../spark/source/TestSparkReaderDeletes.java | 3 +-
.../spark/source/TestStructuredStreamingRead3.java | 26 +-
.../iceberg/spark/sql/TestAggregatePushDown.java | 6 +-
.../apache/iceberg/spark/sql/TestCreateTable.java | 26 +
629 files changed, 10380 insertions(+), 8032 deletions(-)
create mode 100644
api/src/test/java/org/apache/iceberg/util/TestCharSequenceWrapper.java
create mode 100644
core/src/main/java/org/apache/iceberg/rest/responses/ConfigResponseParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestClientPoolImpl.java
create mode 100644
core/src/test/java/org/apache/iceberg/rest/responses/TestConfigResponseParser.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
delete mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/MiniClusterResource.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
delete mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
create mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java
create mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestScanContext.java
create mode 100644
flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java
delete mode 100644
flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java
create mode 100644
flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestScanContext.java
rename flink/{v1.16 => v1.19}/build.gradle (91%)
rename flink/{v1.16 => v1.19}/flink-runtime/LICENSE (100%)
rename flink/{v1.16 => v1.19}/flink-runtime/NOTICE (100%)
rename flink/{v1.16 =>
v1.19}/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java
(81%)
rename flink/{v1.16 =>
v1.19}/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java (100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
(99%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java (100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
(81%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java
(97%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatistics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsEvent.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecord.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecordSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
(97%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java
(98%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
(97%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java
(82%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java
(92%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java
(100%)
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
(98%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/CatalogTestBase.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/DataGenerator.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogExtension.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopTableResource.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/MiniClusterResource.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java (98%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestBase.java (84%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogLoader.java (86%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
(86%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java
(94%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkAnonymousTable.java
(85%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java
(97%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java
(88%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
(51%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java
(96%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java (85%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
(79%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java
(93%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
(99%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java (99%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
(80%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java
(93%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java
(85%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java (100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java
(91%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java
(99%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java
(91%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java
(87%)
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java
(88%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java
(64%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestStructRowData.java
(98%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestAvroGenericRecordToRowDataMapper.java
(94%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionKeySelector.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitioner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerFlinkIcebergSink.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkAppenderFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
(87%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatistics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatisticsTracker.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinatorProvider.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsOperator.java
(98%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapDataStatistics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapRangePartitioner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerNestedStruct.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerPrimitives.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
(83%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java
(64%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java
(77%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java
(89%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
(97%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceConfig.java
(83%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
(53%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java
(86%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedGenericRecord.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java
(90%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
(79%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
(90%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestMetadataTableReadableMetrics.java
(99%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestRowDataToAvroGenericRecordConverter.java
(93%)
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestScanContext.java
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/SplitAssignerTestBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestDefaultSplitAssigner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestFileSequenceNumberBasedSplitAssigner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestEnumerationHistory.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java
(100%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java
(89%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java
(85%)
rename flink/{v1.16 =>
v1.19}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
create mode 100644
mr/src/test/java/org/apache/iceberg/mr/hive/TestHiveIcebergWithHiveAutogatherEnable.java
create mode 100644
spark/v3.4/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/TestSystemFunctionPushDownInRowLevelOperations.java
copy spark/{v3.5 =>
v3.4}/spark/src/main/java/org/apache/iceberg/spark/functions/BaseScalarFunction.java
(100%)
