This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/gradle/antlr-4.13.2
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard 1b5698245f Build: Bump antlr from 4.9.3 to 4.13.2
add 479f468c5f Spec: Deprecate the file system table scheme (#10833)
add d9aacd24cc Core, API: UpdatePartitionSpec: Added ability to create a
new Partition Spec but not set it as the Default
add 4cfa38fbb2 Build: Bump com.palantir.baseline:gradle-baseline-java
(#10864)
add 98ecc9a9ef Build: Bump nessie from 0.94.2 to 0.94.4 (#10869)
add e8582c0f00 Build: Bump org.xerial:sqlite-jdbc from 3.46.0.0 to
3.46.0.1 (#10871)
add 1f21989305 Build: Bump org.apache.commons:commons-compress from 1.26.0
to 1.26.2 (#10868)
add 9b70fdfd03 Build: Bump software.amazon.awssdk:bom from 2.26.25 to
2.26.29 (#10866)
add 74a9adbc0b Build: Bump mkdocs-material from 9.5.30 to 9.5.31 (#10863)
add 722a350afa Build: Fix Scala compilation (#10860)
add 87537f9954 Build: Enable FormatStringAnnotation error-prone check
(#10856)
add 5fc1413a5e Core: Use encoding/decoding methods for namespaces and
deprecate Splitter/Joiner (#10858)
add 04c2533f1d Aliyun: Replace assert usage with assertThat (#10880)
add b531e97f66 Core: Extract filePath comparator into it's own class
(#10664)
add 3d364f6d95 Docs: Fix SQL in branching docs (#10876)
add e9364faabc API: Add SupportsRecoveryOperations mixin for FileIO
(#10711)
add 525d887811 Spec: Clarify identity partition edge cases (#10835)
add 6ee6d1327d Build: Bump org.testcontainers:testcontainers from 1.20.0
to 1.20.1 (#10865)
add 93f7839fa1 Flink: move v1.19 to v.120
add fb60ecde9d Flink: add v1.19 back after coping from 1.20
add 0d8f2c42ff Flink: remove v1.17 module
add 38733f8fe6 Flink: adjust code for the new 1.20 module.
add 257b1d7b18 Build: Add checkstyle rule to ban assert usage (#10886)
add 86611d94db Build: Bump Apache Avro to 1.12.0 (#10879)
add 8ec65abdc5 Spec: Fix rendering of unified partition struct (#10896)
add 71b64399dd Docs: Fix catalog name for S3 MRAP example (#10897)
add a3cbdcbae6 Add Flink 1.20 & remove Flink 1.17 in stage-binaries.sh and
docs (#10888)
add 97e034b2ce Flink: Remove deprecated RowDataUtil.clone method (#10902)
add 3bee806d0c AWS: Fix flaky TestS3RestSigner (#10898)
add 70c506ebad AWS: Implement SupportsRecoveryOperations mixin for
S3FileIO (#10721)
add d17a7f189a Core: Remove deprecated APIs for 1.7.0 (#10818)
add 79620e1980 Core, Flink: Fix build warnings (#10899)
add ae08334cad Build: Bump Spark 3.5 to 3.5.2 (#10918)
add b4e60e0252 Build: Bump com.google.errorprone:error_prone_annotations
(#10915)
add b4fcd40129 Build: Bump org.awaitility:awaitility from 4.2.1 to 4.2.2
(#10912)
add 03c2ce9e39 Build: Bump datamodel-code-generator from 0.25.8 to 0.25.9
(#10917)
add 8bc1dde5cb Build: Bump nessie from 0.94.4 to 0.95.0 (#10910)
add 8ecaaeba5a Docs: Add Trademark symbol where appropriate (#10921)
add 45bd17294a Build: Bump com.google.cloud:libraries-bom from 26.43.0 to
26.44.0 (#10916)
add 994c0fb790 Build: Bump org.apache.commons:commons-compress from 1.26.2
to 1.27.0 (#10914)
add 33259f946b Build: Bump software.amazon.awssdk:bom from 2.26.29 to
2.27.2 (#10913)
add bfab2c334e Build: Bump org.xerial.snappy:snappy-java from 1.1.10.5 to
1.1.10.6 (#10911)
add 3cd82a7e99 Docs, Infra: Mount local versioned doc branch for testing
(#10838)
add 520e7ffce7 API: Fix JavaDoc typos in Transaction API
add 4b57cf8d93 Core: Fix metadata table test to set partition to the right
PartitionKey (#10925)
add cf02ffac43 AWS, Core, Hive: Extract FileIO closing into separate
FileIOTracker class (#10893)
add 8c85a5a7f1 Build: Suppress various build warnings (#10938)
add 3cd2c528a8 Core: add JSON serialization for
BaseFilesTable.ManifestReadTask, AllManifestsTable.ManifestListReadTask, and
BaseEntriesTable.ManifestReadTask (#10735)
add 9f12cf91dc AWS, Core: Slim down Jetty config for tests (#10945)
add a492027735 Docs: Cloudera blog in February 2023 (#10947)
add 49cf9d9881 Core: V3 Metadata Upgrade Validation and Testing (#10861)
add 10fce2700e Spec: Clarify in REST spec that server implementations of
commit endpoints must fail with 400 if any unknown updates or requirements are
received (#10848)
add 65e7cae512 Build: Bump guava from 33.2.1-jre to 33.3.0-jre (#10960)
add d4e0b3f207 Build: Bump org.springframework:spring-web from 5.3.37 to
5.3.39 (#10959)
add b53595b738 Build: Bump software.amazon.awssdk:bom from 2.27.2 to
2.27.7 (#10961)
add 9ddde5077b Docs: Update MRAP endpoint and add notebook link (#9362)
add ed07fd1cd7 Flink: put everything together for range distribution in
Flink sink (#10859)
add 43bbf08adc Flink: FLIP-27 IcebergSource builder missed a couple of
configs compared to old FlinkSource: expose locality and plan parallelism
(#10957)
add 3028552b41 Prevent implicit default locale/charset usage (#10969)
add 2f2c367b35 Core: Add ManifestWrite benchmark (#8637)
add b76d81acf0 S3OutputStream: Don't complete multipart upload on finalize
(#10874)
add ce33890314 Enable UnusedMethod error-prone check (#10968)
add 24afc1f980 Build: Upgrade to Gradle 8.10 (#10976)
add 40d5204fb7 Core: Support case-insensitivity for column names in
PartitionSpec (#10678)
add f17c225f67 Core: Remove unused throws declarations (#10974)
add 85cf79de01 Flink: deprecate ReaderFunction with a new Converter
interface to simplify user experience (#10956)
add bcb32818da Drop ParallelIterable's queue low water mark (#10978)
add f1076494c8 Check for minimal queue size in ParallelIterable (#10977)
add 2f6e7e6371 API, Spark 3.5: Action to compute table stats (#10288)
add cbd71ebd12 Core,AWS: Fix NPE in ResolvingFileIO when HadoopConf is not
set (#10872)
add 04461781c7 Spark 3.5: Fix incorrect catalog loaded in
TestCreateActions (#10952)
add b2cd6f38ed Flink: Maintenance - TriggerManager (#10484)
add 7fec19f3fd Flink: backport PR #10956 for converter interface that
deprecates ReaderFunction (#10985)
add bf459eed48 Flink: backport PR #10777 from 1.19 to 1.18 for sink test
refactoring. (#10965)
add ac0d206359 Spec: Minor modifications for v3 (#10948)
add ce772a6ecd Flink: backport PR #10859 for range distribution (#10990)
add f2d62757e2 Flink: Port #10484 to v1.20 (#10989)
add aa1ecc817b Flink: Maintenance - TableChange refactor (#10992)
add 2424e2c31d Flink: Port #10992 to v1.19 (#10994)
add e0596fbba2 OpenAPI: Add endpoint field to CatalogConfig (#10928)
add 5864850083 Spark 3.5: Add utility to load table state reliably (#10984)
add b9a6645a53 AWS: Include http-auth-aws-crt module into
iceberg-aws-bundle (#10972)
add 5958065b05 Build: Bump software.amazon.awssdk:bom from 2.27.7 to
2.27.12 (#11006)
add 9aa354d222 Build: Bump org.apache.commons:commons-compress from 1.27.0
to 1.27.1 (#11005)
add 4af2b9e7ae Build: Bump jetty from 11.0.22 to 11.0.23 (#11003)
add 244eb1e8d4 Build: Bump mkdocs-material from 9.5.31 to 9.5.33 (#11002)
add 524fbb895c Docs: `_commit_snapshot_id` instead of
`_change_snapshot_id` (#11000)
add 99e4ab711d Docs: Rename Clickhouse to ClickHouse (#10998)
add 2ed61a12bf Flink: infer source parallelism for FLIP-27 source in batch
execution mode (#10832)
add a7398aba21 Flink: Fix duplicate data with upsert writer in case of
aborted checkpoints (#10526)
add bea364c36f Introduces the new IcebergSink based on the new V2 Flink
Sink Abstraction (#10179)
add e6f8ab9950 Flink: Backport PR #10179 to Flink 1.20 for v2 sink
(#11011)
add 1898e62164 Core: Project data file stats only if there are equality
deletes (#11013)
add f1764c6894 Build: Bump org.xerial:sqlite-jdbc from 3.46.0.1 to
3.46.1.0 (#11007)
add 64b36999d7 Docs: Add Druid docs url to sidebar (#10997)
add bf00d51e4b Flink: backport PR #10832 of inferring parallelism in
FLIP-27 source (#11009)
add c95bf58793 Add REST Compatibility Kit (#10908)
add f88f128dd9 Core: Generate realistic bounds in benchmarks (#11022)
add 8e2eb9ac2e OpenAPI, Build: Apply spotless to testFixtures source code
(#11024)
add 877f63b0b9 Docs: bump latest version to 1.6.1 (#11036)
add cd32ec76ec Spec: Add RemovePartitionSpecsUpdate REST update type
(#10846)
add 3c018333b6 Build: Ignore benchmark output folders across all modules
(#11030)
add 6c7964002b Core: Add benchmark for appending files (#11029)
add 9c344f96c8 Spark 3.5: Use FileGenerationUtil in PlanningBenchmark
(#11027)
add 4b71d40cc1 Flink: add unit tests for range distribution on bucket
partition column (#11033)
add a07f8620b9 Kafka Connect: Disable publish tasks in runtime project
(#11032)
add e8c614878d Flink: Backport PR #10526 to v1.18 and v1.20 (#11018)
add fa8fbb3d52 Build: Bump mkdocs-material from 9.5.33 to 9.5.34 (#11062)
add d128a2a981 Build: Bump com.google.errorprone:error_prone_annotations
(#11055)
add 113c6e7d62 API: implement types timestamp_ns and timestamptz_ns (#9008)
add 5319767ee9 Core: Refactor ZOrderByteUtils (#10624)
add a4461640c8 Docs: Initial committer guidelines and requirements for
merging (#10780)
add 896dcd50f9 Flink: Fix compile warning (#11072)
add 7830a3b938 Docs: Fix Flink 1.20 support versions (#11065)
add 4f37041612 Build: Enable more error-prone checks (#11078)
add 2391bdddca open-api: Fix compile warnings for testFixtures (#11071)
add f508a7ea8e Spark 3.3, 3.4: Parallelize reading files in migrate
procedures (#11043)
add f7c6d57a03 Spark 3.5: Mandate identifier fields when
create_changelog_view for table contain unsortable columns (#11045)
add 6e05ae022c Core: Fix setting hasNewDataFile flag in
MergingSnapshotProducer (#11088)
add ab2c6f889d Docs: Document accessing instance variables (#11087)
add 44eca04b65 Build: Bump jetty from 11.0.23 to 11.0.24 (#11096)
add cefb1bbfa2 Spec: Fix rendering of partition stats file section (#11068)
add 3fe4f420dd Build: Bump software.amazon.awssdk:bom from 2.27.12 to
2.27.21 (#11098)
add ed73ec43dd Build: Bump io.netty:netty-buffer from 4.1.112.Final to
4.1.113.Final (#11097)
add 153b070695 Spark 3.3, 3.4: Fix incorrect catalog loaded in
TestCreateActions (#11049)
add 41d00ae64d Core: Prevent incremental file cleanup when expiring
specified snapshots (#10983)
add 4873b4b753 Core, Kafka, Spark: Use AssertJ instead of JUnit assertions
(#11102)
add 026166f229 Docs: Add blogs written by rmoff (#11069)
add e40fe4cdbe Build: Upgrade to Gradle 8.10.1 (#11104)
add a5c8f9cd45 Build: Remove unused variables, fields and parameters
(#11101)
add 8d97d54756 OpenAPI: Add Scan Planning Endpoints to REST spec (#9695)
add 5439cbdb27 Kafka Connect: Docs on configuring the sink (#10746)
add 0747b60441 Kafka Connect: Terminate commits on coordinator stop
(#10814)
add 34cd01ba2e Build: Upgrade google-java-format to 1.22.0 (#11050)
add 6ff7a6ec2e Flink: Maintenance - Lock remover (#11010)
add 8b4b2c1975 Docs: Update Project links to includ contributing and REST
spec (#11114)
add ab0594bf71 Flink: Port #10484 to v1.19 (#11010) (#11117)
add e3d3f8845a OpenAPI: Fix YAML example and value json formatting (#11119)
add d2087a04bd Core: Parallelize manifest writing for many new files
(#11086)
add 799120636e API, Core: Add manifestLocation API to ContentFile (#11044)
add a2b8008da7 Core: Allow servers to express supported endpoints via
endpoint field in ConfigResponse (#10929)
add e449d3405c Hive: Add View support for HIVE catalog (#9852)
add 5582b0ca67 Spark 3.4: Action to compute table stats (#11106)
add 2e4d5b5b21 Docs: Fix missing options for remove_orphan_files procedure
(#11080)
add 5ce7c3091b Flink: Increase the number of checkpoints from 4 to 6 to
fix flakiness. (#11121)
add d5b21d82e3 Spark 3.4: Add utility to load table state reliably (#11115)
add 06ed235f97 Build: switch to slf4j-simple 2.x for test implementation
dependency because avro 1.12.0 brings in slf4j-api dependency to 2.x (#11001)
add f71c7dfb0f Core: Update metadata location without updating
lastUpdatedMillis (#11151)
add 40ffcb9ad4 Kafka Connect: separate CI workflow (#11075)
add bbeadea75e Core: Move internal struct projection to
SupportsIndexProjection (#11132)
add e3088bc098 Core: Add explicit JSON parser for LoadTableResponse
(#11148)
add ffa13b12eb Build: Add .java-version to gitignore (#11167)
add e5d9a1594b Docs: Clarify Partition Transform (#8337)
add 82cedbbb19 API, Core: Enable removing rewritten delete files in
RowDelta (#11166)
add 79fd977f67 Docs: `field_id` in name serialisation spec should read
`field-id` (#11135)
add 60f61c3dd0 AWS: Bump AWS SDK to version 2.28.5 (#11170)
add d4af40c9bc Build: Bump org.xerial.snappy:snappy-java from 1.1.10.6 to
1.1.10.7 (#11140)
add b2b65df4c6 Spark 3.3, 3.4, 3.5: Supplement test case for
`RollbackToTimestampProcedure` (#11171)
add 4482565d0e Docs: Uppercase SQL keywords in branching docs (#11172)
add b92ed13d6f Build: Bump org.apache.httpcomponents.client5:httpclient5
(#11186)
add 5ed9307918 Build: Bump tez010 from 0.10.3 to 0.10.4 (#11183)
add fc6271ca24 Build: Bump nessie from 0.95.0 to 0.97.1 (#11184)
add ddfe503de7 Build: Bump com.google.cloud:libraries-bom from 26.44.0 to
26.47.0 (#11185)
add 5a2c1c9c8d Build: Bump org.roaringbitmap:RoaringBitmap from 1.2.1 to
1.3.0 (#11187)
add 257bad29d7 API: Deprecate ContentFile#path API and add location API
which returns String (#11092)
add 72fd9ab9f4 Docs: Document AWS Redshift and Amazon Data Firehose
support (#11192)
add c0d73f4ef5 API, AWS: Retry S3InputStream reads (#10433)
add 983ede3976 AWS: Fix AWS doc URL (#11198)
add c07de6fffa Build: Bump mkdocs-macros-plugin from 1.0.5 to 1.2.0
(#11189)
add 2fa8c7d86c Core: Add rewritten delete files to write results (#11203)
add 474a770aa0 Core: Support iterating over positions in
PositionDeleteIndex (#11202)
add f3c784e166 Spark: Added merge schema as spark configuration (#9640)
add 1e5dcb1f6b Core: Support merging in PositionDeleteIndex (#11208)
add b1d38b3cac Core: Remove unused code for streaming position deletes
(#11175)
add 26648ae20f Build: Upgrade to Gradle 8.10.2 (#11212)
add 7bd13a32fd Core: Add a util to compute partition stats (#11146)
add 2d9c344b5e Parquet: update PruneColumns to inherit from
TypeWithSchemaVisitor to have Iceberg type (#11179)
add 95497abe55 Core: Replace use of CharSequenceMap in DeleteFileIndex
with String (#11199)
add dddb5f423b [Core] Fix TestFastAppend.testAddManyFiles() (#11218)
add 09370ddbc3 Spark: Deprecate SparkAppenderFactory (#11076)
add 9601784d61 Build: Bump guava from 33.3.0-jre to 33.3.1-jre (#11230)
add 570af254c0 Build: Bump software.amazon.awssdk:bom from 2.28.5 to
2.28.11 (#11229)
add 152f02de52 Build: Bump io.delta:delta-standalone_2.12 from 3.2.0 to
3.2.1 (#11228)
add d00c4938ad Build: Bump junit-platform from 1.10.3 to 1.11.1 (#11227)
add 3ce09bc5f1 Build: Bump io.delta:delta-spark_2.12 from 3.2.0 to 3.2.1
(#11225)
add 9454927ddb Core: Improve error handling when parsing view
representations (#11236)
add 97c9c535fb Core: Update REST CatalogHandlers to handle page sizes
exceeding number of Namespaces/Tables/Views (#11143)
add c8fe01e71f Core: Support combining position deletes during writes
(#11222)
add e4bc593d48 Core: Add DataFileSet / DeleteFileSet (#11195)
add e8a11cbf92 Build: Bump nessie from 0.97.1 to 0.99.0 (#11224)
add 168a983942 ThreadPools introduce newExitingWorkerPool and
newFixedThreadPool for clearer semantics (#11073)
add 8520b5bc76 Core: Deprecate legacy ways for loading position deletes
(#11242)
add 09c737656d AWS: Add configuration and set defaults for S3 retry
behaviour (#11052)
add 4099a671c7 Puffin: Document stats `ndv` value representation (#10793)
add fd8cb71057 Build: Bump mkdocs-material from 9.5.34 to 9.5.38 (#11233)
add 2b38e09346 Build: Bump
org.eclipse.microprofile.openapi:microprofile-openapi-api (#11182)
add b7b0a46819 Build: Bump org.xerial:sqlite-jdbc from 3.46.1.0 to
3.46.1.3 (#11231)
add 746e71931a Build: Update baseline-java 5.69.0 (#11252)
add f6cdf94094 Build: Forbid implicit case fall-through without a comment
and enable couple more recommendable error-prone checks (#11251)
add 8190ce7e6b API, Core: Add default value APIs and Avro implementation
(#9502)
add 745e819f37 AWS: Make sure overridden configurations are applied
(#11274)
add 5dde680797 Build: Bump com.google.cloud:libraries-bom from 26.47.0 to
26.48.0 (#11271)
add 3220fad982 Core: Fix UnicodeUtil#truncateStringMax returns malformed
string. (#11161)
add f0e4fd2f55 Core: Add internal Avro reader (#11108)
add 208ab20dc9 Arrow: Remove unused readers (#11276)
add 67dc9e58cd Spec: Add v3 types and type promotion (#10955)
add d7f668ab89 Build: Bump mkdocs-material from 9.5.38 to 9.5.39 (#11272)
add 5fa3bbeec2 Build: Bump com.google.errorprone:error_prone_annotations
(#11270)
add 410477fd9e Build: Bump junit-platform from 1.11.1 to 1.11.2 (#11266)
add 28265cd7c0 Build: Bump org.testcontainers:testcontainers from 1.20.1
to 1.20.2 (#11265)
add d93677a3f3 Build: Bump io.netty:netty-buffer from 4.1.113.Final to
4.1.114.Final (#11269)
add 7e5caf1c6a Build: Bump software.amazon.awssdk:bom from 2.28.11 to
2.28.16 (#11268)
add 337d05b8d5 Build: Bump jackson-bom from 2.14.2 to 2.18.0 (#11226)
add d3e015822c Build: Bump datamodel-code-generator from 0.25.9 to 0.26.1
(#11234)
add 0a1a6665c1 Build: Bump
software.amazon.s3.accessgrants:aws-s3-accessgrants-java-plugin (#9705)
add 7a7d150bbc Build: Bump net.snowflake:snowflake-jdbc from 3.18.0 to
3.19.0 (#11057)
add 62fd616ddc Build: Bump antlr from 4.9.3 to 4.13.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 (1b5698245f)
\
N -- N -- N refs/heads/dependabot/gradle/antlr-4.13.2
(62fd616ddc)
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 | 8 +
.github/ISSUE_TEMPLATE/iceberg_bug_report.yml | 3 +-
.github/workflows/delta-conversion-ci.yml | 6 +-
.github/workflows/flink-ci.yml | 13 +-
.github/workflows/hive-ci.yml | 6 +-
.github/workflows/java-ci.yml | 3 +-
.../{flink-ci.yml => kafka-connect-ci.yml} | 22 +-
.github/workflows/publish-snapshot.yml | 2 +-
.github/workflows/spark-ci.yml | 4 +-
.gitignore | 5 +-
.palantir/revapi.yml | 99 +-
.../apache/iceberg/aliyun/oss/OSSInputStream.java | 2 +-
.../apache/iceberg/aliyun/oss/OSSOutputStream.java | 2 +-
.../aliyun/oss/mock/AliyunOSSMockLocalStore.java | 18 +-
.../main/java/org/apache/iceberg/ContentFile.java | 20 +-
api/src/main/java/org/apache/iceberg/DataFile.java | 5 +-
api/src/main/java/org/apache/iceberg/Metrics.java | 2 +
.../java/org/apache/iceberg/PartitionSpec.java | 85 +-
api/src/main/java/org/apache/iceberg/RowDelta.java | 11 +
api/src/main/java/org/apache/iceberg/Schema.java | 25 +
.../main/java/org/apache/iceberg/Transaction.java | 6 +-
.../org/apache/iceberg/UpdatePartitionSpec.java | 11 +
.../apache/iceberg/actions/ActionsProvider.java | 6 +
.../apache/iceberg/actions/ComputeTableStats.java | 47 +
.../org/apache/iceberg/encryption/KmsClient.java | 4 +-
.../exceptions/NoSuchIcebergViewException.java | 25 +-
.../iceberg/expressions/BoundLiteralPredicate.java | 1 +
.../apache/iceberg/expressions/BoundReference.java | 4 +-
.../apache/iceberg/expressions/ExpressionUtil.java | 25 +-
.../apache/iceberg/expressions/Expressions.java | 12 +
.../org/apache/iceberg/expressions/Literals.java | 57 +-
.../iceberg/io/BulkDeletionFailureException.java | 4 +-
...eption.java => SupportsRecoveryOperations.java} | 24 +-
.../java/org/apache/iceberg/transforms/Bucket.java | 18 +
.../java/org/apache/iceberg/transforms/Dates.java | 14 +-
.../java/org/apache/iceberg/transforms/Days.java | 34 +-
.../java/org/apache/iceberg/transforms/Hours.java | 33 +-
.../java/org/apache/iceberg/transforms/Months.java | 34 +-
.../iceberg/transforms/PartitionSpecVisitor.java | 15 +-
.../iceberg/transforms/SortOrderVisitor.java | 13 +-
.../apache/iceberg/transforms/TimeTransform.java | 41 +-
.../org/apache/iceberg/transforms/Timestamps.java | 182 ++-
.../org/apache/iceberg/transforms/Transform.java | 6 +
.../apache/iceberg/transforms/TransformUtil.java | 38 +-
.../org/apache/iceberg/transforms/Transforms.java | 66 +-
.../org/apache/iceberg/transforms/Truncate.java | 4 +-
.../java/org/apache/iceberg/transforms/Years.java | 34 +-
.../java/org/apache/iceberg/types/Comparators.java | 49 +-
.../java/org/apache/iceberg/types/Conversions.java | 2 +
.../main/java/org/apache/iceberg/types/Type.java | 1 +
.../java/org/apache/iceberg/types/TypeUtil.java | 28 +-
.../main/java/org/apache/iceberg/types/Types.java | 186 ++-
.../java/org/apache/iceberg/util/DataFileSet.java | 113 ++
.../java/org/apache/iceberg/util/DateTimeUtil.java | 88 +-
.../org/apache/iceberg/util/DeleteFileSet.java | 114 ++
.../java/org/apache/iceberg/util/UnicodeUtil.java | 24 +-
.../java/org/apache/iceberg/util/WrapperSet.java | 177 +++
.../org/apache/iceberg/PartitionSpecTestBase.java | 9 +-
.../java/org/apache/iceberg/TestAccessors.java | 2 +
.../test/java/org/apache/iceberg/TestHelpers.java | 1 +
.../org/apache/iceberg/TestPartitionPaths.java | 38 +
.../apache/iceberg/TestSchemaCaseSensitivity.java | 65 +
.../iceberg/expressions/TestExpressionUtil.java | 71 +-
.../expressions/TestLiteralSerialization.java | 6 +-
.../expressions/TestMiscLiteralConversions.java | 67 +-
.../expressions/TestStringLiteralConversions.java | 64 +-
.../TestTimestampLiteralConversions.java | 245 ++++
.../apache/iceberg/transforms/TestBucketing.java | 56 +
.../org/apache/iceberg/transforms/TestDates.java | 69 +
.../apache/iceberg/transforms/TestIdentity.java | 2 +-
.../iceberg/transforms/TestTimeTransforms.java | 124 ++
.../apache/iceberg/transforms/TestTimestamps.java | 398 +++++-
.../org/apache/iceberg/types/TestComparators.java | 6 +
.../org/apache/iceberg/types/TestConversions.java | 13 +-
.../iceberg/types/TestReadabilityChecks.java | 2 +
.../iceberg/types/TestSerializableTypes.java | 2 +
.../java/org/apache/iceberg/types/TestTypes.java | 5 +
.../org/apache/iceberg/util/TestDateTimeUtil.java | 71 +-
.../vectorized/parquet/DecimalVectorUtil.java | 5 +-
...orizedDictionaryEncodedParquetValuesReader.java | 38 -
.../VectorizedParquetDefinitionLevelReader.java | 108 --
aws-bundle/LICENSE | 140 +-
aws-bundle/NOTICE | 67 +-
aws-bundle/build.gradle | 1 +
.../org/apache/iceberg/aws/AwsIntegTestUtil.java | 73 +-
.../aws/TestAssumeRoleAwsClientFactory.java | 4 -
.../org/apache/iceberg/aws/glue/GlueTestBase.java | 8 +-
.../aws/glue/TestGlueCatalogCommitFailure.java | 3 +-
.../iceberg/aws/glue/TestGlueCatalogTable.java | 2 -
.../aws/lakeformation/LakeFormationTestBase.java | 8 +-
.../TestLakeFormationAwsClientFactory.java | 1 -
.../iceberg/aws/s3/TestS3FileIOIntegration.java | 133 +-
.../iceberg/aws/AssumeRoleAwsClientFactory.java | 1 +
.../org/apache/iceberg/aws/AwsClientFactories.java | 1 +
.../java/org/apache/iceberg/aws/AwsProperties.java | 5 -
.../apache/iceberg/aws/HttpClientProperties.java | 12 +
.../org/apache/iceberg/aws/glue/GlueCatalog.java | 31 +-
.../LakeFormationAwsClientFactory.java | 1 +
.../aws/s3/DefaultS3FileIOAwsClientFactory.java | 1 +
.../java/org/apache/iceberg/aws/s3/S3FileIO.java | 54 +-
.../iceberg/aws/s3/S3FileIOAwsClientFactory.java | 1 +
.../apache/iceberg/aws/s3/S3FileIOProperties.java | 132 +-
.../org/apache/iceberg/aws/s3/S3InputStream.java | 73 +-
.../org/apache/iceberg/aws/s3/S3OutputStream.java | 12 +-
.../apache/iceberg/aws/TestS3FileIOProperties.java | 7 +-
.../iceberg/aws/s3/TestFlakyS3InputStream.java | 206 +++
.../org/apache/iceberg/aws/s3/TestS3FileIO.java | 15 +-
.../iceberg/aws/s3/TestS3FileIOProperties.java | 15 +
.../apache/iceberg/aws/s3/TestS3InputStream.java | 24 +-
.../iceberg/aws/s3/signer/S3SignerServlet.java | 4 +-
.../iceberg/aws/s3/signer/TestS3RestSigner.java | 16 +-
.../iceberg/azure/adlsv2/ADLSInputStream.java | 2 +-
.../iceberg/azure/adlsv2/ADLSOutputStream.java | 2 +-
baseline.gradle | 61 +-
build.gradle | 58 +-
.../org/apache/iceberg/common/DynConstructors.java | 20 +-
.../java/org/apache/iceberg/common/DynFields.java | 15 -
.../java/org/apache/iceberg/common/DynMethods.java | 40 +-
.../java/org/apache/iceberg/AppendBenchmark.java | 128 ++
.../org/apache/iceberg/ManifestReadBenchmark.java | 10 +-
...dBenchmark.java => ManifestWriteBenchmark.java} | 107 +-
.../iceberg/PartitionStatsUtilBenchmark.java | 105 ++
.../iceberg/ReplaceDeleteFilesBenchmark.java | 130 ++
.../apache/iceberg/metrics/CountersBenchmark.java | 2 +-
.../java/org/apache/iceberg/AllManifestsTable.java | 41 +-
.../iceberg/AllManifestsTableTaskParser.java | 107 ++
.../apache/iceberg/BaseDistributedDataScan.java | 10 +-
.../java/org/apache/iceberg/BaseEntriesTable.java | 54 +-
.../src/main/java/org/apache/iceberg/BaseFile.java | 109 +-
.../java/org/apache/iceberg/BaseFilesTable.java | 51 +-
.../iceberg/BaseMetastoreTableOperations.java | 15 +-
.../main/java/org/apache/iceberg/BaseRowDelta.java | 6 +
.../src/main/java/org/apache/iceberg/BaseScan.java | 17 +
.../apache/iceberg/BaseUpdatePartitionSpec.java | 16 +-
.../java/org/apache/iceberg/CatalogProperties.java | 1 +
.../main/java/org/apache/iceberg/CatalogUtil.java | 18 +
.../java/org/apache/iceberg/DeleteFileIndex.java | 31 +-
.../main/java/org/apache/iceberg/FastAppend.java | 9 +-
.../org/apache/iceberg/FileScanTaskParser.java | 29 -
.../org/apache/iceberg/FilesTableTaskParser.java | 99 ++
.../org/apache/iceberg/GenericBlobMetadata.java | 8 +
.../java/org/apache/iceberg/GenericDataFile.java | 5 +
.../java/org/apache/iceberg/GenericDeleteFile.java | 5 +
.../org/apache/iceberg/GenericManifestEntry.java | 17 +-
.../org/apache/iceberg/GenericManifestFile.java | 99 +-
.../apache/iceberg/InheritableMetadataFactory.java | 11 +-
.../iceberg/ManifestEntriesTableTaskParser.java | 98 ++
.../java/org/apache/iceberg/ManifestEntry.java | 1 +
.../org/apache/iceberg/ManifestFileParser.java | 271 ++++
.../org/apache/iceberg/ManifestFilterManager.java | 4 +-
.../java/org/apache/iceberg/ManifestGroup.java | 2 +-
.../java/org/apache/iceberg/ManifestReader.java | 30 +-
.../java/org/apache/iceberg/ManifestWriter.java | 3 +-
.../apache/iceberg/MergingSnapshotProducer.java | 75 +-
.../main/java/org/apache/iceberg/MetricsModes.java | 2 +-
.../java/org/apache/iceberg/PartitionStats.java | 252 ++++
.../org/apache/iceberg/PartitionStatsUtil.java | 136 ++
.../main/java/org/apache/iceberg/Partitioning.java | 10 +
.../java/org/apache/iceberg/PartitionsTable.java | 13 +-
.../java/org/apache/iceberg/RemoveSnapshots.java | 11 +
.../main/java/org/apache/iceberg/ScanSummary.java | 3 +-
.../java/org/apache/iceberg/ScanTaskParser.java | 28 +-
.../java/org/apache/iceberg/SnapshotProducer.java | 143 +-
.../java/org/apache/iceberg/SystemConfigs.java | 4 +-
.../java/org/apache/iceberg/TableMetadata.java | 28 +-
.../java/org/apache/iceberg/TableProperties.java | 16 +-
.../org/apache/iceberg/UpdateRequirements.java | 10 +-
.../main/java/org/apache/iceberg/V1Metadata.java | 5 +
.../main/java/org/apache/iceberg/V2Metadata.java | 5 +
.../main/java/org/apache/iceberg/V3Metadata.java | 5 +
.../iceberg/actions/BaseComputeTableStats.java | 28 +-
.../apache/iceberg/actions/RewriteFileGroup.java | 2 +-
.../actions/RewritePositionDeletesGroup.java | 2 +-
.../iceberg/actions/SizeBasedFileRewriter.java | 3 +-
.../org/apache/iceberg/avro/GenericAvroReader.java | 74 +-
.../org/apache/iceberg/avro/InternalReader.java | 252 ++++
.../org/apache/iceberg/avro/InternalReaders.java | 110 ++
.../iceberg/avro/SupportsIndexProjection.java | 85 ++
.../java/org/apache/iceberg/avro/ValueReaders.java | 98 ++
.../apache/iceberg/data/avro/IcebergDecoder.java | 4 +-
.../iceberg/deletes/BitmapPositionDeleteIndex.java | 40 +-
.../java/org/apache/iceberg/deletes/Deletes.java | 242 +---
.../org/apache/iceberg/deletes/PositionDelete.java | 7 +
.../iceberg/deletes/PositionDeleteIndex.java | 37 +
.../iceberg/deletes/PositionDeleteIndexUtil.java | 14 +-
.../deletes/SortingPositionOnlyDeleteWriter.java | 58 +-
.../org/apache/iceberg/hadoop/HadoopFileIO.java | 3 +-
.../org/apache/iceberg/hadoop/HadoopStreams.java | 4 +-
.../apache/iceberg/io/BasePositionDeltaWriter.java | 1 +
.../java/org/apache/iceberg/io/ContentCache.java | 30 +-
.../org/apache/iceberg/io/DeleteWriteResult.java | 18 +
.../iceberg/io/FanoutPositionOnlyDeleteWriter.java | 28 +-
.../java/org/apache/iceberg/io/FileIOParser.java | 4 +-
.../java/org/apache/iceberg/io/FileIOTracker.java | 65 +
.../org/apache/iceberg/io/OutputFileFactory.java | 2 +
.../org/apache/iceberg/io/ResolvingFileIO.java | 12 +-
.../java/org/apache/iceberg/io/WriteResult.java | 27 +-
.../java/org/apache/iceberg/jdbc/JdbcCatalog.java | 13 +-
.../org/apache/iceberg/rest/CatalogHandlers.java | 58 +-
.../java/org/apache/iceberg/rest/Endpoint.java | 161 +++
.../rest/ExponentialHttpRequestRetryStrategy.java | 2 +-
.../org/apache/iceberg/rest/RESTSerializers.java | 23 +-
.../apache/iceberg/rest/RESTSessionCatalog.java | 185 ++-
.../apache/iceberg/rest/RESTTableOperations.java | 13 +-
.../java/org/apache/iceberg/rest/RESTUtil.java | 16 +-
.../apache/iceberg/rest/RESTViewOperations.java | 11 +-
.../org/apache/iceberg/rest/ResourcePaths.java | 14 +
.../org/apache/iceberg/rest/auth/OAuth2Util.java | 22 -
.../iceberg/rest/responses/ConfigResponse.java | 29 +-
.../rest/responses/ConfigResponseParser.java | 16 +
.../iceberg/rest/responses/LoadTableResponse.java | 8 +-
.../rest/responses/LoadTableResponseParser.java | 90 ++
.../org/apache/iceberg/util/ContentFileUtil.java | 5 +
.../main/java/org/apache/iceberg/util/Pair.java | 5 -
.../org/apache/iceberg/util/ParallelIterable.java | 13 +-
.../org/apache/iceberg/util/PartitionUtil.java | 10 +
.../org/apache/iceberg/util/SerializationUtil.java | 2 +-
.../main/java/org/apache/iceberg/util/Tasks.java | 4 +-
.../java/org/apache/iceberg/util/ThreadPools.java | 58 +-
.../org/apache/iceberg/util/ZOrderByteUtils.java | 59 +-
.../apache/iceberg/view/BaseViewOperations.java | 5 +-
.../org/apache/iceberg/view/ViewVersionParser.java | 10 +-
.../org/apache/iceberg/DataTableScanTestBase.java | 65 +-
.../apache/iceberg/DeleteFileIndexTestBase.java | 8 +
.../org/apache/iceberg/FileGenerationUtil.java | 91 +-
.../iceberg/TestAllManifestsTableTaskParser.java | 152 ++
.../src/test/java/org/apache/iceberg/TestBase.java | 29 +-
.../java/org/apache/iceberg/TestFastAppend.java | 19 +
.../org/apache/iceberg/TestFileGenerationUtil.java | 108 ++
.../org/apache/iceberg/TestFileScanTaskParser.java | 30 -
.../apache/iceberg/TestFilesTableTaskParser.java | 132 ++
.../org/apache/iceberg/TestFormatVersions.java | 66 +-
.../org/apache/iceberg/TestManifestFileParser.java | 111 ++
.../org/apache/iceberg/TestManifestReader.java | 32 +-
.../java/org/apache/iceberg/TestMergeAppend.java | 21 +
.../apache/iceberg/TestMetadataTableFilters.java | 10 +-
.../org/apache/iceberg/TestMetadataTableScans.java | 4 +-
.../org/apache/iceberg/TestMetricsTruncation.java | 34 +-
.../TestPartitionSpecBuilderCaseSensitivity.java | 873 ++++++++++++
.../org/apache/iceberg/TestPartitionSpecInfo.java | 25 +
.../org/apache/iceberg/TestPartitionStatsUtil.java | 429 ++++++
.../java/org/apache/iceberg/TestPartitioning.java | 36 +
.../org/apache/iceberg/TestRemoveSnapshots.java | 25 +-
.../test/java/org/apache/iceberg/TestRowDelta.java | 147 ++
.../org/apache/iceberg/TestSnapshotProducer.java | 77 ++
.../java/org/apache/iceberg/TestTableMetadata.java | 127 +-
.../iceberg/TestTableUpdatePartitionSpec.java | 19 +
.../test/java/org/apache/iceberg/TestTables.java | 21 +-
.../org/apache/iceberg/TestUpdateRequirements.java | 9 +-
.../apache/iceberg/avro/TestReadDefaultValues.java | 166 +++
.../deletes/TestBitmapPositionDeleteIndex.java | 113 ++
.../apache/iceberg/deletes/TestPositionFilter.java | 254 ----
.../apache/iceberg/hadoop/HadoopFileIOTest.java | 6 +-
.../org/apache/iceberg/io/TestFileIOTracker.java | 72 +
.../apache/iceberg/rest/RESTCatalogAdapter.java | 109 +-
.../java/org/apache/iceberg/rest/TestEndpoint.java | 108 ++
.../org/apache/iceberg/rest/TestRESTCatalog.java | 21 +-
.../apache/iceberg/rest/TestRESTViewCatalog.java | 25 +-
.../TestRESTViewCatalogWithAssumedViewSupport.java | 95 ++
.../rest/responses/TestConfigResponseParser.java | 79 ++
.../responses/TestLoadTableResponseParser.java | 203 +++
.../org/apache/iceberg/util/TestDataFileSet.java | 303 ++++
.../org/apache/iceberg/util/TestDeleteFileSet.java | 321 +++++
.../apache/iceberg/util/TestParallelIterable.java | 45 +-
.../apache/iceberg/view/TestViewVersionParser.java | 18 +
.../org/apache/iceberg/data/BaseDeleteLoader.java | 4 +-
.../apache/iceberg/data/TableMigrationUtil.java | 19 +-
.../apache/iceberg/io/TestPartitioningWriters.java | 111 ++
.../iceberg/dell/ecs/EcsSeekableInputStream.java | 1 +
deploy.gradle | 9 +-
dev/stage-binaries.sh | 5 +-
doap.rdf | 6 +-
docs/docs/aws.md | 28 +-
docs/docs/branching.md | 10 +-
docs/docs/flink-configuration.md | 64 +-
docs/docs/flink-writes.md | 101 ++
docs/docs/kafka-connect.md | 352 +++++
docs/docs/partitioning.md | 2 +-
docs/docs/spark-procedures.md | 42 +-
docs/mkdocs.yml | 6 +-
flink/build.gradle | 9 +-
.../org/apache/iceberg/flink/FlinkCatalog.java | 834 -----------
.../apache/iceberg/flink/FlinkCatalogFactory.java | 213 ---
.../iceberg/flink/sink/FlinkAppenderFactory.java | 280 ----
.../flink/sink/IcebergFilesCommitterMetrics.java | 96 --
.../shuffle/CompletedStatisticsSerializer.java | 178 ---
.../flink/sink/shuffle/DataStatisticsOperator.java | 265 ----
.../sink/shuffle/DataStatisticsSerializer.java | 206 ---
.../sink/shuffle/GlobalStatisticsSerializer.java | 201 ---
.../sink/shuffle/StatisticsOrRecordSerializer.java | 210 ---
.../source/assigner/DefaultSplitAssigner.java | 112 --
.../flink/source/assigner/SplitAssigner.java | 118 --
.../org/apache/iceberg/flink/CatalogTestBase.java | 143 --
.../java/org/apache/iceberg/flink/TestBase.java | 128 --
.../apache/iceberg/flink/TestChangeLogTable.java | 296 ----
.../iceberg/flink/TestFlinkCatalogDatabase.java | 253 ----
.../iceberg/flink/TestFlinkCatalogTable.java | 669 ---------
.../flink/TestFlinkCatalogTablePartitions.java | 119 --
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 101 --
.../apache/iceberg/flink/TestFlinkTableSink.java | 358 -----
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 334 -----
.../apache/iceberg/flink/TestIcebergConnector.java | 343 -----
.../flink/actions/TestRewriteDataFilesAction.java | 481 -------
.../flink/data/TestFlinkOrcReaderWriter.java | 107 --
.../iceberg/flink/data/TestRowProjection.java | 594 --------
.../flink/sink/TestFlinkIcebergSinkBase.java | 64 -
.../flink/sink/TestFlinkPartitioningWriters.java | 66 -
.../sink/shuffle/TestDataStatisticsOperator.java | 350 -----
.../shuffle/TestSortKeySerializerSnapshot.java | 213 ---
.../iceberg/flink/source/TableSourceTestBase.java | 104 --
.../source/TestFlinkInputFormatReaderDeletes.java | 70 -
.../flink/source/TestFlinkMergingMetrics.java | 67 -
.../flink/source/TestFlinkMetaDataTable.java | 813 -----------
.../flink/source/TestIcebergSourceContinuous.java | 538 --------
.../source/TestMetadataTableReadableMetrics.java | 299 ----
.../iceberg/flink/source/TestStreamScanSql.java | 434 ------
.../reader/TestColumnStatsWatermarkExtractor.java | 176 ---
.../apache/iceberg/flink/FlinkCatalogFactory.java | 1 +
.../org/apache/iceberg/flink/FlinkConfParser.java | 27 +
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 4 +-
.../org/apache/iceberg/flink/FlinkWriteConf.java | 21 +
.../apache/iceberg/flink/FlinkWriteOptions.java | 14 +
.../org/apache/iceberg/flink/data/RowDataUtil.java | 18 -
.../apache/iceberg/flink/data/StructRowData.java | 4 +-
.../org/apache/iceberg/flink/sink/FlinkSink.java | 166 ++-
.../iceberg/flink/sink/FlinkWriteResult.java} | 22 +-
.../iceberg/flink/sink/IcebergFilesCommitter.java | 48 +-
.../iceberg/flink/sink/IcebergStreamWriter.java | 13 +-
.../flink/sink/ManifestOutputFileFactory.java | 2 +
.../sink/shuffle/AggregatedStatisticsTracker.java | 4 +-
.../sink/shuffle/DataStatisticsCoordinator.java | 27 +-
.../shuffle/DataStatisticsOperatorFactory.java | 98 ++
.../sink/shuffle/RequestGlobalStatisticsEvent.java | 4 +-
.../flink/sink/shuffle/SortKeySerializer.java | 7 +-
.../apache/iceberg/flink/source/DataIterator.java | 6 +-
.../apache/iceberg/flink/source/FlinkSource.java | 4 +-
.../apache/iceberg/flink/source/IcebergSource.java | 187 ++-
.../iceberg/flink/source/IcebergTableSource.java | 31 +-
.../iceberg/flink/source/RowDataRewriter.java | 6 -
.../enumerator/AbstractIcebergEnumerator.java | 6 +-
.../enumerator/ContinuousIcebergEnumerator.java | 1 +
.../source/reader/AvroGenericRecordConverter.java} | 49 +-
.../reader/AvroGenericRecordReaderFunction.java | 10 +-
.../source/reader/ConverterReaderFunction.java} | 66 +-
.../source/reader/IcebergSourceSplitReader.java | 2 +-
.../flink/source/reader/RecordAndPosition.java | 3 +-
.../flink/source/reader/RowDataConverter.java} | 16 +-
.../source/split/IcebergSourceSplitSerializer.java | 2 +
.../org/apache/iceberg/flink/CatalogTestBase.java | 22 -
.../java/org/apache/iceberg/flink/SqlBase.java | 0
.../java/org/apache/iceberg/flink/TestBase.java | 23 +-
.../apache/iceberg/flink/TestFlinkTableSink.java | 116 +-
.../iceberg/flink/TestFlinkTableSinkExtended.java | 92 ++
.../apache/iceberg/flink/TestIcebergConnector.java | 24 +-
.../flink/sink/TestCompressionSettings.java | 11 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 270 +---
.../flink/sink/TestFlinkIcebergSinkBase.java | 51 +-
.../sink/TestFlinkIcebergSinkDistributionMode.java | 494 +++++++
.../flink/sink/TestFlinkIcebergSinkExtended.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
.../flink/sink/TestIcebergFilesCommitter.java | 240 +++-
.../flink/sink/TestIcebergStreamWriter.java | 61 +-
.../sink/shuffle/TestMapRangePartitioner.java | 4 +-
.../flink/source/TestIcebergSourceBounded.java | 9 +-
.../TestIcebergSourceBoundedGenericRecord.java | 70 +-
.../flink/source/TestIcebergSourceBoundedSql.java | 2 +-
.../source/TestIcebergSourceInferParallelism.java | 181 +++
.../iceberg/flink/source/TestIcebergSourceSql.java | 7 +-
.../TestIcebergSpeculativeExecutionSupport.java | 17 +-
.../enumerator/TestContinuousSplitPlannerImpl.java | 4 +-
flink/v1.19/build.gradle | 1 +
.../sink/shuffle/MapRangePartitionerBenchmark.java | 13 +-
.../org/apache/iceberg/flink/FlinkConfParser.java | 27 +
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 4 +-
.../org/apache/iceberg/flink/FlinkWriteConf.java | 21 +
.../apache/iceberg/flink/FlinkWriteOptions.java | 14 +
.../org/apache/iceberg/flink/data/RowDataUtil.java | 18 -
.../apache/iceberg/flink/data/StructRowData.java | 4 +-
.../maintenance/operator/JdbcLockFactory.java | 323 +++++
.../flink/maintenance/operator/LockRemover.java | 144 ++
.../flink/maintenance/operator/MonitorSource.java | 4 +-
.../flink/maintenance/operator/TableChange.java | 198 ++-
.../operator/TableMaintenanceMetrics.java | 39 +
.../flink/maintenance/operator/TaskResult.java} | 47 +-
.../flink/maintenance/operator/Trigger.java | 72 +
.../maintenance/operator/TriggerEvaluator.java | 151 ++
.../maintenance/operator/TriggerLockFactory.java | 63 +
.../flink/maintenance/operator/TriggerManager.java | 341 +++++
.../iceberg/flink/sink/FlinkManifestUtil.java | 27 +
.../org/apache/iceberg/flink/sink/FlinkSink.java | 169 ++-
.../iceberg/flink/sink/FlinkWriteResult.java} | 22 +-
.../iceberg/flink/sink/IcebergCommittable.java | 95 ++
.../flink/sink/IcebergCommittableSerializer.java | 68 +
.../iceberg/flink/sink/IcebergCommitter.java | 311 +++++
.../iceberg/flink/sink/IcebergFilesCommitter.java | 99 +-
.../org/apache/iceberg/flink/sink/IcebergSink.java | 742 ++++++++++
.../iceberg/flink/sink/IcebergSinkWriter.java | 113 ++
.../iceberg/flink/sink/IcebergStreamWriter.java | 19 +-
.../iceberg/flink/sink/IcebergWriteAggregator.java | 127 ++
.../flink/sink/ManifestOutputFileFactory.java | 6 +-
.../org/apache/iceberg/flink/sink/SinkUtil.java | 94 ++
.../iceberg/flink/sink/WriteResultSerializer.java | 61 +
.../sink/shuffle/AggregatedStatisticsTracker.java | 4 +-
.../sink/shuffle/DataStatisticsCoordinator.java | 27 +-
.../shuffle/DataStatisticsOperatorFactory.java | 98 ++
.../sink/shuffle/RequestGlobalStatisticsEvent.java | 4 +-
.../flink/sink/shuffle/SortKeySerializer.java | 7 +-
.../apache/iceberg/flink/source/DataIterator.java | 6 +-
.../apache/iceberg/flink/source/FlinkSource.java | 4 +-
.../apache/iceberg/flink/source/IcebergSource.java | 187 ++-
.../iceberg/flink/source/IcebergTableSource.java | 31 +-
.../iceberg/flink/source/RowDataRewriter.java | 6 -
.../enumerator/AbstractIcebergEnumerator.java | 6 +-
.../enumerator/ContinuousIcebergEnumerator.java | 1 +
.../source/reader/AvroGenericRecordConverter.java} | 49 +-
.../reader/AvroGenericRecordReaderFunction.java | 10 +-
.../source/reader/ConverterReaderFunction.java} | 66 +-
.../source/reader/IcebergSourceSplitReader.java | 2 +-
.../flink/source/reader/RecordAndPosition.java | 3 +-
.../flink/source/reader/RowDataConverter.java} | 16 +-
.../source/split/IcebergSourceSplitSerializer.java | 2 +
.../iceberg/flink/TestFlinkTableSinkExtended.java | 92 ++
.../maintenance/operator/ConstantsForTests.java} | 14 +-
.../flink/maintenance/operator/ManualSource.java | 16 +-
.../operator/MetricsReporterFactoryForTests.java | 153 +++
.../maintenance/operator/OperatorTestBase.java | 107 +-
.../maintenance/operator/TestJdbcLockFactory.java | 57 +
.../maintenance/operator/TestLockFactoryBase.java | 80 ++
.../maintenance/operator/TestLockRemover.java | 378 +++++
.../maintenance/operator/TestMonitorSource.java | 41 +-
.../maintenance/operator/TestTriggerManager.java | 686 ++++++++++
.../apache/iceberg/flink/sink/SinkTestUtil.java | 62 +
.../flink/sink/TestCompressionSettings.java | 11 +-
.../sink/TestFlinkIcebergSinkDistributionMode.java | 314 +++++
...FlinkIcebergSinkRangeDistributionBucketing.java | 253 ++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 52 +-
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 2 +-
.../iceberg/flink/sink/TestFlinkManifest.java | 5 +-
.../iceberg/flink/sink/TestIcebergCommitter.java | 1445 ++++++++++++++++++++
.../flink/sink/TestIcebergFilesCommitter.java | 247 +++-
.../iceberg/flink/sink/TestIcebergSink.java} | 221 +--
.../iceberg/flink/sink/TestIcebergSinkBranch.java} | 27 +-
...nkIcebergSinkV2.java => TestIcebergSinkV2.java} | 60 +-
.../flink/sink/TestIcebergSinkV2Branch.java} | 10 +-
.../flink/sink/TestIcebergStreamWriter.java | 61 +-
.../sink/shuffle/TestMapRangePartitioner.java | 4 +-
.../flink/source/TestIcebergSourceBounded.java | 9 +-
.../TestIcebergSourceBoundedGenericRecord.java | 70 +-
.../flink/source/TestIcebergSourceBoundedSql.java | 2 +-
.../source/TestIcebergSourceInferParallelism.java | 181 +++
.../iceberg/flink/source/TestIcebergSourceSql.java | 7 +-
.../TestIcebergSpeculativeExecutionSupport.java | 14 +-
.../enumerator/TestContinuousSplitPlannerImpl.java | 4 +-
...e.flink.metrics.reporter.MetricReporterFactory} | 2 +-
flink/{v1.17 => v1.20}/build.gradle | 37 +-
flink/{v1.17 => v1.20}/flink-runtime/LICENSE | 0
flink/{v1.17 => v1.20}/flink-runtime/NOTICE | 0
.../iceberg/flink/IcebergConnectorSmokeTest.java | 0
.../sink/shuffle/MapRangePartitionerBenchmark.java | 3 +-
.../org/apache/iceberg/flink/CatalogLoader.java | 0
.../org/apache/iceberg/flink/FlinkCatalog.java | 0
.../apache/iceberg/flink/FlinkCatalogFactory.java | 0
.../org/apache/iceberg/flink/FlinkConfParser.java | 27 +
.../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 | 4 +-
.../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 | 21 +
.../apache/iceberg/flink/FlinkWriteOptions.java | 14 +
.../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 | 0
.../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 | 18 -
.../apache/iceberg/flink/data/StructRowData.java | 4 +-
.../maintenance/operator/JdbcLockFactory.java | 323 +++++
.../flink/maintenance/operator/LockRemover.java | 144 ++
.../flink/maintenance/operator/MonitorSource.java | 4 +-
.../operator/SingleThreadedIteratorSource.java | 0
.../flink/maintenance/operator/TableChange.java | 243 ++++
.../operator/TableMaintenanceMetrics.java | 39 +
.../flink/maintenance/operator/TaskResult.java} | 47 +-
.../flink/maintenance/operator/Trigger.java | 72 +
.../maintenance/operator/TriggerEvaluator.java | 151 ++
.../maintenance/operator/TriggerLockFactory.java | 63 +
.../flink/maintenance/operator/TriggerManager.java | 341 +++++
.../sink/AvroGenericRecordToRowDataMapper.java | 0
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 0
.../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 | 27 +
.../org/apache/iceberg/flink/sink/FlinkSink.java | 169 ++-
.../iceberg/flink/sink/FlinkWriteResult.java} | 22 +-
.../iceberg/flink/sink/IcebergCommittable.java | 95 ++
.../flink/sink/IcebergCommittableSerializer.java | 68 +
.../iceberg/flink/sink/IcebergCommitter.java | 312 +++++
.../iceberg/flink/sink/IcebergFilesCommitter.java | 101 +-
.../flink/sink/IcebergFilesCommitterMetrics.java | 0
.../org/apache/iceberg/flink/sink/IcebergSink.java | 742 ++++++++++
.../iceberg/flink/sink/IcebergSinkWriter.java | 113 ++
.../iceberg/flink/sink/IcebergStreamWriter.java | 19 +-
.../flink/sink/IcebergStreamWriterMetrics.java | 0
.../iceberg/flink/sink/IcebergWriteAggregator.java | 127 ++
.../flink/sink/ManifestOutputFileFactory.java | 6 +-
.../iceberg/flink/sink/PartitionKeySelector.java | 0
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 0
.../flink/sink/RowDataTaskWriterFactory.java | 0
.../org/apache/iceberg/flink/sink/SinkUtil.java | 94 ++
.../iceberg/flink/sink/TaskWriterFactory.java | 0
.../flink/sink/UnpartitionedDeltaWriter.java | 0
.../iceberg/flink/sink/WriteResultSerializer.java | 61 +
.../sink/shuffle/AggregatedStatisticsTracker.java | 4 +-
.../flink/sink/shuffle/CompletedStatistics.java | 0
.../shuffle/CompletedStatisticsSerializer.java | 0
.../iceberg/flink/sink/shuffle/DataStatistics.java | 0
.../sink/shuffle/DataStatisticsCoordinator.java | 27 +-
.../shuffle/DataStatisticsCoordinatorProvider.java | 0
.../flink/sink/shuffle/DataStatisticsOperator.java | 0
.../shuffle/DataStatisticsOperatorFactory.java | 98 ++
.../sink/shuffle/DataStatisticsSerializer.java | 0
.../flink/sink/shuffle/GlobalStatistics.java | 0
.../sink/shuffle/GlobalStatisticsSerializer.java | 0
.../iceberg/flink/sink/shuffle/KeyAssignment.java | 0
.../iceberg/flink/sink/shuffle/MapAssignment.java | 0
.../flink/sink/shuffle/MapDataStatistics.java | 0
.../flink/sink/shuffle/MapRangePartitioner.java | 0
.../flink/sink/shuffle/RangePartitioner.java | 0
.../sink/shuffle/RequestGlobalStatisticsEvent.java | 4 +-
.../flink/sink/shuffle/SketchDataStatistics.java | 0
.../flink/sink/shuffle/SketchRangePartitioner.java | 0
.../iceberg/flink/sink/shuffle/SketchUtil.java | 0
.../flink/sink/shuffle/SortKeySerializer.java | 33 +-
.../sink/shuffle/SortKeySketchSerializer.java | 0
.../iceberg/flink/sink/shuffle/SortKeyUtil.java | 0
.../flink/sink/shuffle/StatisticsEvent.java | 0
.../flink/sink/shuffle/StatisticsOrRecord.java | 0
.../sink/shuffle/StatisticsOrRecordSerializer.java | 0
.../iceberg/flink/sink/shuffle/StatisticsType.java | 0
.../iceberg/flink/sink/shuffle/StatisticsUtil.java | 0
.../AvroGenericRecordFileScanTaskReader.java | 0
.../apache/iceberg/flink/source/DataIterator.java | 6 +-
.../iceberg/flink/source/DataTaskReader.java | 0
.../iceberg/flink/source/FileScanTaskReader.java | 0
.../iceberg/flink/source/FlinkInputFormat.java | 2 +-
.../iceberg/flink/source/FlinkInputSplit.java | 0
.../apache/iceberg/flink/source/FlinkSource.java | 4 +-
.../iceberg/flink/source/FlinkSplitPlanner.java | 0
.../apache/iceberg/flink/source/IcebergSource.java | 189 ++-
.../iceberg/flink/source/IcebergTableSource.java | 31 +-
.../flink/source/RowDataFileScanTaskReader.java | 0
.../iceberg/flink/source/RowDataRewriter.java | 6 -
.../RowDataToAvroGenericRecordConverter.java | 0
.../apache/iceberg/flink/source/ScanContext.java | 0
.../apache/iceberg/flink/source/SourceUtil.java | 0
.../flink/source/StreamingMonitorFunction.java | 2 +-
.../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 | 16 +-
.../enumerator/ContinuousEnumerationResult.java | 0
.../enumerator/ContinuousIcebergEnumerator.java | 10 +
.../source/enumerator/ContinuousSplitPlanner.java | 0
.../enumerator/ContinuousSplitPlannerImpl.java | 2 +-
.../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
.../source/reader/AvroGenericRecordConverter.java} | 49 +-
.../reader/AvroGenericRecordReaderFunction.java | 10 +-
.../reader/ColumnStatsWatermarkExtractor.java | 0
.../source/reader/ConverterReaderFunction.java} | 66 +-
.../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 | 2 +-
.../flink/source/reader/LimitableDataIterator.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 | 3 +-
.../iceberg/flink/source/reader/RecordFactory.java | 0
.../iceberg/flink/source/reader/RecordLimiter.java | 0
.../flink/source/reader/RowDataConverter.java} | 16 +-
.../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 | 0
.../source/split/IcebergSourceSplitSerializer.java | 2 +
.../source/split/IcebergSourceSplitState.java | 0
.../source/split/IcebergSourceSplitStatus.java | 0
.../flink/source/split/SerializableComparator.java | 0
.../flink/source/split/SerializerHelper.java | 0
.../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 | 0
.../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
.../apache/iceberg/flink/HadoopTableExtension.java | 0
.../iceberg/flink/MiniFlinkClusterExtension.java | 0
.../org/apache/iceberg/flink/RowDataConverter.java | 0
.../org/apache/iceberg/flink/SimpleDataUtil.java | 0
.../java/org/apache/iceberg/flink/SqlBase.java | 0
.../java/org/apache/iceberg/flink/TestBase.java | 0
.../apache/iceberg/flink/TestCatalogLoader.java | 0
.../iceberg/flink/TestCatalogTableLoader.java | 0
.../apache/iceberg/flink/TestChangeLogTable.java | 0
.../iceberg/flink/TestDataFileSerialization.java | 0
.../org/apache/iceberg/flink/TestFixtures.java | 0
.../iceberg/flink/TestFlinkAnonymousTable.java | 0
.../iceberg/flink/TestFlinkCatalogDatabase.java | 0
.../iceberg/flink/TestFlinkCatalogFactory.java | 0
.../iceberg/flink/TestFlinkCatalogTable.java | 0
.../flink/TestFlinkCatalogTablePartitions.java | 0
.../apache/iceberg/flink/TestFlinkConfParser.java | 0
.../org/apache/iceberg/flink/TestFlinkFilters.java | 0
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 0
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 0
.../apache/iceberg/flink/TestFlinkTableSink.java | 0
.../iceberg/flink/TestFlinkTableSinkExtended.java | 92 ++
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 0
.../java/org/apache/iceberg/flink/TestHelpers.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 0
.../flink/TestManifestFileSerialization.java | 0
.../apache/iceberg/flink/TestRowDataWrapper.java | 0
.../org/apache/iceberg/flink/TestTableLoader.java | 0
.../iceberg/flink/TestTableSerialization.java | 0
.../flink/actions/TestRewriteDataFilesAction.java | 0
.../apache/iceberg/flink/data/RandomRowData.java | 0
.../iceberg/flink/data/RowDataToRowMapper.java | 0
.../flink/data/TestFlinkAvroReaderWriter.java | 0
.../flink/data/TestFlinkOrcReaderWriter.java | 0
.../iceberg/flink/data/TestFlinkParquetReader.java | 0
.../iceberg/flink/data/TestFlinkParquetWriter.java | 0
.../iceberg/flink/data/TestRowDataProjection.java | 0
.../iceberg/flink/data/TestRowProjection.java | 0
.../iceberg/flink/data/TestStructRowData.java | 0
.../flink/maintenance/operator/CollectingSink.java | 0
.../maintenance/operator/ConstantsForTests.java} | 14 +-
.../maintenance/operator/FlinkSqlExtension.java | 0
.../operator/FlinkStreamingTestUtils.java | 0
.../flink/maintenance/operator/ManualSource.java | 16 +-
.../operator/MetricsReporterFactoryForTests.java | 153 +++
.../maintenance/operator/OperatorTestBase.java | 156 +++
.../maintenance/operator/TestJdbcLockFactory.java | 57 +
.../maintenance/operator/TestLockFactoryBase.java | 80 ++
.../maintenance/operator/TestLockRemover.java | 378 +++++
.../maintenance/operator/TestMonitorSource.java | 41 +-
.../maintenance/operator/TestTriggerManager.java | 686 ++++++++++
.../apache/iceberg/flink/sink/SinkTestUtil.java | 62 +
.../sink/TestAvroGenericRecordToRowDataMapper.java | 0
.../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 | 11 +-
.../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
.../sink/TestFlinkIcebergSinkDistributionMode.java | 494 +++++++
.../flink/sink/TestFlinkIcebergSinkExtended.java | 0
...FlinkIcebergSinkRangeDistributionBucketing.java | 253 ++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 21 +-
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 52 +-
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 2 +-
.../iceberg/flink/sink/TestFlinkManifest.java | 5 +-
.../flink/sink/TestFlinkPartitioningWriters.java | 0
.../flink/sink/TestFlinkPositionDeltaWriters.java | 0
.../flink/sink/TestFlinkRollingFileWriters.java | 0
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 0
.../iceberg/flink/sink/TestIcebergCommitter.java | 1445 ++++++++++++++++++++
.../flink/sink/TestIcebergFilesCommitter.java | 247 +++-
.../iceberg/flink/sink/TestIcebergSink.java} | 221 +--
.../iceberg/flink/sink/TestIcebergSinkBranch.java} | 27 +-
.../iceberg/flink/sink/TestIcebergSinkV2.java} | 60 +-
.../flink/sink/TestIcebergSinkV2Branch.java} | 10 +-
.../flink/sink/TestIcebergStreamWriter.java | 61 +-
.../flink/sink/TestRowDataPartitionKey.java | 0
.../apache/iceberg/flink/sink/TestTaskWriters.java | 0
.../iceberg/flink/sink/shuffle/Fixtures.java | 0
.../shuffle/TestAggregatedStatisticsTracker.java | 0
.../shuffle/TestCompletedStatisticsSerializer.java | 0
.../shuffle/TestDataStatisticsCoordinator.java | 0
.../TestDataStatisticsCoordinatorProvider.java | 0
.../sink/shuffle/TestDataStatisticsOperator.java | 0
.../sink/shuffle/TestDataStatisticsSerializer.java | 0
.../shuffle/TestGlobalStatisticsSerializer.java | 0
.../flink/sink/shuffle/TestMapDataStatistics.java | 0
.../sink/shuffle/TestMapRangePartitioner.java | 4 +-
.../flink/sink/shuffle/TestRangePartitioner.java | 0
.../sink/shuffle/TestSketchDataStatistics.java | 0
.../sink/shuffle/TestSketchRangePartitioner.java | 0
.../iceberg/flink/sink/shuffle/TestSketchUtil.java | 0
.../sink/shuffle/TestSortKeySerializerBase.java | 0
.../shuffle/TestSortKeySerializerNestedStruct.java | 0
.../shuffle/TestSortKeySerializerPrimitives.java | 0
.../shuffle/TestSortKeySerializerSnapshot.java | 0
.../flink/sink/shuffle/TestSortKeyUtil.java | 0
.../iceberg/flink/source/BoundedTableFactory.java | 0
.../iceberg/flink/source/BoundedTestSource.java | 0
.../flink/source/ChangeLogTableTestBase.java | 0
.../apache/iceberg/flink/source/SplitHelpers.java | 0
.../apache/iceberg/flink/source/SqlHelpers.java | 0
.../iceberg/flink/source/TableSourceTestBase.java | 0
.../flink/source/TestBoundedTableFactory.java | 0
.../iceberg/flink/source/TestFlinkInputFormat.java | 0
.../source/TestFlinkInputFormatReaderDeletes.java | 0
.../flink/source/TestFlinkMergingMetrics.java | 0
.../flink/source/TestFlinkMetaDataTable.java | 0
.../flink/source/TestFlinkReaderDeletesBase.java | 0
.../apache/iceberg/flink/source/TestFlinkScan.java | 0
.../iceberg/flink/source/TestFlinkScanSql.java | 0
.../iceberg/flink/source/TestFlinkSource.java | 0
.../flink/source/TestFlinkSourceConfig.java | 0
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../iceberg/flink/source/TestFlinkTableSource.java | 0
.../flink/source/TestIcebergSourceBounded.java | 9 +-
.../TestIcebergSourceBoundedGenericRecord.java | 70 +-
.../flink/source/TestIcebergSourceBoundedSql.java | 2 +-
.../flink/source/TestIcebergSourceContinuous.java | 0
.../flink/source/TestIcebergSourceFailover.java | 0
...cebergSourceFailoverWithWatermarkExtractor.java | 0
.../source/TestIcebergSourceInferParallelism.java | 181 +++
.../source/TestIcebergSourceReaderDeletes.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 7 +-
.../TestIcebergSourceWithWatermarkExtractor.java | 0
.../TestIcebergSpeculativeExecutionSupport.java | 24 +-
.../source/TestMetadataTableReadableMetrics.java | 0
.../flink/source/TestProjectMetaColumn.java | 0
.../TestRowDataToAvroGenericRecordConverter.java | 0
.../iceberg/flink/source/TestScanContext.java | 0
.../iceberg/flink/source/TestSourceUtil.java | 0
.../apache/iceberg/flink/source/TestSqlBase.java | 0
.../iceberg/flink/source/TestStreamScanSql.java | 0
.../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 | 4 +-
...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/TestLimitableDataIterator.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 0
.../iceberg/flink/util/TestFlinkPackage.java | 2 +-
...e.flink.metrics.reporter.MetricReporterFactory} | 2 +-
.../org.apache.flink.table.factories.Factory | 0
format/puffin-spec.md | 4 +-
format/spec.md | 214 ++-
.../java/org/apache/iceberg/gcp/GCPProperties.java | 1 +
.../org/apache/iceberg/gcp/gcs/GCSInputStream.java | 2 +-
.../apache/iceberg/gcp/gcs/GCSOutputStream.java | 2 +-
gradle.properties | 6 +-
gradle/libs.versions.toml | 79 +-
gradle/wrapper/gradle-wrapper.properties | 4 +-
gradlew | 2 +-
.../java/org/apache/iceberg/hive/HiveCatalog.java | 224 ++-
.../apache/iceberg/hive/HiveOperationsBase.java | 23 +-
.../apache/iceberg/hive/HiveTableOperations.java | 6 +-
.../apache/iceberg/hive/HiveViewOperations.java | 389 ++++++
.../org/apache/iceberg/hive/TestHiveCatalog.java | 15 +
.../apache/iceberg/hive/TestHiveViewCatalog.java | 323 +++++
.../apache/iceberg/hive/TestHiveViewCommits.java | 516 +++++++
.../org/apache/hadoop/hive/ql/io/orc/OrcSplit.java | 1 +
jmh.gradle | 12 +-
kafka-connect/build.gradle | 10 +-
.../iceberg/connect/IntegrationTestBase.java | 18 +-
.../apache/iceberg/connect/KafkaConnectUtils.java | 16 +-
.../org/apache/iceberg/connect/TestContext.java | 12 +-
.../iceberg/connect/channel/Coordinator.java | 21 +-
.../iceberg/connect/channel/CoordinatorThread.java | 10 +-
.../apache/iceberg/connect/data/IcebergWriter.java | 6 +-
.../iceberg/connect/data/RecordConverter.java | 12 +-
.../apache/iceberg/connect/data/SinkWriter.java | 3 +-
.../iceberg/connect/channel/CoordinatorTest.java | 46 +-
.../main/java/org/apache/iceberg/mr/Catalogs.java | 10 +-
.../iceberg/mr/hive/HiveIcebergMetaHook.java | 4 +-
.../mr/hive/HiveIcebergOutputCommitter.java | 1 +
.../iceberg/mr/mapreduce/IcebergInputFormat.java | 2 +-
.../apache/iceberg/mr/TestIcebergInputFormats.java | 6 +-
.../apache/iceberg/nessie/NessieIcebergClient.java | 4 +-
open-api/README.md | 63 +
open-api/requirements.txt | 2 +-
open-api/rest-catalog-open-api.py | 212 ++-
open-api/rest-catalog-open-api.yaml | 1059 +++++++++++---
.../rest/RESTCompatibilityKitCatalogTests.java | 87 ++
.../iceberg/rest/RESTCompatibilityKitSuite.java | 45 +
.../rest/RESTCompatibilityKitViewCatalogTests.java | 91 ++
.../java/org/apache/iceberg/rest/RCKUtils.java | 110 ++
.../org/apache/iceberg/rest/RESTCatalogServer.java | 123 ++
.../iceberg/rest/RESTServerCatalogAdapter.java | 85 ++
.../apache/iceberg/rest/RESTServerExtension.java | 46 +-
orc/src/main/java/org/apache/iceberg/orc/ORC.java | 4 +-
.../java/org/apache/iceberg/orc/ORCSchemaUtil.java | 8 +-
.../org/apache/iceberg/orc/OrcFileAppender.java | 3 +
.../org/apache/iceberg/parquet/PageIterator.java | 15 +-
.../java/org/apache/iceberg/parquet/Parquet.java | 8 +-
.../apache/iceberg/parquet/ParquetSchemaUtil.java | 4 +-
.../org/apache/iceberg/parquet/PruneColumns.java | 16 +-
.../org/apache/iceberg/pig/PigParquetReader.java | 11 +-
settings.gradle | 52 +-
site/README.md | 10 +
site/dev/common.sh | 9 +-
site/docs/blogs.md | 24 +
site/docs/contribute.md | 40 +
site/docs/hive-quickstart.md | 5 +-
site/docs/multi-engine-support.md | 3 +-
site/docs/releases.md | 4 +-
site/docs/spark-quickstart.md | 4 +-
site/mkdocs.yml | 4 +-
site/nav.yml | 5 +-
site/overrides/home.html | 4 +-
site/overrides/partials/header.html | 7 +-
site/requirements.txt | 4 +-
.../apache/iceberg/snowflake/NamespaceHelpers.java | 5 +-
.../apache/iceberg/snowflake/SnowflakeCatalog.java | 1 +
.../spark/extensions/TestAddFilesProcedure.java | 22 +
.../TestRollbackToTimestampProcedure.java | 35 +
.../extensions/TestSnapshotTableProcedure.java | 1 +
.../java/org/apache/iceberg/spark/SmokeTest.java | 2 +-
.../spark/action/DeleteOrphanFilesBenchmark.java | 3 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 220 ++-
.../spark/actions/MigrateTableSparkAction.java | 11 +-
.../spark/actions/SnapshotTableSparkAction.java | 11 +-
.../spark/procedures/AddFilesProcedure.java | 54 +-
.../spark/procedures/MigrateTableProcedure.java | 17 +-
.../iceberg/spark/procedures/ProcedureInput.java | 12 +
.../spark/procedures/SnapshotTableProcedure.java | 9 +-
.../iceberg/spark/source/SparkAppenderFactory.java | 4 +
.../iceberg/spark/actions/TestCreateActions.java | 15 +
.../spark/actions/TestMigrateTableAction.java | 70 +
.../spark/actions/TestSnapshotTableAction.java | 69 +
.../spark/source/TestIcebergSourceTablesBase.java | 9 +-
spark/v3.4/build.gradle | 2 +
.../spark/extensions/TestAddFilesProcedure.java | 22 +
.../TestRollbackToTimestampProcedure.java | 35 +
.../extensions/TestSnapshotTableProcedure.java | 1 +
.../java/org/apache/iceberg/spark/SmokeTest.java | 2 +-
.../spark/action/DeleteOrphanFilesBenchmark.java | 3 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 237 +++-
.../actions/ComputeTableStatsSparkAction.java | 179 +++
.../spark/actions/MigrateTableSparkAction.java | 11 +-
.../iceberg/spark/actions/NDVSketchUtil.java | 89 ++
.../spark/actions/SnapshotTableSparkAction.java | 11 +-
.../apache/iceberg/spark/actions/SparkActions.java | 6 +
.../spark/procedures/AddFilesProcedure.java | 54 +-
.../spark/procedures/MigrateTableProcedure.java | 10 +-
.../iceberg/spark/procedures/ProcedureInput.java | 12 +
.../spark/procedures/SnapshotTableProcedure.java | 9 +-
.../iceberg/spark/source/SparkAppenderFactory.java | 4 +
.../apache/spark/sql/stats/ThetaSketchAgg.scala | 121 ++
.../spark/actions/TestComputeTableStatsAction.java | 429 ++++++
.../iceberg/spark/actions/TestCreateActions.java | 15 +
.../spark/actions/TestMigrateTableAction.java | 70 +
.../spark/actions/TestSnapshotTableAction.java | 69 +
.../spark/source/TestIcebergSourceTablesBase.java | 9 +-
spark/v3.5/build.gradle | 2 +
.../apache/iceberg/spark/PlanningBenchmark.java | 118 +-
.../TestCreateChangelogViewProcedure.java | 14 +
.../TestRollbackToTimestampProcedure.java | 35 +
.../extensions/TestSnapshotTableProcedure.java | 1 +
.../java/org/apache/iceberg/spark/SmokeTest.java | 2 +-
.../spark/action/DeleteOrphanFilesBenchmark.java | 3 +-
.../apache/iceberg/spark/SparkSQLProperties.java | 4 +
.../org/apache/iceberg/spark/SparkTableUtil.java | 31 +-
.../org/apache/iceberg/spark/SparkWriteConf.java | 3 +-
.../apache/iceberg/spark/SparkWriteOptions.java | 1 -
.../actions/ComputeTableStatsSparkAction.java | 179 +++
.../iceberg/spark/actions/NDVSketchUtil.java | 89 ++
.../apache/iceberg/spark/actions/SparkActions.java | 6 +
.../procedures/CreateChangelogViewProcedure.java | 15 +-
.../iceberg/spark/source/SparkAppenderFactory.java | 4 +
.../apache/spark/sql/stats/ThetaSketchAgg.scala | 121 ++
.../spark/actions/TestComputeTableStatsAction.java | 406 ++++++
.../iceberg/spark/actions/TestCreateActions.java | 15 +
.../spark/source/TestDataFrameWriterV2.java | 35 +
.../spark/source/TestIcebergSourceTablesBase.java | 9 +-
946 files changed, 37004 insertions(+), 14848 deletions(-)
copy .github/workflows/{flink-ci.yml => kafka-connect-ci.yml} (82%)
create mode 100644
api/src/main/java/org/apache/iceberg/actions/ComputeTableStats.java
copy
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
=>
api/src/main/java/org/apache/iceberg/exceptions/NoSuchIcebergViewException.java
(60%)
copy
api/src/main/java/org/apache/iceberg/io/{BulkDeletionFailureException.java =>
SupportsRecoveryOperations.java} (57%)
create mode 100644 api/src/main/java/org/apache/iceberg/util/DataFileSet.java
create mode 100644 api/src/main/java/org/apache/iceberg/util/DeleteFileSet.java
create mode 100644 api/src/main/java/org/apache/iceberg/util/WrapperSet.java
create mode 100644
api/src/test/java/org/apache/iceberg/TestSchemaCaseSensitivity.java
create mode 100644
api/src/test/java/org/apache/iceberg/expressions/TestTimestampLiteralConversions.java
create mode 100644
api/src/test/java/org/apache/iceberg/transforms/TestTimeTransforms.java
create mode 100644
aws/src/test/java/org/apache/iceberg/aws/s3/TestFlakyS3InputStream.java
create mode 100644 core/src/jmh/java/org/apache/iceberg/AppendBenchmark.java
copy core/src/jmh/java/org/apache/iceberg/{ManifestReadBenchmark.java =>
ManifestWriteBenchmark.java} (70%)
create mode 100644
core/src/jmh/java/org/apache/iceberg/PartitionStatsUtilBenchmark.java
create mode 100644
core/src/jmh/java/org/apache/iceberg/ReplaceDeleteFilesBenchmark.java
create mode 100644
core/src/main/java/org/apache/iceberg/AllManifestsTableTaskParser.java
create mode 100644
core/src/main/java/org/apache/iceberg/FilesTableTaskParser.java
create mode 100644
core/src/main/java/org/apache/iceberg/ManifestEntriesTableTaskParser.java
create mode 100644
core/src/main/java/org/apache/iceberg/ManifestFileParser.java
create mode 100644 core/src/main/java/org/apache/iceberg/PartitionStats.java
create mode 100644
core/src/main/java/org/apache/iceberg/PartitionStatsUtil.java
copy
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
=> core/src/main/java/org/apache/iceberg/actions/BaseComputeTableStats.java
(60%)
create mode 100644
core/src/main/java/org/apache/iceberg/avro/InternalReader.java
create mode 100644
core/src/main/java/org/apache/iceberg/avro/InternalReaders.java
create mode 100644
core/src/main/java/org/apache/iceberg/avro/SupportsIndexProjection.java
create mode 100644 core/src/main/java/org/apache/iceberg/io/FileIOTracker.java
create mode 100644 core/src/main/java/org/apache/iceberg/rest/Endpoint.java
create mode 100644
core/src/main/java/org/apache/iceberg/rest/responses/LoadTableResponseParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestAllManifestsTableTaskParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestFileGenerationUtil.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestFilesTableTaskParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestManifestFileParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestPartitionSpecBuilderCaseSensitivity.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestPartitionStatsUtil.java
create mode 100644
core/src/test/java/org/apache/iceberg/TestSnapshotProducer.java
create mode 100644
core/src/test/java/org/apache/iceberg/avro/TestReadDefaultValues.java
create mode 100644
core/src/test/java/org/apache/iceberg/deletes/TestBitmapPositionDeleteIndex.java
create mode 100644
core/src/test/java/org/apache/iceberg/io/TestFileIOTracker.java
create mode 100644 core/src/test/java/org/apache/iceberg/rest/TestEndpoint.java
create mode 100644
core/src/test/java/org/apache/iceberg/rest/TestRESTViewCatalogWithAssumedViewSupport.java
create mode 100644
core/src/test/java/org/apache/iceberg/rest/responses/TestLoadTableResponseParser.java
create mode 100644
core/src/test/java/org/apache/iceberg/util/TestDataFileSet.java
create mode 100644
core/src/test/java/org/apache/iceberg/util/TestDeleteFileSet.java
create mode 100644 docs/docs/kafka-connect.md
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/CatalogTestBase.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestBase.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsOperator.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TableSourceTestBase.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestMetadataTableReadableMetrics.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
delete mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
=>
v1.18/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java}
(63%)
create mode 100644
flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
=>
v1.18/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java}
(62%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
=>
v1.18/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java}
(67%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
=>
v1.18/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java}
(72%)
copy flink/{v1.19 =>
v1.18}/flink/src/test/java/org/apache/iceberg/flink/SqlBase.java (100%)
copy flink/{v1.19 =>
v1.18}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSinkExtended.java
(70%)
create mode 100644
flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkDistributionMode.java
copy flink/{v1.19 =>
v1.18}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkExtended.java
(100%)
create mode 100644
flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceInferParallelism.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/JdbcLockFactory.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
=>
v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResult.java}
(51%)
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/Trigger.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerLockFactory.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
=>
v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java}
(63%)
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java
create mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
=>
v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java}
(62%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
=>
v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java}
(67%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
=>
v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java}
(72%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
=>
v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ConstantsForTests.java}
(74%)
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/MetricsReporterFactoryForTests.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestJdbcLockFactory.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockFactoryBase.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemover.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/SinkTestUtil.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergCommitter.java
rename
flink/{v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
=>
v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java}
(65%)
copy
flink/{v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
=>
v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkBranch.java}
(83%)
copy
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/{TestFlinkIcebergSinkV2.java
=> TestIcebergSinkV2.java} (81%)
copy
flink/{v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
=>
v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2Branch.java}
(89%)
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceInferParallelism.java
copy
flink/{v1.17/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
=>
v1.19/flink/src/test/resources/META-INF/services/org.apache.flink.metrics.reporter.MetricReporterFactory}
(91%)
rename flink/{v1.17 => v1.20}/build.gradle (91%)
rename flink/{v1.17 => v1.20}/flink-runtime/LICENSE (100%)
rename flink/{v1.17 => v1.20}/flink-runtime/NOTICE (100%)
rename flink/{v1.17 =>
v1.20}/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java
(98%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java (100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (91%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java (99%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (89%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java (82%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java (84%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java
(98%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/JdbcLockFactory.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java
(98%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
=>
v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResult.java}
(51%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/Trigger.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerLockFactory.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java
(82%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (77%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
=>
v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java}
(63%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
(87%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
(88%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
(93%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
(96%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java
(100%)
create mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatistics.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/KeyAssignment.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapAssignment.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RangePartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RequestGlobalStatisticsEvent.java
(93%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchDataStatistics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java
(91%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySketchSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeyUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsEvent.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecord.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsType.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java
(96%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java
(97%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java
(77%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
(89%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
(96%)
copy flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
(92%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
(94%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java
(100%)
rename
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
=>
v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java}
(62%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
(92%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
(100%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
=>
v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java}
(67%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
(98%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/LimitableDataIterator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java
(95%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordLimiter.java
(100%)
copy
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
=>
v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java}
(72%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java
(97%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
(100%)
copy flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
copy flink/{v1.17 =>
v1.20}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/CatalogTestBase.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/DataGenerator.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogExtension.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/HadoopTableExtension.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/SqlBase.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestBase.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogLoader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkAnonymousTable.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSinkExtended.java
(70%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java
(100%)
copy flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/data/TestStructRowData.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java
(100%)
rename
flink/{v1.17/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
=>
v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ConstantsForTests.java}
(74%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkStreamingTestUtils.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java
(96%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/MetricsReporterFactoryForTests.java
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestJdbcLockFactory.java
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockFactoryBase.java
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemover.java
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java
(92%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/SinkTestUtil.java
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestAvroGenericRecordToRowDataMapper.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionKeySelector.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerFlinkIcebergSink.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java
(96%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkAppenderFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
(100%)
copy flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
(100%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkDistributionMode.java
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkExtended.java
(100%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
(90%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
(90%)
copy flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
(98%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
(98%)
copy flink/{v1.18 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java
(100%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergCommitter.java
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
(82%)
copy
flink/{v1.18/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
=>
v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java}
(65%)
rename
flink/{v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
=>
v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkBranch.java}
(83%)
copy
flink/{v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
=>
v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2.java}
(81%)
rename
flink/{v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
=>
v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2Branch.java}
(89%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
(85%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/Fixtures.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatisticsTracker.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestCompletedStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinatorProvider.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsOperator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestGlobalStatisticsSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapDataStatistics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapRangePartitioner.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestRangePartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchDataStatistics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchRangePartitioner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSketchUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerNestedStruct.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerPrimitives.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeyUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TableSourceTestBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceConfig.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java
(94%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedGenericRecord.java
(83%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
(96%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
(100%)
create mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceInferParallelism.java
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
(93%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpeculativeExecutionSupport.java
(88%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestMetadataTableReadableMetrics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestRowDataToAvroGenericRecordConverter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestScanContext.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/SplitAssignerTestBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestDefaultSplitAssigner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestFileSequenceNumberBasedSplitAssigner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
(99%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestEnumerationHistory.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestLimitableDataIterator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java
(97%)
rename
flink/{v1.17/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
=>
v1.20/flink/src/test/resources/META-INF/services/org.apache.flink.metrics.reporter.MetricReporterFactory}
(91%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
create mode 100644
hive-metastore/src/main/java/org/apache/iceberg/hive/HiveViewOperations.java
create mode 100644
hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveViewCatalog.java
create mode 100644
hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveViewCommits.java
create mode 100644
open-api/src/test/java/org/apache/iceberg/rest/RESTCompatibilityKitCatalogTests.java
create mode 100644
open-api/src/test/java/org/apache/iceberg/rest/RESTCompatibilityKitSuite.java
create mode 100644
open-api/src/test/java/org/apache/iceberg/rest/RESTCompatibilityKitViewCatalogTests.java
create mode 100644
open-api/src/testFixtures/java/org/apache/iceberg/rest/RCKUtils.java
create mode 100644
open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTCatalogServer.java
create mode 100644
open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTServerCatalogAdapter.java
rename
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java
=>
open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTServerExtension.java
(52%)
create mode 100644
spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/actions/TestMigrateTableAction.java
create mode 100644
spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/actions/TestSnapshotTableAction.java
create mode 100644
spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/ComputeTableStatsSparkAction.java
create mode 100644
spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/NDVSketchUtil.java
create mode 100644
spark/v3.4/spark/src/main/scala/org/apache/spark/sql/stats/ThetaSketchAgg.scala
create mode 100644
spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/actions/TestComputeTableStatsAction.java
create mode 100644
spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/actions/TestMigrateTableAction.java
create mode 100644
spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/actions/TestSnapshotTableAction.java
create mode 100644
spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/ComputeTableStatsSparkAction.java
create mode 100644
spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/NDVSketchUtil.java
create mode 100644
spark/v3.5/spark/src/main/scala/org/apache/spark/sql/stats/ThetaSketchAgg.scala
create mode 100644
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/actions/TestComputeTableStatsAction.java
