This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/com.google.cloud-libraries-bom-26.37.0
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard 685bf970da Build: Bump com.google.cloud:libraries-bom from 26.28.0 to
26.37.0
add abf238abcc Build: Bump mkdocs-material from 9.5.15 to 9.5.17 (#10092)
add b3261d07fc AWS: Migrate tests to JUnit5 (#10086)
add cd707394dd Spec: Document support for binary in truncate transform
(#10079)
add a351e22b6d Docs: Add Upsolver to vendor list (#10096)
add 6f4e9c6a68 Docs: Update releases.md for Spark scala versions (#10104)
add 9bb86fa496 Docs: Fix spacing/descriptions on Branching and Tagging DDL
(#10091)
add 81bb0d4c9b Core: Add EnvironmentContext to commit summary (#9273)
add 96793bf621 docs: Fix links of `Get Started` and `Community` parts in
footer (#10098)
add 528b9b336c Core: Allow configuring socket/connection timeout in
HTTPClient (#10053)
add 0bc6dfa1bd Core: Extend HTTPClient Builder to allow setting a proxy
server (#10052)
add 290a6a0c5d Spark 3.4: Fix system function pushdown in CoW row-level
commands (#10119)
add ce7c2c150c API, Core, Kafka, Spark: Reduce enum array allocation
(#10126)
add 2025e79905 Spark: Test initialization improvements (#10131)
add 1e66657874 Spec: Make request bodies required (#10125)
add 81b3310ab4 Spark 3.5: Support preserving schema nullability in CTAS
and RTAS (#10074)
add 496b320985 Flink, Spark: Replace Boolean.getBoolean() with
Boolean.parseBoolean() (#10136)
add 2400aa5307 Build: Bump net.snowflake:snowflake-jdbc from 3.14.5 to
3.15.1 (#10095)
add 47825ffd8b Build: Bump software.amazon.awssdk:bom from 2.25.21 to
2.25.31 (#10138)
add dd74dd289e Build: Bump org.springframework:spring-web from 5.3.33 to
5.3.34 (#10139)
add fb657b413e Spark: Simplify SparkSchemaUtil#schemaForTable (#10137)
add 943321ee6d Flink: Migrate tests to JUnit5 (#10130)
add e6a1a45624 Core: Fix logging table name when scanning metadata table
(#10141)
add d067677df8 AWS: Close underlying scheduler for DynamoDbLockManager
(#10132)
add 78e8204c53 Spark 3.5: Add threshold for failed commits in data
rewrites (#9611)
add 97c5700ff5 Core: Fix JDBC Catalog table commit when migrating from
schema V0 to V1 (#10111)
add fc5b2b336c Core: Use 'delete' if RowDelta only has delete files
(#10123)
add fbcd142c5d Flink: Move flink/v1.18 to flink/v1.19
add f761d98a1d Flink: Recover flink/1.18 files from history
add b3ebcf109a Flink: Refactoring code and properties to make Flink 1.19
to work
add a0abdfbb7b Build: Bump com.google.cloud:libraries-bom from 26.28.0 to
26.37.0
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 (685bf970da)
\
N -- N -- N
refs/heads/dependabot/gradle/com.google.cloud-libraries-bom-26.37.0 (a0abdfbb7b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.baseline/checkstyle/checkstyle.xml | 4 +-
.github/workflows/flink-ci.yml | 2 +-
.../main/java/org/apache/iceberg/FileFormat.java | 4 +-
.../apache/iceberg/actions/RewriteDataFiles.java | 7 +
.../aws/TestAssumeRoleAwsClientFactory.java | 23 +-
.../iceberg/aws/TestDefaultAwsClientFactory.java | 13 +-
.../iceberg/aws/dynamodb/TestDynamoDbCatalog.java | 127 +++++-----
.../aws/dynamodb/TestDynamoDbLockManager.java | 74 +++---
.../org/apache/iceberg/aws/glue/GlueTestBase.java | 8 +-
.../aws/glue/TestGlueCatalogCommitFailure.java | 162 ++++++------
.../iceberg/aws/glue/TestGlueCatalogLock.java | 26 +-
.../iceberg/aws/glue/TestGlueCatalogNamespace.java | 68 +++--
.../iceberg/aws/glue/TestGlueCatalogTable.java | 217 +++++++---------
.../aws/lakeformation/LakeFormationTestBase.java | 15 +-
.../TestLakeFormationAwsClientFactory.java | 26 +-
.../TestLakeFormationDataOperations.java | 19 +-
.../TestLakeFormationMetadataOperations.java | 33 ++-
.../iceberg/aws/s3/TestS3FileIOIntegration.java | 73 +++---
.../iceberg/aws/s3/TestS3MultipartUpload.java | 35 ++-
.../iceberg/aws/dynamodb/DynamoDbLockManager.java | 4 +-
build.gradle | 1 +
.../apache/iceberg/BaseAllMetadataTableScan.java | 6 +-
.../src/main/java/org/apache/iceberg/BaseFile.java | 3 +-
.../main/java/org/apache/iceberg/BaseRowDelta.java | 4 +
.../java/org/apache/iceberg/CachingCatalog.java | 3 +-
.../org/apache/iceberg/GenericManifestEntry.java | 3 +-
.../org/apache/iceberg/GenericManifestFile.java | 3 +-
.../java/org/apache/iceberg/SnapshotProducer.java | 1 +
.../apache/iceberg/actions/BaseCommitService.java | 6 +
.../iceberg/hadoop/HadoopTableOperations.java | 4 +-
.../java/org/apache/iceberg/jdbc/JdbcUtil.java | 38 ++-
.../java/org/apache/iceberg/rest/HTTPClient.java | 103 +++++++-
.../org/apache/iceberg/TestCommitReporting.java | 2 +-
.../test/java/org/apache/iceberg/TestRowDelta.java | 12 +
.../org/apache/iceberg/TestSnapshotSummary.java | 7 +
.../org/apache/iceberg/jdbc/TestJdbcCatalog.java | 62 ++++-
.../java/org/apache/iceberg/jdbc/TestJdbcUtil.java | 98 ++++++++
.../org/apache/iceberg/rest/TestHTTPClient.java | 166 ++++++++++++
.../java/org/apache/iceberg/data/DataTest.java | 8 +-
.../apache/iceberg/data/avro/TestGenericData.java | 7 +-
.../apache/iceberg/data/orc/TestGenericData.java | 81 +++---
.../iceberg/data/parquet/TestGenericData.java | 20 +-
.../TestParquetEncryptionWithWriteSupport.java | 41 +--
dev/stage-binaries.sh | 2 +-
docs/docs/spark-configuration.md | 1 +
docs/docs/spark-ddl.md | 12 +-
flink/build.gradle | 7 +-
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 24 +-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 24 +-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/AvroGenericRecordConverterBase.java | 2 +-
.../iceberg/flink/TestDataFileSerialization.java | 14 +-
.../iceberg/flink/TestFlinkCatalogFactory.java | 20 +-
.../org/apache/iceberg/flink/TestFlinkFilters.java | 87 +++----
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 40 +--
.../flink/TestManifestFileSerialization.java | 17 +-
.../apache/iceberg/flink/TestRowDataWrapper.java | 18 +-
.../iceberg/flink/TestTableSerialization.java | 18 +-
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 24 +-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/data/TestRowProjection.java | 280 +++++++++++----------
.../iceberg/flink/data/TestStructRowData.java | 2 +-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 5 +-
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../TestRowDataToAvroGenericRecordConverter.java | 5 +-
.../iceberg/flink/util/TestFlinkPackage.java | 11 +-
flink/{v1.18 => v1.19}/build.gradle | 36 +--
flink/{v1.16 => v1.19}/flink-runtime/LICENSE | 0
flink/{v1.16 => v1.19}/flink-runtime/NOTICE | 0
.../iceberg/flink/IcebergConnectorSmokeTest.java | 0
.../sink/shuffle/MapRangePartitionerBenchmark.java | 0
.../org/apache/iceberg/flink/CatalogLoader.java | 0
.../org/apache/iceberg/flink/FlinkCatalog.java | 0
.../apache/iceberg/flink/FlinkCatalogFactory.java | 2 +-
.../org/apache/iceberg/flink/FlinkConfParser.java | 0
.../apache/iceberg/flink/FlinkConfigOptions.java | 0
.../iceberg/flink/FlinkDynamicTableFactory.java | 0
.../iceberg/flink/FlinkEnvironmentContext.java | 0
.../org/apache/iceberg/flink/FlinkFilters.java | 0
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 0
.../org/apache/iceberg/flink/FlinkReadConf.java | 0
.../org/apache/iceberg/flink/FlinkReadOptions.java | 0
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 0
.../apache/iceberg/flink/FlinkSourceFilter.java | 0
.../org/apache/iceberg/flink/FlinkTypeToType.java | 0
.../org/apache/iceberg/flink/FlinkTypeVisitor.java | 0
.../org/apache/iceberg/flink/FlinkWriteConf.java | 0
.../apache/iceberg/flink/FlinkWriteOptions.java | 0
.../org/apache/iceberg/flink/IcebergTableSink.java | 0
.../org/apache/iceberg/flink/RowDataWrapper.java | 0
.../java/org/apache/iceberg/flink/TableLoader.java | 0
.../org/apache/iceberg/flink/TypeToFlinkType.java | 0
.../org/apache/iceberg/flink/actions/Actions.java | 0
.../flink/actions/RewriteDataFilesAction.java | 0
.../flink/data/AvroWithFlinkSchemaVisitor.java | 0
.../apache/iceberg/flink/data/FlinkAvroReader.java | 0
.../apache/iceberg/flink/data/FlinkAvroWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcReader.java | 0
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 0
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 0
.../iceberg/flink/data/FlinkParquetReaders.java | 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 | 0
.../apache/iceberg/flink/data/StructRowData.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
.../flink/sink/shuffle/AggregatedStatistics.java | 0
.../sink/shuffle/AggregatedStatisticsTracker.java | 0
.../iceberg/flink/sink/shuffle/DataStatistics.java | 0
.../sink/shuffle/DataStatisticsCoordinator.java | 0
.../shuffle/DataStatisticsCoordinatorProvider.java | 0
.../flink/sink/shuffle/DataStatisticsEvent.java | 0
.../flink/sink/shuffle/DataStatisticsOperator.java | 0
.../flink/sink/shuffle/DataStatisticsOrRecord.java | 0
.../shuffle/DataStatisticsOrRecordSerializer.java | 0
.../flink/sink/shuffle/DataStatisticsUtil.java | 0
.../flink/sink/shuffle/MapDataStatistics.java | 0
.../sink/shuffle/MapDataStatisticsSerializer.java | 0
.../flink/sink/shuffle/MapRangePartitioner.java | 0
.../flink/sink/shuffle/SortKeySerializer.java | 0
.../AvroGenericRecordFileScanTaskReader.java | 0
.../apache/iceberg/flink/source/DataIterator.java | 0
.../iceberg/flink/source/DataTaskReader.java | 0
.../iceberg/flink/source/FileScanTaskReader.java | 0
.../iceberg/flink/source/FlinkInputFormat.java | 0
.../iceberg/flink/source/FlinkInputSplit.java | 0
.../apache/iceberg/flink/source/FlinkSource.java | 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/ListBatchRecords.java | 0
.../source/reader/ListDataIteratorBatcher.java | 0
.../source/reader/MetaDataReaderFunction.java | 0
.../flink/source/reader/ReaderFunction.java | 0
.../flink/source/reader/RecordAndPosition.java | 0
.../iceberg/flink/source/reader/RecordFactory.java | 0
.../flink/source/reader/RowDataReaderFunction.java | 0
.../flink/source/reader/RowDataRecordFactory.java | 0
.../source/reader/SerializableRecordEmitter.java | 0
.../source/reader/SplitWatermarkExtractor.java | 0
.../reader/WatermarkExtractorRecordEmitter.java | 0
.../flink/source/split/IcebergSourceSplit.java | 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/SplitComparators.java | 0
.../flink/source/split/SplitRequestEvent.java | 0
.../iceberg/flink/util/ElapsedTimeGauge.java | 0
.../iceberg/flink/util/FlinkAlterTableUtil.java | 0
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 0
.../apache/iceberg/flink/util/FlinkPackage.java | 0
.../org.apache.flink.table.factories.Factory | 0
.../org.apache.flink.table.factories.TableFactory | 0
.../flink/AvroGenericRecordConverterBase.java | 2 +-
.../org/apache/iceberg/flink/CatalogTestBase.java | 0
.../org/apache/iceberg/flink/DataGenerator.java | 0
.../org/apache/iceberg/flink/DataGenerators.java | 0
.../org/apache/iceberg/flink/FlinkTestBase.java | 18 ++
.../iceberg/flink/HadoopCatalogExtension.java | 0
.../iceberg/flink/HadoopCatalogResource.java | 0
.../apache/iceberg/flink/HadoopTableResource.java | 0
.../apache/iceberg/flink/MiniClusterResource.java | 0
.../iceberg/flink/MiniFlinkClusterExtension.java | 0
.../org/apache/iceberg/flink/RowDataConverter.java | 0
.../org/apache/iceberg/flink/SimpleDataUtil.java | 0
.../java/org/apache/iceberg/flink/TestBase.java | 20 +-
.../apache/iceberg/flink/TestCatalogLoader.java | 0
.../iceberg/flink/TestCatalogTableLoader.java | 0
.../apache/iceberg/flink/TestChangeLogTable.java | 2 +-
.../iceberg/flink/TestDataFileSerialization.java | 14 +-
.../org/apache/iceberg/flink/TestFixtures.java | 0
.../iceberg/flink/TestFlinkAnonymousTable.java | 0
.../iceberg/flink/TestFlinkCatalogDatabase.java | 8 +-
.../iceberg/flink/TestFlinkCatalogFactory.java | 20 +-
.../iceberg/flink/TestFlinkCatalogTable.java | 2 +-
.../flink/TestFlinkCatalogTablePartitions.java | 2 +-
.../apache/iceberg/flink/TestFlinkConfParser.java | 0
.../org/apache/iceberg/flink/TestFlinkFilters.java | 87 +++----
.../apache/iceberg/flink/TestFlinkHiveCatalog.java | 2 +-
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 40 +--
.../apache/iceberg/flink/TestFlinkTableSink.java | 2 +-
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 2 +-
.../java/org/apache/iceberg/flink/TestHelpers.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 20 +-
.../flink/TestManifestFileSerialization.java | 17 +-
.../apache/iceberg/flink/TestRowDataWrapper.java | 18 +-
.../org/apache/iceberg/flink/TestTableLoader.java | 0
.../iceberg/flink/TestTableSerialization.java | 18 +-
.../flink/actions/TestRewriteDataFilesAction.java | 2 +-
.../apache/iceberg/flink/data/RandomRowData.java | 0
.../iceberg/flink/data/RowDataToRowMapper.java | 0
.../flink/data/TestFlinkAvroReaderWriter.java | 21 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 19 +-
.../iceberg/flink/data/TestFlinkParquetReader.java | 24 +-
.../iceberg/flink/data/TestFlinkParquetWriter.java | 17 +-
.../iceberg/flink/data/TestRowDataProjection.java | 0
.../iceberg/flink/data/TestRowProjection.java | 280 +++++++++++----------
.../iceberg/flink/data/TestStructRowData.java | 2 +-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 5 +-
.../flink/sink/TestBucketPartitionKeySelector.java | 0
.../iceberg/flink/sink/TestBucketPartitioner.java | 0
.../TestBucketPartitionerFlinkIcebergSink.java | 0
.../flink/sink/TestBucketPartitionerUtil.java | 0
.../flink/sink/TestCachingTableSupplier.java | 0
.../flink/sink/TestCompressionSettings.java | 0
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 0
.../flink/sink/TestFlinkAppenderFactory.java | 0
.../flink/sink/TestFlinkFileWriterFactory.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 0
.../flink/sink/TestFlinkIcebergSinkBase.java | 0
.../flink/sink/TestFlinkIcebergSinkBranch.java | 0
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 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
.../sink/shuffle/TestAggregatedStatistics.java | 0
.../shuffle/TestAggregatedStatisticsTracker.java | 0
.../shuffle/TestDataStatisticsCoordinator.java | 0
.../TestDataStatisticsCoordinatorProvider.java | 0
.../sink/shuffle/TestDataStatisticsOperator.java | 4 +-
.../flink/sink/shuffle/TestMapDataStatistics.java | 0
.../sink/shuffle/TestMapRangePartitioner.java | 0
.../sink/shuffle/TestSortKeySerializerBase.java | 0
.../shuffle/TestSortKeySerializerNestedStruct.java | 0
.../shuffle/TestSortKeySerializerPrimitives.java | 0
.../iceberg/flink/source/BoundedTableFactory.java | 0
.../iceberg/flink/source/BoundedTestSource.java | 0
.../flink/source/ChangeLogTableTestBase.java | 0
.../apache/iceberg/flink/source/SplitHelpers.java | 0
.../apache/iceberg/flink/source/SqlHelpers.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 | 2 +-
.../flink/source/TestFlinkReaderDeletesBase.java | 0
.../apache/iceberg/flink/source/TestFlinkScan.java | 0
.../iceberg/flink/source/TestFlinkScanSql.java | 0
.../iceberg/flink/source/TestFlinkSource.java | 2 +-
.../flink/source/TestFlinkSourceConfig.java | 0
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../iceberg/flink/source/TestFlinkTableSource.java | 2 +-
.../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
.../source/TestMetadataTableReadableMetrics.java | 2 +-
.../flink/source/TestProjectMetaColumn.java | 0
.../TestRowDataToAvroGenericRecordConverter.java | 5 +-
.../iceberg/flink/source/TestSourceUtil.java | 0
.../apache/iceberg/flink/source/TestSqlBase.java | 0
.../iceberg/flink/source/TestStreamScanSql.java | 2 +-
.../flink/source/TestStreamingMonitorFunction.java | 0
.../flink/source/TestStreamingReaderOperator.java | 0
.../source/assigner/SplitAssignerTestBase.java | 0
.../source/assigner/TestDefaultSplitAssigner.java | 0
.../TestFileSequenceNumberBasedSplitAssigner.java | 0
.../assigner/TestWatermarkBasedSplitAssigner.java | 0
.../enumerator/ManualContinuousSplitPlanner.java | 0
.../TestContinuousIcebergEnumerator.java | 0
.../enumerator/TestContinuousSplitPlannerImpl.java | 0
...estContinuousSplitPlannerImplStartStrategy.java | 0
.../source/enumerator/TestEnumerationHistory.java | 0
.../TestIcebergEnumeratorStateSerializer.java | 0
.../source/reader/ReaderFunctionTestBase.java | 0
.../iceberg/flink/source/reader/ReaderUtil.java | 0
.../flink/source/reader/TestArrayBatchRecords.java | 0
.../TestArrayPoolDataIteratorBatcherRowData.java | 0
.../reader/TestColumnStatsWatermarkExtractor.java | 0
.../source/reader/TestIcebergSourceReader.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 0
.../iceberg/flink/util/TestFlinkPackage.java | 11 +-
.../org.apache.flink.table.factories.Factory | 0
format/spec.md | 4 +-
gradle.properties | 4 +-
gradle/libs.versions.toml | 30 +--
.../org/apache/iceberg/connect/events/Event.java | 3 +-
open-api/rest-catalog-open-api.yaml | 8 +
settings.gradle | 18 +-
site/docs/releases.md | 9 +-
site/docs/vendors.md | 4 +
site/overrides/partials/footer.html | 24 +-
site/requirements.txt | 2 +-
.../SparkRowLevelOperationsTestBase.java | 14 +-
.../iceberg/spark/extensions/TestDelete.java | 27 ++
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/source/TestStructuredStreamingRead3.java | 13 +-
.../catalyst/optimizer/ReplaceStaticInvoke.scala | 49 +++-
.../iceberg/spark/extensions/SparkPlanUtil.java | 48 ++++
.../SparkRowLevelOperationsTestBase.java | 13 +-
.../iceberg/spark/extensions/TestDelete.java | 27 ++
...SystemFunctionPushDownInRowLevelOperations.java | 78 +++---
.../org/apache/iceberg/spark/SparkContentFile.java | 4 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/functions/BaseScalarFunction.java | 0
.../iceberg/spark/functions/BucketFunction.java | 3 +-
.../iceberg/spark/functions/DaysFunction.java | 3 +-
.../iceberg/spark/functions/HoursFunction.java | 5 +-
.../spark/functions/IcebergVersionFunction.java | 3 +-
.../iceberg/spark/functions/MonthsFunction.java | 3 +-
.../iceberg/spark/functions/TruncateFunction.java | 3 +-
.../iceberg/spark/functions/YearsFunction.java | 3 +-
.../spark/source/TestStructuredStreamingRead3.java | 13 +-
.../spark/extensions/ExtensionsTestBase.java | 3 +
.../SparkRowLevelOperationsTestBase.java | 14 +-
.../iceberg/spark/extensions/TestDelete.java | 26 ++
.../extensions/TestRewriteDataFilesProcedure.java | 17 ++
.../TestRewritePositionDeleteFilesProcedure.java | 22 ++
.../java/org/apache/iceberg/spark/BaseCatalog.java | 20 ++
.../org/apache/iceberg/spark/SparkCatalog.java | 2 +
.../org/apache/iceberg/spark/SparkContentFile.java | 4 +-
.../org/apache/iceberg/spark/SparkSchemaUtil.java | 4 +-
.../apache/iceberg/spark/SparkSessionCatalog.java | 2 +
.../org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/actions/RewriteDataFilesSparkAction.java | 36 ++-
.../org/apache/iceberg/spark/CatalogTestBase.java | 4 -
.../apache/iceberg/spark/TestBaseWithCatalog.java | 2 +-
.../iceberg/spark/TestSparkCatalogOperations.java | 102 ++++++++
.../iceberg/spark/TestSparkExecutorCache.java | 4 +-
.../spark/actions/TestRewriteDataFilesAction.java | 48 +++-
.../spark/source/TestStructuredStreamingRead3.java | 12 +-
411 files changed, 2434 insertions(+), 1458 deletions(-)
copy flink/{v1.18 => v1.19}/build.gradle (91%)
copy flink/{v1.16 => v1.19}/flink-runtime/LICENSE (100%)
copy flink/{v1.16 => v1.19}/flink-runtime/NOTICE (100%)
copy flink/{v1.16 =>
v1.19}/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java (100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java (100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
(99%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java (100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatistics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsEvent.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecord.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecordSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
(98%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/CatalogTestBase.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/DataGenerator.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/DataGenerators.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java (85%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogExtension.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/HadoopTableResource.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/MiniClusterResource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/MiniFlinkClusterExtension.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java (100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestBase.java (84%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogLoader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
(99%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java
(94%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkAnonymousTable.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java
(97%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java
(88%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java
(98%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkConfParser.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java (85%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
(99%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java
(93%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java (99%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
(95%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java
(93%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java
(85%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java (100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java
(91%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java
(99%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java
(91%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java
(87%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
(88%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java
(88%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java
(64%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/data/TestStructRowData.java
(98%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestAvroGenericRecordToRowDataMapper.java
(94%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionKeySelector.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitioner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerFlinkIcebergSink.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestBucketPartitionerUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCachingTableSupplier.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkAppenderFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatistics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestAggregatedStatisticsTracker.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsCoordinatorProvider.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestDataStatisticsOperator.java
(98%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapDataStatistics.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestMapRangePartitioner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerNestedStruct.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerPrimitives.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
(97%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceConfig.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
(99%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedGenericRecord.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailoverWithWatermarkExtractor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestMetadataTableReadableMetrics.java
(99%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java
(100%)
copy flink/{v1.18 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestRowDataToAvroGenericRecordConverter.java
(93%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
(99%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/SplitAssignerTestBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestDefaultSplitAssigner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestFileSequenceNumberBasedSplitAssigner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestWatermarkBasedSplitAssigner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java
(100%)
copy flink/{v1.17 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestEnumerationHistory.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestColumnStatsWatermarkExtractor.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java
(100%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java
(85%)
copy flink/{v1.16 =>
v1.19}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
copy spark/{v3.5 =>
v3.4}/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/TestSystemFunctionPushDownInRowLevelOperations.java
(93%)
copy spark/{v3.5 =>
v3.4}/spark/src/main/java/org/apache/iceberg/spark/functions/BaseScalarFunction.java
(100%)
