You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by gi...@apache.org on 2022/11/03 18:24:00 UTC
[iceberg] branch dependabot/pip/python/fastavro-1.7.0 updated (a063d4ce8d -> 7945ec7712)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/python/fastavro-1.7.0
in repository https://gitbox.apache.org/repos/asf/iceberg.git
discard a063d4ce8d Build: Bump fastavro from 1.6.1 to 1.7.0 in /python
add 50a45485eb Python: PyArrow timestamp in microseconds (#6070)
add 40b50df9c1 Spark 3.3: Use separate scan during file filtering in copy-on-write ops (#6077)
add 3f4c0ce174 Spark: Remove redundant max_concurrent_deletes check (#6083)
add 4e5e6f029f Infra: Publish nightly build for Spark-3.3_2.13 (#6054)
add ee927f3980 Infra: Update slack invite link (#6052)
add dbe7a5877b Docs: Fix link in the Java Custom Catalog page (#6068)
add a4dcd346d6 Infra: Add 1.0.0 in issue template dropdown (#6057)
add 8f9155ec75 Flink: Remove Flink 1.13 (#6103)
add b8a637c61a Core, Spark: Fix raw generics usage of ManifestWriter (#6059)
add aaefa6669c Spark 3.2: Use separate scan during file filtering in copy-on-write ops (#6095)
add a0a353d06d Spark 3.3: Relocate all Netty classes (#6107)
add 6450ae53a8 Spark 3.2: Relocate all Netty classes (#6109)
add dc7e6ef101 Spark: Optimize Preconditions.checkArgument in procedures (#6096)
add 5687e5f0a3 Docs: Update spotless apply command for non-default versions (#6101)
add db7e09e54a Core: Improve collection handling in JsonUtil (#6051)
add 3373a414c1 Build: Add gaborkaszab as a collaborator (#6036)
add b2a95f5625 Flink: Move flink/v1.15 to flink/v1.16
add f3182356f7 Flink: Copy flink/1.15 files from flink/1.16
add 9e76a846d2 Flink: Make flink 1.16 work
add ddf0e27c6b Python: Use Types from Typing (#6114)
add de98e4bfd1 Python: Add the REST token to the properties (#6086)
add 957ea6d146 Python: Pin versions explicitly (#6078)
add 7945ec7712 Build: Bump fastavro from 1.6.1 to 1.7.0 in /python
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 (a063d4ce8d)
\
N -- N -- N refs/heads/dependabot/pip/python/fastavro-1.7.0 (7945ec7712)
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:
.asf.yaml | 1 +
.github/ISSUE_TEMPLATE/iceberg_bug_report.yml | 3 +-
.github/ISSUE_TEMPLATE/iceberg_question.yml | 2 +-
.github/workflows/flink-ci.yml | 2 +-
.github/workflows/java-ci.yml | 2 +-
.github/workflows/publish-snapshot.yml | 4 +-
README.md | 4 +-
.../main/java/org/apache/iceberg/FastAppend.java | 2 +-
.../java/org/apache/iceberg/util/JsonUtil.java | 26 +-
.../iceberg/metrics/TestScanReportParser.java | 4 +-
.../iceberg/puffin/TestFileMetadataParser.java | 2 +-
.../java/org/apache/iceberg/util/TestJsonUtil.java | 214 +++++
dev/stage-binaries.sh | 2 +-
docs/java-custom-catalog.md | 2 +-
flink/build.gradle | 8 +-
.../org/apache/iceberg/flink/FlinkCatalog.java | 772 ------------------
.../apache/iceberg/flink/FlinkCatalogFactory.java | 189 -----
.../apache/iceberg/flink/FlinkConfigOptions.java | 48 --
.../iceberg/flink/FlinkDynamicTableFactory.java | 205 -----
.../org/apache/iceberg/flink/FlinkWriteConf.java | 107 ---
.../apache/iceberg/flink/FlinkWriteOptions.java | 47 --
.../apache/iceberg/flink/IcebergTableSource.java | 193 -----
.../iceberg/flink/data/FlinkParquetReaders.java | 823 --------------------
.../iceberg/flink/sink/BaseDeltaTaskWriter.java | 120 ---
.../iceberg/flink/sink/FlinkManifestUtil.java | 120 ---
.../org/apache/iceberg/flink/sink/FlinkSink.java | 562 -------------
.../iceberg/flink/sink/IcebergFilesCommitter.java | 450 -----------
.../iceberg/flink/sink/IcebergStreamWriter.java | 114 ---
.../flink/sink/ManifestOutputFileFactory.java | 86 --
.../flink/sink/RowDataTaskWriterFactory.java | 186 -----
.../apache/iceberg/flink/source/DataIterator.java | 92 ---
.../iceberg/flink/source/FlinkInputFormat.java | 123 ---
.../apache/iceberg/flink/source/FlinkSource.java | 320 --------
.../iceberg/flink/source/FlinkSplitGenerator.java | 103 ---
.../iceberg/flink/source/RowDataRewriter.java | 164 ----
.../apache/iceberg/flink/source/ScanContext.java | 373 ---------
.../flink/source/StreamingMonitorFunction.java | 224 ------
.../flink/source/StreamingReaderOperator.java | 246 ------
.../org/apache/iceberg/flink/FlinkTestBase.java | 117 ---
.../org/apache/iceberg/flink/RowDataConverter.java | 148 ----
.../org/apache/iceberg/flink/SimpleDataUtil.java | 328 --------
.../iceberg/flink/TestCatalogTableLoader.java | 130 ----
.../apache/iceberg/flink/TestChangeLogTable.java | 301 -------
.../org/apache/iceberg/flink/TestFixtures.java | 48 --
.../iceberg/flink/TestFlinkCatalogTable.java | 419 ----------
.../apache/iceberg/flink/TestFlinkTableSink.java | 343 --------
.../org/apache/iceberg/flink/TestFlinkUpsert.java | 339 --------
.../apache/iceberg/flink/TestIcebergConnector.java | 348 ---------
.../iceberg/flink/TestTableSerialization.java | 110 ---
.../flink/data/TestFlinkAvroReaderWriter.java | 106 ---
.../iceberg/flink/data/TestFlinkParquetReader.java | 79 --
.../iceberg/flink/sink/TestDeltaTaskWriter.java | 351 ---------
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 389 ---------
.../iceberg/flink/sink/TestFlinkManifest.java | 302 -------
.../flink/sink/TestIcebergFilesCommitter.java | 866 ---------------------
.../flink/sink/TestIcebergStreamWriter.java | 392 ----------
.../apache/iceberg/flink/sink/TestTaskWriters.java | 245 ------
.../iceberg/flink/source/BoundedTableFactory.java | 168 ----
.../flink/source/ChangeLogTableTestBase.java | 87 ---
.../iceberg/flink/source/TestFlinkInputFormat.java | 146 ----
.../apache/iceberg/flink/source/TestFlinkScan.java | 368 ---------
.../iceberg/flink/source/TestFlinkScanSql.java | 295 -------
.../iceberg/flink/source/TestFlinkSource.java | 85 --
.../flink/source/TestProjectMetaColumn.java | 185 -----
.../iceberg/flink/source/TestStreamScanSql.java | 253 ------
.../flink/source/TestStreamingMonitorFunction.java | 387 ---------
.../flink/source/TestStreamingReaderOperator.java | 284 -------
flink/{v1.13 => v1.16}/build.gradle | 96 ++-
flink/{v1.13 => v1.16}/flink-runtime/LICENSE | 0
flink/{v1.13 => v1.16}/flink-runtime/NOTICE | 0
.../iceberg/flink/IcebergConnectorSmokeTest.java | 0
.../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
.../org/apache/iceberg/flink/FlinkFilters.java | 0
.../org/apache/iceberg/flink/FlinkFixupTypes.java | 0
.../org/apache/iceberg/flink/FlinkSchemaUtil.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 | 36 +-
.../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
.../iceberg/flink/sink/BaseDeltaTaskWriter.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
.../apache/iceberg/flink/source/DataIterator.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
.../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
.../flink/source/assigner/GetSplitResult.java | 0
.../flink/source/assigner/SimpleSplitAssigner.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
.../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
.../flink/source/reader/DataIteratorBatcher.java | 0
.../source/reader/DataIteratorReaderFunction.java | 0
.../flink/source/reader/IcebergSourceReader.java | 0
.../source/reader/IcebergSourceReaderMetrics.java | 0
.../source/reader/IcebergSourceRecordEmitter.java | 0
.../source/reader/IcebergSourceSplitReader.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
.../flink/source/split/IcebergSourceSplit.java | 0
.../source/split/IcebergSourceSplitSerializer.java | 0
.../source/split/IcebergSourceSplitState.java | 0
.../source/split/IcebergSourceSplitStatus.java | 0
.../flink/source/split/SplitRequestEvent.java | 0
.../iceberg/flink/util/FlinkCompatibilityUtil.java | 0
.../org.apache.flink.table.factories.Factory | 0
.../org.apache.flink.table.factories.TableFactory | 0
.../apache/iceberg/flink/FlinkCatalogTestBase.java | 0
.../org/apache/iceberg/flink/FlinkTestBase.java | 0
.../iceberg/flink/HadoopCatalogResource.java | 0
.../apache/iceberg/flink/HadoopTableResource.java | 0
.../apache/iceberg/flink/MiniClusterResource.java | 0
.../org/apache/iceberg/flink/RowDataConverter.java | 0
.../org/apache/iceberg/flink/SimpleDataUtil.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/TestFlinkCatalogDatabase.java | 0
.../iceberg/flink/TestFlinkCatalogFactory.java | 0
.../iceberg/flink/TestFlinkCatalogTable.java | 0
.../flink/TestFlinkCatalogTablePartitions.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
.../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
.../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
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.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/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/TestFlinkReaderDeletesBase.java | 0
.../apache/iceberg/flink/source/TestFlinkScan.java | 0
.../iceberg/flink/source/TestFlinkScanSql.java | 0
.../iceberg/flink/source/TestFlinkSource.java | 0
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../flink/source}/TestFlinkTableSource.java | 52 +-
.../flink/source/TestIcebergSourceBounded.java | 0
.../flink/source/TestIcebergSourceBoundedSql.java | 0
.../flink/source/TestIcebergSourceContinuous.java | 0
.../flink/source/TestIcebergSourceFailover.java | 0
.../source/TestIcebergSourceReaderDeletes.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 0
.../flink/source/TestProjectMetaColumn.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/TestSimpleSplitAssigner.java | 0
.../enumerator/ManualContinuousSplitPlanner.java | 0
.../TestContinuousIcebergEnumerator.java | 0
.../enumerator/TestContinuousSplitPlannerImpl.java | 0
...estContinuousSplitPlannerImplStartStrategy.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
.../source/reader/TestIcebergSourceReader.java | 0
.../source/reader/TestRowDataReaderFunction.java | 0
.../flink/source/reader/TestingMetricGroup.java | 0
.../split/TestIcebergSourceSplitSerializer.java | 0
.../org.apache.flink.table.factories.Factory | 0
gradle.properties | 4 +-
python/.pre-commit-config.yaml | 2 +-
python/CONTRIBUTING.md | 6 +
python/poetry.lock | 309 ++++----
python/pyiceberg/avro/codecs/__init__.py | 4 +-
python/pyiceberg/avro/file.py | 9 +-
python/pyiceberg/avro/reader.py | 19 +-
python/pyiceberg/catalog/__init__.py | 50 +-
python/pyiceberg/catalog/rest.py | 9 +-
python/pyiceberg/expressions/literals.py | 29 +-
python/pyiceberg/io/fsspec.py | 9 +-
python/pyiceberg/io/pyarrow.py | 4 +-
python/pyiceberg/utils/schema_conversion.py | 14 +-
python/pyproject.toml | 34 +-
python/tests/io/test_pyarrow.py | 4 +-
settings.gradle | 18 +-
.../iceberg/TestManifestFileSerialization.java | 2 +-
.../spark/source/TestForwardCompatibility.java | 2 +-
.../spark/procedures/ExpireSnapshotsProcedure.java | 5 +-
.../procedures/RemoveOrphanFilesProcedure.java | 5 +-
.../iceberg/TestManifestFileSerialization.java | 2 +-
.../spark/source/TestForwardCompatibility.java | 2 +-
.../spark/procedures/ExpireSnapshotsProcedure.java | 5 +-
.../procedures/RemoveOrphanFilesProcedure.java | 5 +-
.../iceberg/TestManifestFileSerialization.java | 2 +-
.../spark/source/TestForwardCompatibility.java | 2 +-
spark/v3.2/build.gradle | 16 +-
.../RowLevelCommandDynamicPruning.scala | 56 +-
.../SparkRowLevelOperationsTestBase.java | 36 +
.../spark/extensions/TestCopyOnWriteDelete.java | 103 +++
.../spark/extensions/TestCopyOnWriteMerge.java | 108 +++
.../spark/extensions/TestCopyOnWriteUpdate.java | 100 +++
.../iceberg/spark/extensions/TestDelete.java | 80 +-
.../apache/iceberg/spark/extensions/TestMerge.java | 57 +-
.../iceberg/spark/extensions/TestUpdate.java | 56 +-
.../spark/procedures/ExpireSnapshotsProcedure.java | 5 +-
.../procedures/RemoveOrphanFilesProcedure.java | 5 +-
.../iceberg/spark/source/SparkCopyOnWriteScan.java | 14 +
.../iceberg/TestManifestFileSerialization.java | 2 +-
.../spark/source/TestForwardCompatibility.java | 2 +-
spark/v3.3/build.gradle | 16 +-
.../RowLevelCommandDynamicPruning.scala | 55 +-
.../SparkRowLevelOperationsTestBase.java | 36 +
.../spark/extensions/TestCopyOnWriteDelete.java | 103 +++
.../spark/extensions/TestCopyOnWriteMerge.java | 108 +++
.../spark/extensions/TestCopyOnWriteUpdate.java | 100 +++
.../iceberg/spark/extensions/TestDelete.java | 80 +-
.../apache/iceberg/spark/extensions/TestMerge.java | 57 +-
.../iceberg/spark/extensions/TestUpdate.java | 56 +-
.../spark/procedures/ExpireSnapshotsProcedure.java | 5 +-
.../procedures/RemoveOrphanFilesProcedure.java | 5 +-
.../iceberg/spark/source/SparkCopyOnWriteScan.java | 14 +
.../iceberg/TestManifestFileSerialization.java | 2 +-
.../spark/source/TestForwardCompatibility.java | 2 +-
322 files changed, 1811 insertions(+), 13772 deletions(-)
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSource.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitGenerator.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java
delete mode 100644 flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java
delete mode 100644 flink/v1.13/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java
rename flink/{v1.13 => v1.16}/build.gradle (61%)
rename flink/{v1.13 => v1.16}/flink-runtime/LICENSE (100%)
rename flink/{v1.13 => v1.16}/flink-runtime/NOTICE (100%)
copy flink/{v1.14 => v1.16}/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java (75%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroReader.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceRecordEmitter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory (100%)
rename flink/{v1.13 => v1.16}/flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/FlinkCatalogTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/HadoopTableResource.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/MiniClusterResource.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/RowDataConverter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/SimpleDataUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestCatalogTableLoader.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestDataFileSerialization.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFixtures.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogDatabase.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTable.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogTablePartitions.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkFilters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkSchemaUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestFlinkUpsert.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestHelpers.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestIcebergConnector.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestManifestFileSerialization.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestRowDataWrapper.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestTableLoader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/TestTableSerialization.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/actions/TestRewriteDataFilesAction.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/RandomRowData.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/RowDataToRowMapper.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkAvroReaderWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReader.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowDataProjection.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/data/TestRowProjection.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestDeltaTaskWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkAppenderFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkFileWriterFactory.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkManifest.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPartitioningWriters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkPositionDeltaWriters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkRollingFileWriters.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkWriterMetrics.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergFilesCommitter.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestRowDataPartitionKey.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/sink/TestTaskWriters.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTestSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/SplitHelpers.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormat.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkInputFormatReaderDeletes.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkReaderDeletesBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScan.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkScanSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java (100%)
rename flink/{v1.13/flink/src/test/java/org/apache/iceberg/flink => v1.16/flink/src/test/java/org/apache/iceberg/flink/source}/TestFlinkTableSource.java (92%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBounded.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceContinuous.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceReaderDeletes.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java (100%)
copy flink/{v1.15 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestProjectMetaColumn.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamScanSql.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingReaderOperator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/assigner/TestSimpleSplitAssigner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/ManualContinuousSplitPlanner.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousIcebergEnumerator.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImpl.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestContinuousSplitPlannerImplStartStrategy.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/enumerator/TestIcebergEnumeratorStateSerializer.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayBatchRecords.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestArrayPoolDataIteratorBatcherRowData.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestingMetricGroup.java (100%)
copy flink/{v1.14 => v1.16}/flink/src/test/java/org/apache/iceberg/flink/source/split/TestIcebergSourceSplitSerializer.java (100%)
rename flink/{v1.13 => v1.16}/flink/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory (100%)