This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/com.azure-azure-sdk-bom-1.2.26
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard 21bf279e1c Build: Bump com.azure:azure-sdk-bom from 1.2.25 to 1.2.26
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 f701e9076d Build: Bump com.azure:azure-sdk-bom from 1.2.25 to 1.2.26
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 (21bf279e1c)
\
N -- N -- N
refs/heads/dependabot/gradle/com.azure-azure-sdk-bom-1.2.26 (f701e9076d)
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 | 3 +
.github/workflows/flink-ci.yml | 9 +-
.palantir/revapi.yml | 75 ++
.../aliyun/oss/mock/AliyunOSSMockLocalStore.java | 18 +-
...FileIO.java => SupportsRecoveryOperations.java} | 17 +-
.../java/org/apache/iceberg/types/Comparators.java | 41 +
.../org/apache/iceberg/aws/AwsIntegTestUtil.java | 62 +-
.../iceberg/aws/s3/TestS3FileIOIntegration.java | 38 +
.../java/org/apache/iceberg/aws/s3/S3FileIO.java | 50 +-
.../iceberg/aws/s3/signer/S3SignerServlet.java | 4 +-
.../iceberg/aws/s3/signer/TestS3RestSigner.java | 8 +-
baseline.gradle | 3 +-
.../org/apache/iceberg/common/DynConstructors.java | 18 +-
.../java/org/apache/iceberg/common/DynFields.java | 15 -
.../java/org/apache/iceberg/common/DynMethods.java | 38 +-
.../java/org/apache/iceberg/BaseEntriesTable.java | 2 +-
.../iceberg/BaseMetastoreTableOperations.java | 11 -
.../org/apache/iceberg/FileScanTaskParser.java | 29 -
.../java/org/apache/iceberg/SnapshotProducer.java | 12 -
.../iceberg/actions/SizeBasedFileRewriter.java | 3 +-
.../java/org/apache/iceberg/deletes/Deletes.java | 31 +-
.../java/org/apache/iceberg/io/ContentCache.java | 25 +-
.../rest/ExponentialHttpRequestRetryStrategy.java | 2 +-
.../apache/iceberg/rest/RESTSessionCatalog.java | 2 +-
.../java/org/apache/iceberg/rest/RESTUtil.java | 16 +-
.../org/apache/iceberg/rest/auth/OAuth2Util.java | 20 -
.../main/java/org/apache/iceberg/util/Pair.java | 5 -
.../org/apache/iceberg/util/ParallelIterable.java | 1 +
.../main/java/org/apache/iceberg/util/Tasks.java | 4 +-
.../apache/iceberg/view/BaseViewOperations.java | 1 +
.../org/apache/iceberg/TestFileScanTaskParser.java | 30 -
.../apache/iceberg/rest/RESTCatalogAdapter.java | 6 +-
dev/stage-binaries.sh | 2 +-
docs/docs/aws.md | 4 +-
docs/docs/branching.md | 2 +-
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 -----
.../flink/sink/shuffle/SortKeySerializer.java | 373 ---------
.../sink/shuffle/StatisticsOrRecordSerializer.java | 210 ------
.../source/assigner/DefaultSplitAssigner.java | 112 ---
.../flink/source/assigner/SplitAssigner.java | 118 ---
.../enumerator/AbstractIcebergEnumerator.java | 182 -----
.../enumerator/ContinuousIcebergEnumerator.java | 178 -----
.../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 ---------------
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 385 ----------
.../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 -----
.../org/apache/iceberg/flink/data/RowDataUtil.java | 18 -
.../sink/shuffle/MapRangePartitionerBenchmark.java | 10 +-
.../org/apache/iceberg/flink/data/RowDataUtil.java | 18 -
flink/{v1.17 => v1.20}/build.gradle | 36 +-
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 | 0
.../apache/iceberg/flink/FlinkConfigOptions.java | 0
.../iceberg/flink/FlinkDynamicTableFactory.java | 0
.../iceberg/flink/FlinkEnvironmentContext.java | 0
.../org/apache/iceberg/flink/FlinkFilters.java | 0
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 0
.../org/apache/iceberg/flink/FlinkReadConf.java | 0
.../org/apache/iceberg/flink/FlinkReadOptions.java | 0
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 0
.../apache/iceberg/flink/FlinkSourceFilter.java | 0
.../org/apache/iceberg/flink/FlinkTypeToType.java | 0
.../org/apache/iceberg/flink/FlinkTypeVisitor.java | 0
.../org/apache/iceberg/flink/FlinkWriteConf.java | 0
.../apache/iceberg/flink/FlinkWriteOptions.java | 0
.../org/apache/iceberg/flink/IcebergTableSink.java | 0
.../org/apache/iceberg/flink/RowDataWrapper.java | 0
.../java/org/apache/iceberg/flink/TableLoader.java | 0
.../org/apache/iceberg/flink/TypeToFlinkType.java | 0
.../org/apache/iceberg/flink/actions/Actions.java | 0
.../flink/actions/RewriteDataFilesAction.java | 0
.../flink/data/AvroWithFlinkSchemaVisitor.java | 0
.../apache/iceberg/flink/data/FlinkAvroReader.java | 0
.../apache/iceberg/flink/data/FlinkAvroWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcReader.java | 0
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 0
.../iceberg/flink/data/FlinkParquetReaders.java | 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 | 0
.../flink/maintenance/operator/MonitorSource.java | 0
.../operator/SingleThreadedIteratorSource.java | 0
.../flink/maintenance/operator/TableChange.java | 0
.../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 | 0
.../org/apache/iceberg/flink/sink/FlinkSink.java | 0
.../iceberg/flink/sink/IcebergFilesCommitter.java | 0
.../flink/sink/IcebergFilesCommitterMetrics.java | 0
.../iceberg/flink/sink/IcebergStreamWriter.java | 0
.../flink/sink/IcebergStreamWriterMetrics.java | 0
.../flink/sink/ManifestOutputFileFactory.java | 0
.../iceberg/flink/sink/PartitionKeySelector.java | 0
.../iceberg/flink/sink/PartitionedDeltaWriter.java | 0
.../flink/sink/RowDataTaskWriterFactory.java | 0
.../iceberg/flink/sink/TaskWriterFactory.java | 0
.../flink/sink/UnpartitionedDeltaWriter.java | 0
.../sink/shuffle/AggregatedStatisticsTracker.java | 0
.../flink/sink/shuffle/CompletedStatistics.java | 0
.../shuffle/CompletedStatisticsSerializer.java | 0
.../iceberg/flink/sink/shuffle/DataStatistics.java | 0
.../sink/shuffle/DataStatisticsCoordinator.java | 0
.../shuffle/DataStatisticsCoordinatorProvider.java | 0
.../flink/sink/shuffle/DataStatisticsOperator.java | 0
.../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 | 0
.../flink/sink/shuffle/SketchDataStatistics.java | 0
.../flink/sink/shuffle/SketchRangePartitioner.java | 0
.../iceberg/flink/sink/shuffle/SketchUtil.java | 0
.../flink/sink/shuffle/SortKeySerializer.java | 0
.../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 | 0
.../iceberg/flink/source/DataTaskReader.java | 0
.../iceberg/flink/source/FileScanTaskReader.java | 0
.../iceberg/flink/source/FlinkInputFormat.java | 0
.../iceberg/flink/source/FlinkInputSplit.java | 0
.../apache/iceberg/flink/source/FlinkSource.java | 0
.../iceberg/flink/source/FlinkSplitPlanner.java | 0
.../apache/iceberg/flink/source/IcebergSource.java | 0
.../iceberg/flink/source/IcebergTableSource.java | 0
.../flink/source/RowDataFileScanTaskReader.java | 0
.../iceberg/flink/source/RowDataRewriter.java | 0
.../RowDataToAvroGenericRecordConverter.java | 0
.../apache/iceberg/flink/source/ScanContext.java | 0
.../apache/iceberg/flink/source/SourceUtil.java | 0
.../flink/source/StreamingMonitorFunction.java | 0
.../flink/source/StreamingReaderOperator.java | 0
.../flink/source/StreamingStartingStrategy.java | 0
.../source/assigner/DefaultSplitAssigner.java | 0
.../flink/source/assigner/GetSplitResult.java | 0
.../assigner/OrderedSplitAssignerFactory.java | 0
.../assigner/SimpleSplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssigner.java | 0
.../source/assigner/SplitAssignerFactory.java | 0
.../flink/source/assigner/SplitAssignerType.java | 0
.../enumerator/AbstractIcebergEnumerator.java | 0
.../enumerator/ContinuousEnumerationResult.java | 0
.../enumerator/ContinuousIcebergEnumerator.java | 0
.../source/enumerator/ContinuousSplitPlanner.java | 0
.../enumerator/ContinuousSplitPlannerImpl.java | 0
.../source/enumerator/EnumerationHistory.java | 0
.../enumerator/IcebergEnumeratorPosition.java | 0
.../IcebergEnumeratorPositionSerializer.java | 0
.../source/enumerator/IcebergEnumeratorState.java | 0
.../IcebergEnumeratorStateSerializer.java | 0
.../source/enumerator/StaticIcebergEnumerator.java | 0
.../flink/source/reader/ArrayBatchRecords.java | 0
.../reader/ArrayPoolDataIteratorBatcher.java | 0
.../reader/AvroGenericRecordReaderFunction.java | 0
.../reader/ColumnStatsWatermarkExtractor.java | 0
.../flink/source/reader/DataIteratorBatcher.java | 0
.../source/reader/DataIteratorReaderFunction.java | 0
.../flink/source/reader/IcebergSourceReader.java | 0
.../source/reader/IcebergSourceReaderMetrics.java | 0
.../source/reader/IcebergSourceSplitReader.java | 0
.../flink/source/reader/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 | 0
.../iceberg/flink/source/reader/RecordFactory.java | 0
.../iceberg/flink/source/reader/RecordLimiter.java | 0
.../flink/source/reader/RowDataReaderFunction.java | 0
.../flink/source/reader/RowDataRecordFactory.java | 0
.../source/reader/SerializableRecordEmitter.java | 0
.../source/reader/SplitWatermarkExtractor.java | 0
.../reader/WatermarkExtractorRecordEmitter.java | 0
.../flink/source/split/IcebergSourceSplit.java | 0
.../source/split/IcebergSourceSplitSerializer.java | 0
.../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 | 0
.../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/FlinkSqlExtension.java | 0
.../operator/FlinkStreamingTestUtils.java | 0
.../flink/maintenance/operator/ManualSource.java | 0
.../maintenance/operator/OperatorTestBase.java | 0
.../maintenance/operator/TestMonitorSource.java | 0
.../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 | 0
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 0
.../flink/sink/TestFlinkAppenderFactory.java | 0
.../flink/sink/TestFlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 0
.../flink/sink/TestFlinkIcebergSinkBase.java | 0
.../flink/sink/TestFlinkIcebergSinkBranch.java | 0
.../sink/TestFlinkIcebergSinkDistributionMode.java | 0
.../flink/sink/TestFlinkIcebergSinkExtended.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 0
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 0
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 0
.../iceberg/flink/sink/TestFlinkManifest.java | 0
.../flink/sink/TestFlinkPartitioningWriters.java | 0
.../flink/sink/TestFlinkPositionDeltaWriters.java | 0
.../flink/sink/TestFlinkRollingFileWriters.java | 0
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 0
.../flink/sink/TestIcebergFilesCommitter.java | 0
.../flink/sink/TestIcebergStreamWriter.java | 0
.../flink/sink/TestRowDataPartitionKey.java | 0
.../apache/iceberg/flink/sink/TestTaskWriters.java | 0
.../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 | 0
.../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 | 0
.../TestIcebergSourceBoundedGenericRecord.java | 0
.../flink/source/TestIcebergSourceBoundedSql.java | 0
.../flink/source/TestIcebergSourceContinuous.java | 0
.../flink/source/TestIcebergSourceFailover.java | 0
...cebergSourceFailoverWithWatermarkExtractor.java | 0
.../source/TestIcebergSourceReaderDeletes.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 0
.../TestIcebergSourceWithWatermarkExtractor.java | 0
.../TestIcebergSpeculativeExecutionSupport.java | 12 +-
.../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 | 0
...estContinuousSplitPlannerImplStartStrategy.java | 0
.../source/enumerator/TestEnumerationHistory.java | 0
.../TestIcebergEnumeratorStateSerializer.java | 0
.../source/reader/ReaderFunctionTestBase.java | 0
.../iceberg/flink/source/reader/ReaderUtil.java | 0
.../flink/source/reader/TestArrayBatchRecords.java | 0
.../TestArrayPoolDataIteratorBatcherRowData.java | 0
.../reader/TestColumnStatsWatermarkExtractor.java | 0
.../source/reader/TestIcebergSourceReader.java | 0
.../source/reader/TestLimitableDataIterator.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 0
.../iceberg/flink/util/TestFlinkPackage.java | 2 +-
.../org.apache.flink.table.factories.Factory | 0
format/spec.md | 25 +-
gradle.properties | 4 +-
gradle/libs.versions.toml | 40 +-
.../apache/iceberg/hive/HiveOperationsBase.java | 10 -
jmh.gradle | 12 +-
kafka-connect/build.gradle | 2 +-
open-api/requirements.txt | 2 +-
settings.gradle | 18 +-
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 | 2 +-
site/overrides/home.html | 4 +-
site/overrides/partials/header.html | 7 +-
419 files changed, 429 insertions(+), 11397 deletions(-)
copy api/src/main/java/org/apache/iceberg/io/{DelegateFileIO.java =>
SupportsRecoveryOperations.java} (62%)
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/SortKeySerializer.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/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
delete mode 100644
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.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/TestFlinkIcebergSink.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
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 (100%)
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 (100%)
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 (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java
(100%)
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
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java
(100%)
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
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
(100%)
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%)
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%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java
(100%)
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
(100%)
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%)
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
(100%)
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%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java
(100%)
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
(100%)
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
(100%)
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
(100%)
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
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
(100%)
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
(100%)
rename 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
(100%)
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%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
(100%)
copy flink/{v1.18 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
(100%)
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
(100%)
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 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
(100%)
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
(100%)
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
(100%)
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%)
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
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
(100%)
rename 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%)
rename 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
(100%)
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%)
rename 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%)
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
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java
(100%)
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
(100%)
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%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkDistributionMode.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkExtended.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
(100%)
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%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
(100%)
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
(100%)
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
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedGenericRecord.java
(100%)
rename flink/{v1.17 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
(100%)
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%)
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
(100%)
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
(94%)
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
(100%)
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 =>
v1.20}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
