Path Lines of Code aliyun/src/main/java/org/apache/iceberg/aliyun/AliyunClientFactories.java 80 aliyun/src/main/java/org/apache/iceberg/aliyun/AliyunClientFactory.java 9 aliyun/src/main/java/org/apache/iceberg/aliyun/AliyunProperties.java 45 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/BaseOSSFile.java 57 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSFileIO.java 81 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSInputFile.java 34 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSInputStream.java 120 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSOutputFile.java 34 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSOutputStream.java 138 aliyun/src/main/java/org/apache/iceberg/aliyun/oss/OSSURI.java 54 api/src/main/java/org/apache/iceberg/Accessor.java 7 api/src/main/java/org/apache/iceberg/Accessors.java 173 api/src/main/java/org/apache/iceberg/AddedRowsScanTask.java 18 api/src/main/java/org/apache/iceberg/AppendFiles.java 5 api/src/main/java/org/apache/iceberg/BaseScanTaskGroup.java 70 api/src/main/java/org/apache/iceberg/BatchScan.java 8 api/src/main/java/org/apache/iceberg/BatchScanAdapter.java 108 api/src/main/java/org/apache/iceberg/BlobMetadata.java 10 api/src/main/java/org/apache/iceberg/ChangelogOperation.java 7 api/src/main/java/org/apache/iceberg/ChangelogScanTask.java 6 api/src/main/java/org/apache/iceberg/CombinedScanTask.java 13 api/src/main/java/org/apache/iceberg/ContentFile.java 52 api/src/main/java/org/apache/iceberg/ContentScanTask.java 22 api/src/main/java/org/apache/iceberg/DataFile.java 130 api/src/main/java/org/apache/iceberg/DataOperations.java 8 api/src/main/java/org/apache/iceberg/DataTask.java 13 api/src/main/java/org/apache/iceberg/DeleteFile.java 17 api/src/main/java/org/apache/iceberg/DeleteFiles.java 17 api/src/main/java/org/apache/iceberg/DeletedDataFileScanTask.java 18 api/src/main/java/org/apache/iceberg/DeletedRowsScanTask.java 21 api/src/main/java/org/apache/iceberg/DistributionMode.java 23 api/src/main/java/org/apache/iceberg/EmptyStructLike.java 36 api/src/main/java/org/apache/iceberg/ExpireSnapshots.java 17 api/src/main/java/org/apache/iceberg/FileContent.java 13 api/src/main/java/org/apache/iceberg/FileFormat.java 50 api/src/main/java/org/apache/iceberg/FileScanTask.java 25 api/src/main/java/org/apache/iceberg/Files.java 174 api/src/main/java/org/apache/iceberg/HistoryEntry.java 6 api/src/main/java/org/apache/iceberg/IcebergBuild.java 80 api/src/main/java/org/apache/iceberg/IncrementalAppendScan.java 3 api/src/main/java/org/apache/iceberg/IncrementalChangelogScan.java 4 api/src/main/java/org/apache/iceberg/IncrementalScan.java 23 api/src/main/java/org/apache/iceberg/LockManager.java 7 api/src/main/java/org/apache/iceberg/ManageSnapshots.java 26 api/src/main/java/org/apache/iceberg/ManifestContent.java 21 api/src/main/java/org/apache/iceberg/ManifestFile.java 138 api/src/main/java/org/apache/iceberg/MergeableScanTask.java 5 api/src/main/java/org/apache/iceberg/Metrics.java 122 api/src/main/java/org/apache/iceberg/NullOrder.java 16 api/src/main/java/org/apache/iceberg/OverwriteFiles.java 15 api/src/main/java/org/apache/iceberg/PartitionField.java 49 api/src/main/java/org/apache/iceberg/PartitionKey.java 35 api/src/main/java/org/apache/iceberg/PartitionScanTask.java 5 api/src/main/java/org/apache/iceberg/PartitionSpec.java 500 api/src/main/java/org/apache/iceberg/PartitionStatisticsFile.java 6 api/src/main/java/org/apache/iceberg/PendingUpdate.java 11 api/src/main/java/org/apache/iceberg/ReplacePartitions.java 8 api/src/main/java/org/apache/iceberg/ReplaceSortOrder.java 3 api/src/main/java/org/apache/iceberg/RewriteFiles.java 44 api/src/main/java/org/apache/iceberg/RewriteJobOrder.java 26 api/src/main/java/org/apache/iceberg/RewriteManifests.java 9 api/src/main/java/org/apache/iceberg/RowDelta.java 21 api/src/main/java/org/apache/iceberg/Scan.java 36 api/src/main/java/org/apache/iceberg/ScanTask.java 28 api/src/main/java/org/apache/iceberg/ScanTaskGroup.java 20 api/src/main/java/org/apache/iceberg/Schema.java 366 api/src/main/java/org/apache/iceberg/Snapshot.java 39 api/src/main/java/org/apache/iceberg/SnapshotRef.java 140 api/src/main/java/org/apache/iceberg/SnapshotRefType.java 16 api/src/main/java/org/apache/iceberg/SnapshotUpdate.java 15 api/src/main/java/org/apache/iceberg/SortDirection.java 16 api/src/main/java/org/apache/iceberg/SortField.java 60 api/src/main/java/org/apache/iceberg/SortKey.java 25 api/src/main/java/org/apache/iceberg/SortOrder.java 202 api/src/main/java/org/apache/iceberg/SortOrderBuilder.java 29 api/src/main/java/org/apache/iceberg/SortOrderComparators.java 71 api/src/main/java/org/apache/iceberg/SplittableScanTask.java 4 api/src/main/java/org/apache/iceberg/StatisticsFile.java 9 api/src/main/java/org/apache/iceberg/StructLike.java 6 api/src/main/java/org/apache/iceberg/StructTransform.java 98 api/src/main/java/org/apache/iceberg/Table.java 80 api/src/main/java/org/apache/iceberg/TableScan.java 18 api/src/main/java/org/apache/iceberg/Tables.java 26 api/src/main/java/org/apache/iceberg/Transaction.java 35 api/src/main/java/org/apache/iceberg/UnboundPartitionSpec.java 97 api/src/main/java/org/apache/iceberg/UnboundSortOrder.java 99 api/src/main/java/org/apache/iceberg/UpdateLocation.java 4 api/src/main/java/org/apache/iceberg/UpdatePartitionSpec.java 17 api/src/main/java/org/apache/iceberg/UpdatePartitionStatistics.java 6 api/src/main/java/org/apache/iceberg/UpdateProperties.java 7 api/src/main/java/org/apache/iceberg/UpdateSchema.java 93 api/src/main/java/org/apache/iceberg/UpdateStatistics.java 12 api/src/main/java/org/apache/iceberg/actions/Action.java 13 api/src/main/java/org/apache/iceberg/actions/ActionsProvider.java 48 api/src/main/java/org/apache/iceberg/actions/ComputeTableStats.java 9 api/src/main/java/org/apache/iceberg/actions/ConvertEqualityDeleteFiles.java 10 api/src/main/java/org/apache/iceberg/actions/DeleteOrphanFiles.java 41 api/src/main/java/org/apache/iceberg/actions/DeleteReachableFiles.java 19 api/src/main/java/org/apache/iceberg/actions/ExpireSnapshots.java 22 api/src/main/java/org/apache/iceberg/actions/MigrateTable.java 19 api/src/main/java/org/apache/iceberg/actions/RemoveDanglingDeleteFiles.java 8 api/src/main/java/org/apache/iceberg/actions/RewriteDataFiles.java 83 api/src/main/java/org/apache/iceberg/actions/RewriteManifests.java 13 api/src/main/java/org/apache/iceberg/actions/RewritePositionDeleteFiles.java 48 api/src/main/java/org/apache/iceberg/actions/RewriteTablePath.java 12 api/src/main/java/org/apache/iceberg/actions/SnapshotTable.java 15 api/src/main/java/org/apache/iceberg/actions/SnapshotUpdate.java 5 api/src/main/java/org/apache/iceberg/catalog/Catalog.java 137 api/src/main/java/org/apache/iceberg/catalog/Namespace.java 63 api/src/main/java/org/apache/iceberg/catalog/SessionCatalog.java 100 api/src/main/java/org/apache/iceberg/catalog/SupportsNamespaces.java 32 api/src/main/java/org/apache/iceberg/catalog/TableIdentifier.java 72 api/src/main/java/org/apache/iceberg/catalog/ViewCatalog.java 26 api/src/main/java/org/apache/iceberg/catalog/ViewSessionCatalog.java 26 api/src/main/java/org/apache/iceberg/data/Record.java 32 api/src/main/java/org/apache/iceberg/encryption/EncryptedInputFile.java 6 api/src/main/java/org/apache/iceberg/encryption/EncryptedKey.java 9 api/src/main/java/org/apache/iceberg/encryption/EncryptedOutputFile.java 6 api/src/main/java/org/apache/iceberg/encryption/EncryptingFileIO.java 160 api/src/main/java/org/apache/iceberg/encryption/EncryptionKeyMetadata.java 20 api/src/main/java/org/apache/iceberg/encryption/EncryptionManager.java 15 api/src/main/java/org/apache/iceberg/encryption/KmsClient.java 30 api/src/main/java/org/apache/iceberg/events/IncrementalScanEvent.java 43 api/src/main/java/org/apache/iceberg/events/Listener.java 4 api/src/main/java/org/apache/iceberg/events/Listeners.java 26 api/src/main/java/org/apache/iceberg/events/ScanEvent.java 27 api/src/main/java/org/apache/iceberg/exceptions/AlreadyExistsException.java 12 api/src/main/java/org/apache/iceberg/exceptions/BadRequestException.java 12 api/src/main/java/org/apache/iceberg/exceptions/CherrypickAncestorCommitException.java 11 api/src/main/java/org/apache/iceberg/exceptions/CleanableFailure.java 2 api/src/main/java/org/apache/iceberg/exceptions/CommitFailedException.java 15 api/src/main/java/org/apache/iceberg/exceptions/CommitStateUnknownException.java 16 api/src/main/java/org/apache/iceberg/exceptions/DuplicateWAPCommitException.java 6 api/src/main/java/org/apache/iceberg/exceptions/ForbiddenException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NamespaceNotEmptyException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NoSuchIcebergTableException.java 14 api/src/main/java/org/apache/iceberg/exceptions/NoSuchIcebergViewException.java 14 api/src/main/java/org/apache/iceberg/exceptions/NoSuchNamespaceException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NoSuchTableException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NoSuchViewException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NotAuthorizedException.java 12 api/src/main/java/org/apache/iceberg/exceptions/NotFoundException.java 12 api/src/main/java/org/apache/iceberg/exceptions/RESTException.java 12 api/src/main/java/org/apache/iceberg/exceptions/RuntimeIOException.java 17 api/src/main/java/org/apache/iceberg/exceptions/ServiceFailureException.java 12 api/src/main/java/org/apache/iceberg/exceptions/ServiceUnavailableException.java 12 api/src/main/java/org/apache/iceberg/exceptions/UnprocessableEntityException.java 8 api/src/main/java/org/apache/iceberg/exceptions/ValidationException.java 20 api/src/main/java/org/apache/iceberg/expressions/Aggregate.java 31 api/src/main/java/org/apache/iceberg/expressions/AggregateEvaluator.java 83 api/src/main/java/org/apache/iceberg/expressions/And.java 36 api/src/main/java/org/apache/iceberg/expressions/Binder.java 142 api/src/main/java/org/apache/iceberg/expressions/Bound.java 6 api/src/main/java/org/apache/iceberg/expressions/BoundAggregate.java 126 api/src/main/java/org/apache/iceberg/expressions/BoundExtract.java 40 api/src/main/java/org/apache/iceberg/expressions/BoundLiteralPredicate.java 133 api/src/main/java/org/apache/iceberg/expressions/BoundPredicate.java 38 api/src/main/java/org/apache/iceberg/expressions/BoundReference.java 61 api/src/main/java/org/apache/iceberg/expressions/BoundSetPredicate.java 61 api/src/main/java/org/apache/iceberg/expressions/BoundTerm.java 14 api/src/main/java/org/apache/iceberg/expressions/BoundTransform.java 48 api/src/main/java/org/apache/iceberg/expressions/BoundUnaryPredicate.java 56 api/src/main/java/org/apache/iceberg/expressions/CountAggregate.java 42 api/src/main/java/org/apache/iceberg/expressions/CountNonNull.java 33 api/src/main/java/org/apache/iceberg/expressions/CountStar.java 24 api/src/main/java/org/apache/iceberg/expressions/Evaluator.java 109 api/src/main/java/org/apache/iceberg/expressions/Expression.java 104 api/src/main/java/org/apache/iceberg/expressions/ExpressionUtil.java 486 api/src/main/java/org/apache/iceberg/expressions/ExpressionVisitors.java 460 api/src/main/java/org/apache/iceberg/expressions/Expressions.java 242 api/src/main/java/org/apache/iceberg/expressions/False.java 25 api/src/main/java/org/apache/iceberg/expressions/InclusiveMetricsEvaluator.java 402 api/src/main/java/org/apache/iceberg/expressions/Literal.java 45 api/src/main/java/org/apache/iceberg/expressions/Literals.java 566 api/src/main/java/org/apache/iceberg/expressions/ManifestEvaluator.java 283 api/src/main/java/org/apache/iceberg/expressions/MaxAggregate.java 57 api/src/main/java/org/apache/iceberg/expressions/MinAggregate.java 57 api/src/main/java/org/apache/iceberg/expressions/NamedReference.java 33 api/src/main/java/org/apache/iceberg/expressions/Not.java 22 api/src/main/java/org/apache/iceberg/expressions/Or.java 36 api/src/main/java/org/apache/iceberg/expressions/PathUtil.java 91 api/src/main/java/org/apache/iceberg/expressions/Predicate.java 18 api/src/main/java/org/apache/iceberg/expressions/Projections.java 111 api/src/main/java/org/apache/iceberg/expressions/Reference.java 4 api/src/main/java/org/apache/iceberg/expressions/ResidualEvaluator.java 189 api/src/main/java/org/apache/iceberg/expressions/RewriteNot.java 36 api/src/main/java/org/apache/iceberg/expressions/SerializationProxies.java 44 api/src/main/java/org/apache/iceberg/expressions/StrictMetricsEvaluator.java 341 api/src/main/java/org/apache/iceberg/expressions/Term.java 3 api/src/main/java/org/apache/iceberg/expressions/True.java 25 api/src/main/java/org/apache/iceberg/expressions/Unbound.java 6 api/src/main/java/org/apache/iceberg/expressions/UnboundAggregate.java 33 api/src/main/java/org/apache/iceberg/expressions/UnboundExtract.java 40 api/src/main/java/org/apache/iceberg/expressions/UnboundPredicate.java 230 api/src/main/java/org/apache/iceberg/expressions/UnboundTerm.java 2 api/src/main/java/org/apache/iceberg/expressions/UnboundTransform.java 40 api/src/main/java/org/apache/iceberg/expressions/ValueAggregate.java 45 api/src/main/java/org/apache/iceberg/expressions/VariantExpressionUtil.java 85 api/src/main/java/org/apache/iceberg/io/BulkDeletionFailureException.java 12 api/src/main/java/org/apache/iceberg/io/CloseableGroup.java 39 api/src/main/java/org/apache/iceberg/io/CloseableIterable.java 221 api/src/main/java/org/apache/iceberg/io/CloseableIterator.java 70 api/src/main/java/org/apache/iceberg/io/ClosingIterator.java 31 api/src/main/java/org/apache/iceberg/io/CredentialSupplier.java 5 api/src/main/java/org/apache/iceberg/io/DelegateFileIO.java 2 api/src/main/java/org/apache/iceberg/io/DelegatingInputStream.java 5 api/src/main/java/org/apache/iceberg/io/DelegatingOutputStream.java 5 api/src/main/java/org/apache/iceberg/io/FileAppender.java 21 api/src/main/java/org/apache/iceberg/io/FileIO.java 50 api/src/main/java/org/apache/iceberg/io/FileIOMetricsContext.java 8 api/src/main/java/org/apache/iceberg/io/FileInfo.java 20 api/src/main/java/org/apache/iceberg/io/FilterIterator.java 54 api/src/main/java/org/apache/iceberg/io/InputFile.java 10 api/src/main/java/org/apache/iceberg/io/LocationProvider.java 8 api/src/main/java/org/apache/iceberg/io/OutputFile.java 10 api/src/main/java/org/apache/iceberg/io/PositionOutputStream.java 9 api/src/main/java/org/apache/iceberg/io/RangeReadable.java 13 api/src/main/java/org/apache/iceberg/io/SeekableInputStream.java 7 api/src/main/java/org/apache/iceberg/io/SupportsBulkOperations.java 4 api/src/main/java/org/apache/iceberg/io/SupportsPrefixOperations.java 5 api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java 4 api/src/main/java/org/apache/iceberg/metrics/Counter.java 16 api/src/main/java/org/apache/iceberg/metrics/DefaultCounter.java 112 api/src/main/java/org/apache/iceberg/metrics/DefaultMetricsContext.java 30 api/src/main/java/org/apache/iceberg/metrics/DefaultTimer.java 83 api/src/main/java/org/apache/iceberg/metrics/FixedReservoirHistogram.java 104 api/src/main/java/org/apache/iceberg/metrics/Histogram.java 14 api/src/main/java/org/apache/iceberg/metrics/LoggingMetricsReporter.java 14 api/src/main/java/org/apache/iceberg/metrics/MetricsContext.java 87 api/src/main/java/org/apache/iceberg/metrics/MetricsReport.java 2 api/src/main/java/org/apache/iceberg/metrics/MetricsReporter.java 10 api/src/main/java/org/apache/iceberg/metrics/Timer.java 66 api/src/main/java/org/apache/iceberg/transforms/Bucket.java 221 api/src/main/java/org/apache/iceberg/transforms/Dates.java 163 api/src/main/java/org/apache/iceberg/transforms/Days.java 36 api/src/main/java/org/apache/iceberg/transforms/Hours.java 41 api/src/main/java/org/apache/iceberg/transforms/Identity.java 121 api/src/main/java/org/apache/iceberg/transforms/Months.java 36 api/src/main/java/org/apache/iceberg/transforms/PartitionSpecVisitor.java 103 api/src/main/java/org/apache/iceberg/transforms/ProjectionUtil.java 299 api/src/main/java/org/apache/iceberg/transforms/SerializationProxies.java 66 api/src/main/java/org/apache/iceberg/transforms/SortOrderVisitor.java 83 api/src/main/java/org/apache/iceberg/transforms/TimeTransform.java 72 api/src/main/java/org/apache/iceberg/transforms/Timestamps.java 223 api/src/main/java/org/apache/iceberg/transforms/Transform.java 82 api/src/main/java/org/apache/iceberg/transforms/TransformUtil.java 66 api/src/main/java/org/apache/iceberg/transforms/Transforms.java 122 api/src/main/java/org/apache/iceberg/transforms/Truncate.java 416 api/src/main/java/org/apache/iceberg/transforms/UnknownTransform.java 58 api/src/main/java/org/apache/iceberg/transforms/VoidTransform.java 67 api/src/main/java/org/apache/iceberg/transforms/Years.java 36 api/src/main/java/org/apache/iceberg/types/AssignFreshIds.java 88 api/src/main/java/org/apache/iceberg/types/AssignIds.java 67 api/src/main/java/org/apache/iceberg/types/CheckCompatibility.java 172 api/src/main/java/org/apache/iceberg/types/Comparators.java 292 api/src/main/java/org/apache/iceberg/types/Conversions.java 151 api/src/main/java/org/apache/iceberg/types/EdgeAlgorithm.java 23 api/src/main/java/org/apache/iceberg/types/FindTypeVisitor.java 61 api/src/main/java/org/apache/iceberg/types/GetProjectedIds.java 54 api/src/main/java/org/apache/iceberg/types/IndexById.java 46 api/src/main/java/org/apache/iceberg/types/IndexByName.java 144 api/src/main/java/org/apache/iceberg/types/IndexParents.java 58 api/src/main/java/org/apache/iceberg/types/JavaHash.java 19 api/src/main/java/org/apache/iceberg/types/JavaHashes.java 81 api/src/main/java/org/apache/iceberg/types/PrimitiveLikeHolder.java 13 api/src/main/java/org/apache/iceberg/types/PruneColumns.java 157 api/src/main/java/org/apache/iceberg/types/ReassignDoc.java 68 api/src/main/java/org/apache/iceberg/types/ReassignIds.java 121 api/src/main/java/org/apache/iceberg/types/Type.java 119 api/src/main/java/org/apache/iceberg/types/TypeUtil.java 550 api/src/main/java/org/apache/iceberg/types/Types.java 1072 api/src/main/java/org/apache/iceberg/util/BinaryUtil.java 55 api/src/main/java/org/apache/iceberg/util/BucketUtil.java 63 api/src/main/java/org/apache/iceberg/util/ByteBuffers.java 50 api/src/main/java/org/apache/iceberg/util/CharSequenceMap.java 154 api/src/main/java/org/apache/iceberg/util/CharSequenceSet.java 151 api/src/main/java/org/apache/iceberg/util/CharSequenceUtil.java 20 api/src/main/java/org/apache/iceberg/util/CharSequenceWrapper.java 73 api/src/main/java/org/apache/iceberg/util/DataFileSet.java 75 api/src/main/java/org/apache/iceberg/util/DateTimeUtil.java 193 api/src/main/java/org/apache/iceberg/util/DeleteFileSet.java 77 api/src/main/java/org/apache/iceberg/util/ExceptionUtil.java 110 api/src/main/java/org/apache/iceberg/util/NaNUtil.java 16 api/src/main/java/org/apache/iceberg/util/ScanTaskUtil.java 26 api/src/main/java/org/apache/iceberg/util/SerializableFunction.java 4 api/src/main/java/org/apache/iceberg/util/StructProjection.java 137 api/src/main/java/org/apache/iceberg/util/TruncateUtil.java 30 api/src/main/java/org/apache/iceberg/util/UUIDUtil.java 52 api/src/main/java/org/apache/iceberg/util/UnicodeUtil.java 63 api/src/main/java/org/apache/iceberg/util/WrapperSet.java 124 api/src/main/java/org/apache/iceberg/variants/BasicType.java 7 api/src/main/java/org/apache/iceberg/variants/LogicalType.java 17 api/src/main/java/org/apache/iceberg/variants/PhysicalType.java 89 api/src/main/java/org/apache/iceberg/variants/Primitives.java 26 api/src/main/java/org/apache/iceberg/variants/Serialized.java 5 api/src/main/java/org/apache/iceberg/variants/SerializedArray.java 65 api/src/main/java/org/apache/iceberg/variants/SerializedMetadata.java 104 api/src/main/java/org/apache/iceberg/variants/SerializedObject.java 172 api/src/main/java/org/apache/iceberg/variants/SerializedPrimitive.java 120 api/src/main/java/org/apache/iceberg/variants/SerializedShortString.java 54 api/src/main/java/org/apache/iceberg/variants/SerializedValue.java 14 api/src/main/java/org/apache/iceberg/variants/Variant.java 20 api/src/main/java/org/apache/iceberg/variants/VariantArray.java 28 api/src/main/java/org/apache/iceberg/variants/VariantData.java 24 api/src/main/java/org/apache/iceberg/variants/VariantMetadata.java 28 api/src/main/java/org/apache/iceberg/variants/VariantObject.java 56 api/src/main/java/org/apache/iceberg/variants/VariantPrimitive.java 43 api/src/main/java/org/apache/iceberg/variants/VariantUtil.java 153 api/src/main/java/org/apache/iceberg/variants/VariantValue.java 31 api/src/main/java/org/apache/iceberg/view/ReplaceViewVersion.java 4 api/src/main/java/org/apache/iceberg/view/SQLViewRepresentation.java 9 api/src/main/java/org/apache/iceberg/view/UpdateViewProperties.java 7 api/src/main/java/org/apache/iceberg/view/VersionBuilder.java 9 api/src/main/java/org/apache/iceberg/view/View.java 33 api/src/main/java/org/apache/iceberg/view/ViewBuilder.java 13 api/src/main/java/org/apache/iceberg/view/ViewHistoryEntry.java 5 api/src/main/java/org/apache/iceberg/view/ViewRepresentation.java 8 api/src/main/java/org/apache/iceberg/view/ViewVersion.java 18 arrow/src/main/java/org/apache/iceberg/arrow/ArrowAllocation.java 12 arrow/src/main/java/org/apache/iceberg/arrow/ArrowSchemaUtil.java 108 arrow/src/main/java/org/apache/iceberg/arrow/DictEncodedArrowConverter.java 177 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowBatchReader.java 29 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowReader.java 236 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowVectorAccessor.java 64 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowVectorAccessors.java 72 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/BaseBatchReader.java 55 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ColumnVector.java 70 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ColumnarBatch.java 44 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/GenericArrowVectorAccessorFactory.java 654 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/NullabilityHolder.java 44 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/VectorHolder.java 127 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/VectorizedArrowReader.java 528 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/VectorizedReaderBuilder.java 135 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/VectorizedTableScanIterable.java 31 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/BaseVectorizedParquetValuesReader.java 176 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/DecimalVectorUtil.java 35 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedColumnIterator.java 216 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedDictionaryEncodedParquetValuesReader.java 154 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedPageIterator.java 387 arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedParquetDefinitionLevelReader.java 639 aws/src/integration/java/org/apache/iceberg/aws/AwsIntegTestUtil.java 162 aws/src/integration/java/org/apache/iceberg/aws/TestAssumeRoleAwsClientFactory.java 188 aws/src/integration/java/org/apache/iceberg/aws/TestDefaultAwsClientFactory.java 77 aws/src/integration/java/org/apache/iceberg/aws/dynamodb/TestDynamoDbCatalog.java 359 aws/src/integration/java/org/apache/iceberg/aws/dynamodb/TestDynamoDbLockManager.java 206 aws/src/integration/java/org/apache/iceberg/aws/glue/GlueTestBase.java 150 aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogCommitFailure.java 418 aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogLock.java 133 aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogNamespace.java 156 aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogTable.java 689 aws/src/integration/java/org/apache/iceberg/aws/lakeformation/LakeFormationTestBase.java 536 aws/src/integration/java/org/apache/iceberg/aws/lakeformation/TestLakeFormationAwsClientFactory.java 155 aws/src/integration/java/org/apache/iceberg/aws/lakeformation/TestLakeFormationDataOperations.java 123 aws/src/integration/java/org/apache/iceberg/aws/lakeformation/TestLakeFormationMetadataOperations.java 295 aws/src/integration/java/org/apache/iceberg/aws/s3/MinioUtil.java 36 aws/src/integration/java/org/apache/iceberg/aws/s3/S3TestUtil.java 10 aws/src/integration/java/org/apache/iceberg/aws/s3/TestFlakyS3InputStream.java 181 aws/src/integration/java/org/apache/iceberg/aws/s3/TestMinioUtil.java 49 aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3FileIO.java 608 aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3FileIOIntegration.java 663 aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3InputStream.java 158 aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3MultipartUpload.java 143 aws/src/integration/java/org/apache/iceberg/aws/s3/TestS3OutputStream.java 282 aws/src/integration/java/org/apache/iceberg/aws/s3/signer/S3SignerServlet.java 205 aws/src/integration/java/org/apache/iceberg/aws/s3/signer/TestS3RestSigner.java 305 aws/src/main/java/org/apache/iceberg/aws/ApacheHttpClientConfigurations.java 98 aws/src/main/java/org/apache/iceberg/aws/AssumeRoleAwsClientFactory.java 150 aws/src/main/java/org/apache/iceberg/aws/AwsClientFactories.java 186 aws/src/main/java/org/apache/iceberg/aws/AwsClientFactory.java 16 aws/src/main/java/org/apache/iceberg/aws/AwsClientProperties.java 151 aws/src/main/java/org/apache/iceberg/aws/AwsProperties.java 264 aws/src/main/java/org/apache/iceberg/aws/HttpClientProperties.java 82 aws/src/main/java/org/apache/iceberg/aws/RESTSigV4AuthManager.java 63 aws/src/main/java/org/apache/iceberg/aws/RESTSigV4AuthSession.java 111 aws/src/main/java/org/apache/iceberg/aws/S3FileIOAwsClientFactories.java 47 aws/src/main/java/org/apache/iceberg/aws/UrlConnectionHttpClientConfigurations.java 55 aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbCatalog.java 597 aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java 324 aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java 208 aws/src/main/java/org/apache/iceberg/aws/glue/GlueCatalog.java 543 aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java 340 aws/src/main/java/org/apache/iceberg/aws/glue/GlueToIcebergConverter.java 14 aws/src/main/java/org/apache/iceberg/aws/glue/IcebergToGlueConverter.java 243 aws/src/main/java/org/apache/iceberg/aws/lakeformation/LakeFormationAwsClientFactory.java 120 aws/src/main/java/org/apache/iceberg/aws/s3/AnalyticsAcceleratorInputStreamWrapper.java 34 aws/src/main/java/org/apache/iceberg/aws/s3/AnalyticsAcceleratorUtil.java 62 aws/src/main/java/org/apache/iceberg/aws/s3/BaseS3File.java 70 aws/src/main/java/org/apache/iceberg/aws/s3/DefaultS3FileIOAwsClientFactory.java 55 aws/src/main/java/org/apache/iceberg/aws/s3/S3AccessGrantsPluginConfigurations.java 26 aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIO.java 447 aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOAwsClientFactory.java 10 aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOProperties.java 632 aws/src/main/java/org/apache/iceberg/aws/s3/S3InputFile.java 100 aws/src/main/java/org/apache/iceberg/aws/s3/S3InputStream.java 226 aws/src/main/java/org/apache/iceberg/aws/s3/S3OutputFile.java 76 aws/src/main/java/org/apache/iceberg/aws/s3/S3OutputStream.java 419 aws/src/main/java/org/apache/iceberg/aws/s3/S3RequestUtil.java 114 aws/src/main/java/org/apache/iceberg/aws/s3/S3URI.java 64 aws/src/main/java/org/apache/iceberg/aws/s3/VendedCredentialsProvider.java 150 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3ObjectMapper.java 87 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3SignRequest.java 22 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3SignRequestParser.java 88 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3SignResponse.java 13 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3SignResponseParser.java 37 aws/src/main/java/org/apache/iceberg/aws/s3/signer/S3V4RestSignerClient.java 283 aws/src/main/java/org/apache/iceberg/aws/util/RetryDetector.java 23 aws/src/main/resources/s3-signer-open-api.yaml 116 azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSFileIOTest.java 142 azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSInputStreamTest.java 145 azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSOutputStreamTest.java 65 azure/src/integration/java/org/apache/iceberg/azure/adlsv2/AzuriteContainer.java 66 azure/src/integration/java/org/apache/iceberg/azure/adlsv2/BaseAzuriteTest.java 42 azure/src/main/java/org/apache/iceberg/azure/AzureProperties.java 100 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSFileIO.java 170 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSInputFile.java 36 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSInputStream.java 145 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSLocation.java 43 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSOutputFile.java 40 azure/src/main/java/org/apache/iceberg/azure/adlsv2/ADLSOutputStream.java 87 azure/src/main/java/org/apache/iceberg/azure/adlsv2/BaseADLSFile.java 46 azure/src/main/java/org/apache/iceberg/azure/adlsv2/VendedAdlsCredentialProvider.java 133 azure/src/main/java/org/apache/iceberg/azure/adlsv2/VendedAzureSasCredentialPolicy.java 42 bundled-guava/src/main/java/org/apache/iceberg/GuavaClasses.java 77 common/src/main/java/org/apache/iceberg/common/DynClasses.java 52 common/src/main/java/org/apache/iceberg/common/DynConstructors.java 230 common/src/main/java/org/apache/iceberg/common/DynFields.java 223 common/src/main/java/org/apache/iceberg/common/DynMethods.java 237 core/src/jmh/java/org/apache/iceberg/AppendBenchmark.java 84 core/src/jmh/java/org/apache/iceberg/ManifestReadBenchmark.java 134 core/src/jmh/java/org/apache/iceberg/ManifestWriteBenchmark.java 129 core/src/jmh/java/org/apache/iceberg/PartitionStatsUtilBenchmark.java 66 core/src/jmh/java/org/apache/iceberg/ReplaceDeleteFilesBenchmark.java 113 core/src/jmh/java/org/apache/iceberg/deletes/RoaringPositionBitmapBenchmark.java 114 core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java 54 core/src/jmh/java/org/apache/iceberg/util/ZOrderByteUtilsBenchmark.java 92 core/src/main/java/org/apache/iceberg/AllDataFilesTable.java 34 core/src/main/java/org/apache/iceberg/AllDeleteFilesTable.java 34 core/src/main/java/org/apache/iceberg/AllEntriesTable.java 36 core/src/main/java/org/apache/iceberg/AllFilesTable.java 34 core/src/main/java/org/apache/iceberg/AllManifestsTable.java 362 core/src/main/java/org/apache/iceberg/AllManifestsTableTaskParser.java 71 core/src/main/java/org/apache/iceberg/BaseAddedRowsScanTask.java 46 core/src/main/java/org/apache/iceberg/BaseAllMetadataTableScan.java 58 core/src/main/java/org/apache/iceberg/BaseChangelogContentScanTask.java 112 core/src/main/java/org/apache/iceberg/BaseCombinedScanTask.java 55 core/src/main/java/org/apache/iceberg/BaseContentScanTask.java 102 core/src/main/java/org/apache/iceberg/BaseDeletedDataFileScanTask.java 48 core/src/main/java/org/apache/iceberg/BaseDeletedRowsScanTask.java 58 core/src/main/java/org/apache/iceberg/BaseDistributedDataScan.java 267 core/src/main/java/org/apache/iceberg/BaseEntriesTable.java 322 core/src/main/java/org/apache/iceberg/BaseFile.java 532 core/src/main/java/org/apache/iceberg/BaseFileScanTask.java 141 core/src/main/java/org/apache/iceberg/BaseFilesTable.java 179 core/src/main/java/org/apache/iceberg/BaseIncrementalAppendScan.java 79 core/src/main/java/org/apache/iceberg/BaseIncrementalChangelogScan.java 131 core/src/main/java/org/apache/iceberg/BaseIncrementalScan.java 140 core/src/main/java/org/apache/iceberg/BaseMetadataTable.java 137 core/src/main/java/org/apache/iceberg/BaseMetadataTableScan.java 37 core/src/main/java/org/apache/iceberg/BaseMetastoreCatalog.java 230 core/src/main/java/org/apache/iceberg/BaseMetastoreOperations.java 91 core/src/main/java/org/apache/iceberg/BaseMetastoreTableOperations.java 253 core/src/main/java/org/apache/iceberg/BaseOverwriteFiles.java 129 core/src/main/java/org/apache/iceberg/BasePositionDeletesScanTask.java 18 core/src/main/java/org/apache/iceberg/BaseReadOnlyTable.java 88 core/src/main/java/org/apache/iceberg/BaseReplacePartitions.java 91 core/src/main/java/org/apache/iceberg/BaseReplaceSortOrder.java 59 core/src/main/java/org/apache/iceberg/BaseRewriteFiles.java 109 core/src/main/java/org/apache/iceberg/BaseRewriteManifests.java 313 core/src/main/java/org/apache/iceberg/BaseRowDelta.java 140 core/src/main/java/org/apache/iceberg/BaseScan.java 230 core/src/main/java/org/apache/iceberg/BaseSnapshot.java 299 core/src/main/java/org/apache/iceberg/BaseTable.java 209 core/src/main/java/org/apache/iceberg/BaseTableScan.java 25 core/src/main/java/org/apache/iceberg/BaseTransaction.java 659 core/src/main/java/org/apache/iceberg/BaseUpdatePartitionSpec.java 435 core/src/main/java/org/apache/iceberg/CachingCatalog.java 215 core/src/main/java/org/apache/iceberg/CatalogProperties.java 58 core/src/main/java/org/apache/iceberg/CatalogUtil.java 379 core/src/main/java/org/apache/iceberg/ChangelogUtil.java 23 core/src/main/java/org/apache/iceberg/CherryPickOperation.java 166 core/src/main/java/org/apache/iceberg/ClientPool.java 8 core/src/main/java/org/apache/iceberg/ClientPoolImpl.java 136 core/src/main/java/org/apache/iceberg/CommitCallbackTransaction.java 89 core/src/main/java/org/apache/iceberg/ContentFileParser.java 237 core/src/main/java/org/apache/iceberg/DataFiles.java 289 core/src/main/java/org/apache/iceberg/DataFilesTable.java 34 core/src/main/java/org/apache/iceberg/DataScan.java 42 core/src/main/java/org/apache/iceberg/DataTableScan.java 63 core/src/main/java/org/apache/iceberg/DataTaskParser.java 49 core/src/main/java/org/apache/iceberg/Delegates.java 222 core/src/main/java/org/apache/iceberg/DeleteFileIndex.java 695 core/src/main/java/org/apache/iceberg/DeleteFilesTable.java 34 core/src/main/java/org/apache/iceberg/DoubleFieldMetrics.java 39 core/src/main/java/org/apache/iceberg/EncryptedKeyParser.java 53 core/src/main/java/org/apache/iceberg/EnvironmentContext.java 22 core/src/main/java/org/apache/iceberg/FastAppend.java 173 core/src/main/java/org/apache/iceberg/FieldMetrics.java 53 core/src/main/java/org/apache/iceberg/FileCleanupStrategy.java 110 core/src/main/java/org/apache/iceberg/FileMetadata.java 251 core/src/main/java/org/apache/iceberg/FileScanTaskParser.java 84 core/src/main/java/org/apache/iceberg/FilesTable.java 34 core/src/main/java/org/apache/iceberg/FilesTableTaskParser.java 63 core/src/main/java/org/apache/iceberg/FindFiles.java 123 core/src/main/java/org/apache/iceberg/FixedSizeSplitScanTaskIterator.java 31 core/src/main/java/org/apache/iceberg/FloatFieldMetrics.java 42 core/src/main/java/org/apache/iceberg/GenericBlobMetadata.java 94 core/src/main/java/org/apache/iceberg/GenericDataFile.java 76 core/src/main/java/org/apache/iceberg/GenericDeleteFile.java 80 core/src/main/java/org/apache/iceberg/GenericManifestEntry.java 172 core/src/main/java/org/apache/iceberg/GenericManifestFile.java 419 core/src/main/java/org/apache/iceberg/GenericPartitionFieldSummary.java 162 core/src/main/java/org/apache/iceberg/GenericPartitionStatisticsFile.java 4 core/src/main/java/org/apache/iceberg/GenericStatisticsFile.java 76 core/src/main/java/org/apache/iceberg/HasTableOperations.java 4 core/src/main/java/org/apache/iceberg/HistoryTable.java 75 core/src/main/java/org/apache/iceberg/IncrementalDataTableScan.java 143 core/src/main/java/org/apache/iceberg/IncrementalFileCleanup.java 212 core/src/main/java/org/apache/iceberg/IndexedStructLike.java 37 core/src/main/java/org/apache/iceberg/InheritableMetadata.java 5 core/src/main/java/org/apache/iceberg/InheritableMetadataFactory.java 79 core/src/main/java/org/apache/iceberg/InternalData.java 85 core/src/main/java/org/apache/iceberg/IsolationLevel.java 16 core/src/main/java/org/apache/iceberg/LocationProviders.java 191 core/src/main/java/org/apache/iceberg/ManifestEntriesTable.java 36 core/src/main/java/org/apache/iceberg/ManifestEntriesTableTaskParser.java 63 core/src/main/java/org/apache/iceberg/ManifestEntry.java 49 core/src/main/java/org/apache/iceberg/ManifestFileParser.java 178 core/src/main/java/org/apache/iceberg/ManifestFiles.java 297 core/src/main/java/org/apache/iceberg/ManifestFilterManager.java 404 core/src/main/java/org/apache/iceberg/ManifestGroup.java 333 core/src/main/java/org/apache/iceberg/ManifestListWriter.java 157 core/src/main/java/org/apache/iceberg/ManifestLists.java 50 core/src/main/java/org/apache/iceberg/ManifestMergeManager.java 135 core/src/main/java/org/apache/iceberg/ManifestReader.java 333 core/src/main/java/org/apache/iceberg/ManifestWriter.java 292 core/src/main/java/org/apache/iceberg/ManifestsTable.java 115 core/src/main/java/org/apache/iceberg/MergeAppend.java 39 core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java 888 core/src/main/java/org/apache/iceberg/MetadataColumns.java 126 core/src/main/java/org/apache/iceberg/MetadataLogEntriesTable.java 89 core/src/main/java/org/apache/iceberg/MetadataTableType.java 27 core/src/main/java/org/apache/iceberg/MetadataTableUtils.java 86 core/src/main/java/org/apache/iceberg/MetadataUpdate.java 423 core/src/main/java/org/apache/iceberg/MetadataUpdateParser.java 527 core/src/main/java/org/apache/iceberg/MetricsConfig.java 132 core/src/main/java/org/apache/iceberg/MetricsModes.java 102 core/src/main/java/org/apache/iceberg/MetricsUtil.java 334 core/src/main/java/org/apache/iceberg/MicroBatches.java 221 core/src/main/java/org/apache/iceberg/OffsetsAwareSplitScanTaskIterator.java 49 core/src/main/java/org/apache/iceberg/PartitionData.java 197 core/src/main/java/org/apache/iceberg/PartitionSpecParser.java 110 core/src/main/java/org/apache/iceberg/PartitionStatisticsFileParser.java 35 core/src/main/java/org/apache/iceberg/PartitionStats.java 189 core/src/main/java/org/apache/iceberg/PartitionStatsUtil.java 92 core/src/main/java/org/apache/iceberg/PartitionSummary.java 73 core/src/main/java/org/apache/iceberg/Partitioning.java 244 core/src/main/java/org/apache/iceberg/PartitionsTable.java 279 core/src/main/java/org/apache/iceberg/PlanningMode.java 26 core/src/main/java/org/apache/iceberg/PositionDeletesScanTask.java 2 core/src/main/java/org/apache/iceberg/PositionDeletesTable.java 286 core/src/main/java/org/apache/iceberg/PropertiesUpdate.java 80 core/src/main/java/org/apache/iceberg/ReachableFileCleanup.java 163 core/src/main/java/org/apache/iceberg/ReachableFileUtil.java 101 core/src/main/java/org/apache/iceberg/RefsTable.java 70 core/src/main/java/org/apache/iceberg/RemoveSnapshots.java 318 core/src/main/java/org/apache/iceberg/RewriteTablePathUtil.java 441 core/src/main/java/org/apache/iceberg/RollingManifestWriter.java 76 core/src/main/java/org/apache/iceberg/RowLevelOperationMode.java 23 core/src/main/java/org/apache/iceberg/ScanSummary.java 330 core/src/main/java/org/apache/iceberg/ScanTaskParser.java 98 core/src/main/java/org/apache/iceberg/SchemaParser.java 233 core/src/main/java/org/apache/iceberg/SchemaUpdate.java 691 core/src/main/java/org/apache/iceberg/SerializableByteBufferMap.java 123 core/src/main/java/org/apache/iceberg/SerializableTable.java 370 core/src/main/java/org/apache/iceberg/SetLocation.java 41 core/src/main/java/org/apache/iceberg/SetPartitionStatistics.java 43 core/src/main/java/org/apache/iceberg/SetSnapshotOperation.java 104 core/src/main/java/org/apache/iceberg/SetStatistics.java 44 core/src/main/java/org/apache/iceberg/SingleValueParser.java 356 core/src/main/java/org/apache/iceberg/SnapshotIdGeneratorUtil.java 11 core/src/main/java/org/apache/iceberg/SnapshotManager.java 139 core/src/main/java/org/apache/iceberg/SnapshotParser.java 188 core/src/main/java/org/apache/iceberg/SnapshotProducer.java 616 core/src/main/java/org/apache/iceberg/SnapshotRefParser.java 55 core/src/main/java/org/apache/iceberg/SnapshotScan.java 125 core/src/main/java/org/apache/iceberg/SnapshotSummary.java 327 core/src/main/java/org/apache/iceberg/SnapshotsTable.java 68 core/src/main/java/org/apache/iceberg/SortOrderParser.java 131 core/src/main/java/org/apache/iceberg/SplitPositionDeletesScanTask.java 59 core/src/main/java/org/apache/iceberg/SplitScanTaskIterator.java 8 core/src/main/java/org/apache/iceberg/StaticDataTask.java 118 core/src/main/java/org/apache/iceberg/StaticTableOperations.java 55 core/src/main/java/org/apache/iceberg/StaticTableScan.java 31 core/src/main/java/org/apache/iceberg/StatisticsFileParser.java 89 core/src/main/java/org/apache/iceberg/StreamingDelete.java 47 core/src/main/java/org/apache/iceberg/SystemConfigs.java 92 core/src/main/java/org/apache/iceberg/SystemProperties.java 16 core/src/main/java/org/apache/iceberg/TableMetadata.java 1478 core/src/main/java/org/apache/iceberg/TableMetadataParser.java 496 core/src/main/java/org/apache/iceberg/TableOperations.java 26 core/src/main/java/org/apache/iceberg/TableProperties.java 226 core/src/main/java/org/apache/iceberg/TableScanContext.java 146 core/src/main/java/org/apache/iceberg/TableUtil.java 44 core/src/main/java/org/apache/iceberg/Transactions.java 43 core/src/main/java/org/apache/iceberg/UpdateRequirement.java 175 core/src/main/java/org/apache/iceberg/UpdateRequirementParser.java 209 core/src/main/java/org/apache/iceberg/UpdateRequirements.java 164 core/src/main/java/org/apache/iceberg/UpdateSnapshotReferencesOperation.java 159 core/src/main/java/org/apache/iceberg/V1Metadata.java 410 core/src/main/java/org/apache/iceberg/V2Metadata.java 470 core/src/main/java/org/apache/iceberg/V3Metadata.java 424 core/src/main/java/org/apache/iceberg/actions/BaseAction.java 20 core/src/main/java/org/apache/iceberg/actions/BaseCommitService.java 162 core/src/main/java/org/apache/iceberg/actions/BaseComputeTableStats.java 18 core/src/main/java/org/apache/iceberg/actions/BaseDeleteOrphanFiles.java 12 core/src/main/java/org/apache/iceberg/actions/BaseDeleteReachableFiles.java 12 core/src/main/java/org/apache/iceberg/actions/BaseExpireSnapshots.java 18 core/src/main/java/org/apache/iceberg/actions/BaseMigrateTable.java 12 core/src/main/java/org/apache/iceberg/actions/BaseRemoveDanglingDeleteFiles.java 12 core/src/main/java/org/apache/iceberg/actions/BaseRewriteDataFiles.java 56 core/src/main/java/org/apache/iceberg/actions/BaseRewriteDataFilesAction.java 247 core/src/main/java/org/apache/iceberg/actions/BaseRewriteManifests.java 12 core/src/main/java/org/apache/iceberg/actions/BaseRewritePositionalDeleteFiles.java 37 core/src/main/java/org/apache/iceberg/actions/BaseRewriteTablePath.java 12 core/src/main/java/org/apache/iceberg/actions/BaseSnapshotTable.java 12 core/src/main/java/org/apache/iceberg/actions/BaseSnapshotUpdateAction.java 18 core/src/main/java/org/apache/iceberg/actions/BinPackRewriteFilePlanner.java 223 core/src/main/java/org/apache/iceberg/actions/BinPackRewritePositionDeletePlanner.java 172 core/src/main/java/org/apache/iceberg/actions/ConvertEqualityDeleteStrategy.java 15 core/src/main/java/org/apache/iceberg/actions/FileRewritePlan.java 32 core/src/main/java/org/apache/iceberg/actions/FileRewritePlanner.java 17 core/src/main/java/org/apache/iceberg/actions/FileRewriteRunner.java 17 core/src/main/java/org/apache/iceberg/actions/RewriteDataFilesActionResult.java 24 core/src/main/java/org/apache/iceberg/actions/RewriteDataFilesCommitManager.java 100 core/src/main/java/org/apache/iceberg/actions/RewriteFileGroup.java 79 core/src/main/java/org/apache/iceberg/actions/RewriteGroupBase.java 44 core/src/main/java/org/apache/iceberg/actions/RewritePositionDeletesCommitManager.java 84 core/src/main/java/org/apache/iceberg/actions/RewritePositionDeletesGroup.java 91 core/src/main/java/org/apache/iceberg/actions/SizeBasedFileRewritePlanner.java 201 core/src/main/java/org/apache/iceberg/actions/SnapshotUpdateAction.java 4 core/src/main/java/org/apache/iceberg/avro/ApplyNameMapping.java 136 core/src/main/java/org/apache/iceberg/avro/Avro.java 622 core/src/main/java/org/apache/iceberg/avro/AvroCustomOrderSchemaVisitor.java 98 core/src/main/java/org/apache/iceberg/avro/AvroEncoderUtil.java 52 core/src/main/java/org/apache/iceberg/avro/AvroFileAppender.java 88 core/src/main/java/org/apache/iceberg/avro/AvroIO.java 137 core/src/main/java/org/apache/iceberg/avro/AvroIterable.java 168 core/src/main/java/org/apache/iceberg/avro/AvroMetrics.java 15 core/src/main/java/org/apache/iceberg/avro/AvroSchemaUtil.java 427 core/src/main/java/org/apache/iceberg/avro/AvroSchemaVisitor.java 86 core/src/main/java/org/apache/iceberg/avro/AvroSchemaWithTypeVisitor.java 102 core/src/main/java/org/apache/iceberg/avro/AvroWithPartnerByStructureVisitor.java 130 core/src/main/java/org/apache/iceberg/avro/AvroWithPartnerVisitor.java 180 core/src/main/java/org/apache/iceberg/avro/AvroWithTypeByStructureVisitor.java 35 core/src/main/java/org/apache/iceberg/avro/BaseWriteBuilder.java 89 core/src/main/java/org/apache/iceberg/avro/BuildAvroProjection.java 214 core/src/main/java/org/apache/iceberg/avro/GenericAvroReader.java 183 core/src/main/java/org/apache/iceberg/avro/GenericAvroWriter.java 39 core/src/main/java/org/apache/iceberg/avro/HasIds.java 37 core/src/main/java/org/apache/iceberg/avro/InternalReader.java 204 core/src/main/java/org/apache/iceberg/avro/InternalReaders.java 78 core/src/main/java/org/apache/iceberg/avro/InternalWriter.java 40 core/src/main/java/org/apache/iceberg/avro/LogicalMap.java 26 core/src/main/java/org/apache/iceberg/avro/MetricsAwareDatumWriter.java 7 core/src/main/java/org/apache/iceberg/avro/MissingIds.java 37 core/src/main/java/org/apache/iceberg/avro/NameMappingDatumReader.java 35 core/src/main/java/org/apache/iceberg/avro/NameMappingWithAvroSchema.java 83 core/src/main/java/org/apache/iceberg/avro/ProjectionDatumReader.java 59 core/src/main/java/org/apache/iceberg/avro/PruneColumns.java 266 core/src/main/java/org/apache/iceberg/avro/RemoveIds.java 70 core/src/main/java/org/apache/iceberg/avro/SchemaToType.java 197 core/src/main/java/org/apache/iceberg/avro/SupportsCustomRecords.java 6 core/src/main/java/org/apache/iceberg/avro/SupportsCustomTypes.java 7 core/src/main/java/org/apache/iceberg/avro/SupportsIndexProjection.java 51 core/src/main/java/org/apache/iceberg/avro/SupportsRowPosition.java 5 core/src/main/java/org/apache/iceberg/avro/TypeToSchema.java 267 core/src/main/java/org/apache/iceberg/avro/UUIDConversion.java 27 core/src/main/java/org/apache/iceberg/avro/ValueReader.java 9 core/src/main/java/org/apache/iceberg/avro/ValueReaders.java 955 core/src/main/java/org/apache/iceberg/avro/ValueWriter.java 11 core/src/main/java/org/apache/iceberg/avro/ValueWriters.java 475 core/src/main/java/org/apache/iceberg/avro/VariantConversion.java 45 core/src/main/java/org/apache/iceberg/avro/VariantLogicalType.java 20 core/src/main/java/org/apache/iceberg/catalog/BaseSessionCatalog.java 118 core/src/main/java/org/apache/iceberg/catalog/BaseViewSessionCatalog.java 59 core/src/main/java/org/apache/iceberg/catalog/TableCommit.java 28 core/src/main/java/org/apache/iceberg/catalog/TableIdentifierParser.java 44 core/src/main/java/org/apache/iceberg/data/GenericDataUtil.java 29 core/src/main/java/org/apache/iceberg/data/GenericRecord.java 132 core/src/main/java/org/apache/iceberg/data/IdentityPartitionConverters.java 34 core/src/main/java/org/apache/iceberg/data/avro/DataReader.java 140 core/src/main/java/org/apache/iceberg/data/avro/DataWriter.java 129 core/src/main/java/org/apache/iceberg/data/avro/DecoderResolver.java 47 core/src/main/java/org/apache/iceberg/data/avro/GenericReaders.java 140 core/src/main/java/org/apache/iceberg/data/avro/GenericWriters.java 98 core/src/main/java/org/apache/iceberg/data/avro/IcebergDecoder.java 92 core/src/main/java/org/apache/iceberg/data/avro/IcebergEncoder.java 69 core/src/main/java/org/apache/iceberg/data/avro/PlannedDataReader.java 155 core/src/main/java/org/apache/iceberg/data/avro/RawDecoder.java 45 core/src/main/java/org/apache/iceberg/deletes/BaseDVFileWriter.java 150 core/src/main/java/org/apache/iceberg/deletes/BitmapPositionDeleteIndex.java 151 core/src/main/java/org/apache/iceberg/deletes/DVFileWriter.java 10 core/src/main/java/org/apache/iceberg/deletes/DeleteCounter.java 10 core/src/main/java/org/apache/iceberg/deletes/DeleteGranularity.java 27 core/src/main/java/org/apache/iceberg/deletes/Deletes.java 160 core/src/main/java/org/apache/iceberg/deletes/EmptyPositionDeleteIndex.java 28 core/src/main/java/org/apache/iceberg/deletes/EqualityDeleteWriter.java 77 core/src/main/java/org/apache/iceberg/deletes/FileScopedPositionDeleteWriter.java 75 core/src/main/java/org/apache/iceberg/deletes/PositionDelete.java 66 core/src/main/java/org/apache/iceberg/deletes/PositionDeleteIndex.java 41 core/src/main/java/org/apache/iceberg/deletes/PositionDeleteIndexUtil.java 9 core/src/main/java/org/apache/iceberg/deletes/PositionDeleteWriter.java 92 core/src/main/java/org/apache/iceberg/deletes/RoaringPositionBitmap.java 170 core/src/main/java/org/apache/iceberg/deletes/SortingPositionOnlyDeleteWriter.java 128 core/src/main/java/org/apache/iceberg/encryption/AesGcmInputFile.java 40 core/src/main/java/org/apache/iceberg/encryption/AesGcmInputStream.java 189 core/src/main/java/org/apache/iceberg/encryption/AesGcmOutputFile.java 30 core/src/main/java/org/apache/iceberg/encryption/AesGcmOutputStream.java 119 core/src/main/java/org/apache/iceberg/encryption/BaseEncryptedInputFile.java 18 core/src/main/java/org/apache/iceberg/encryption/BaseEncryptedKey.java 35 core/src/main/java/org/apache/iceberg/encryption/BaseEncryptedOutputFile.java 18 core/src/main/java/org/apache/iceberg/encryption/BaseEncryptionKeyMetadata.java 29 core/src/main/java/org/apache/iceberg/encryption/Ciphers.java 170 core/src/main/java/org/apache/iceberg/encryption/EncryptedFiles.java 37 core/src/main/java/org/apache/iceberg/encryption/EncryptionAlgorithm.java 6 core/src/main/java/org/apache/iceberg/encryption/EncryptionKeyMetadatas.java 11 core/src/main/java/org/apache/iceberg/encryption/EncryptionUtil.java 70 core/src/main/java/org/apache/iceberg/encryption/InputFilesDecryptor.java 41 core/src/main/java/org/apache/iceberg/encryption/KeyManagementClient.java 32 core/src/main/java/org/apache/iceberg/encryption/KeyMetadataDecoder.java 40 core/src/main/java/org/apache/iceberg/encryption/KeyMetadataEncoder.java 60 core/src/main/java/org/apache/iceberg/encryption/NativeEncryptionInputFile.java 6 core/src/main/java/org/apache/iceberg/encryption/NativeEncryptionKeyMetadata.java 6 core/src/main/java/org/apache/iceberg/encryption/NativeEncryptionOutputFile.java 25 core/src/main/java/org/apache/iceberg/encryption/NativeFileCryptoParameters.java 36 core/src/main/java/org/apache/iceberg/encryption/NativelyEncryptedFile.java 5 core/src/main/java/org/apache/iceberg/encryption/PlaintextEncryptionManager.java 24 core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java 144 core/src/main/java/org/apache/iceberg/encryption/StandardKeyMetadata.java 109 core/src/main/java/org/apache/iceberg/events/CreateSnapshotEvent.java 36 core/src/main/java/org/apache/iceberg/expressions/ExpressionParser.java 348 core/src/main/java/org/apache/iceberg/expressions/Zorder.java 12 core/src/main/java/org/apache/iceberg/hadoop/ConfigProperties.java 7 core/src/main/java/org/apache/iceberg/hadoop/Configurable.java 4 core/src/main/java/org/apache/iceberg/hadoop/HadoopCatalog.java 329 core/src/main/java/org/apache/iceberg/hadoop/HadoopConfigurable.java 9 core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java 182 core/src/main/java/org/apache/iceberg/hadoop/HadoopInputFile.java 190 core/src/main/java/org/apache/iceberg/hadoop/HadoopMetricsContext.java 111 core/src/main/java/org/apache/iceberg/hadoop/HadoopOutputFile.java 89 core/src/main/java/org/apache/iceberg/hadoop/HadoopStreams.java 167 core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java 331 core/src/main/java/org/apache/iceberg/hadoop/HadoopTables.java 277 core/src/main/java/org/apache/iceberg/hadoop/HiddenPathFilter.java 15 core/src/main/java/org/apache/iceberg/hadoop/SerializableConfiguration.java 24 core/src/main/java/org/apache/iceberg/hadoop/Util.java 97 core/src/main/java/org/apache/iceberg/inmemory/InMemoryCatalog.java 418 core/src/main/java/org/apache/iceberg/inmemory/InMemoryFileIO.java 47 core/src/main/java/org/apache/iceberg/inmemory/InMemoryInputFile.java 106 core/src/main/java/org/apache/iceberg/inmemory/InMemoryOutputFile.java 94 core/src/main/java/org/apache/iceberg/io/BasePositionDeltaWriter.java 75 core/src/main/java/org/apache/iceberg/io/BaseTaskWriter.java 319 core/src/main/java/org/apache/iceberg/io/ByteBufferInputStream.java 38 core/src/main/java/org/apache/iceberg/io/ClusteredDataWriter.java 37 core/src/main/java/org/apache/iceberg/io/ClusteredEqualityDeleteWriter.java 40 core/src/main/java/org/apache/iceberg/io/ClusteredPositionDeleteWriter.java 67 core/src/main/java/org/apache/iceberg/io/ClusteredWriter.java 84 core/src/main/java/org/apache/iceberg/io/ContentCache.java 168 core/src/main/java/org/apache/iceberg/io/DataWriteResult.java 16 core/src/main/java/org/apache/iceberg/io/DataWriter.java 79 core/src/main/java/org/apache/iceberg/io/DeleteSchemaUtil.java 33 core/src/main/java/org/apache/iceberg/io/DeleteWriteResult.java 50 core/src/main/java/org/apache/iceberg/io/EqualityDeltaWriter.java 12 core/src/main/java/org/apache/iceberg/io/FanoutDataWriter.java 37 core/src/main/java/org/apache/iceberg/io/FanoutPositionOnlyDeleteWriter.java 82 core/src/main/java/org/apache/iceberg/io/FanoutWriter.java 54 core/src/main/java/org/apache/iceberg/io/FileAppenderFactory.java 18 core/src/main/java/org/apache/iceberg/io/FileIOParser.java 50 core/src/main/java/org/apache/iceberg/io/FileIOTracker.java 37 core/src/main/java/org/apache/iceberg/io/FileWriter.java 14 core/src/main/java/org/apache/iceberg/io/FileWriterFactory.java 13 core/src/main/java/org/apache/iceberg/io/IOUtil.java 48 core/src/main/java/org/apache/iceberg/io/ImmutableStorageCredential.java 157 core/src/main/java/org/apache/iceberg/io/MultiBufferInputStream.java 263 core/src/main/java/org/apache/iceberg/io/OutputFileFactory.java 126 core/src/main/java/org/apache/iceberg/io/PartitionedFanoutWriter.java 40 core/src/main/java/org/apache/iceberg/io/PartitionedWriter.java 50 core/src/main/java/org/apache/iceberg/io/PartitioningDVWriter.java 36 core/src/main/java/org/apache/iceberg/io/PartitioningWriter.java 10 core/src/main/java/org/apache/iceberg/io/PositionDeltaWriter.java 17 core/src/main/java/org/apache/iceberg/io/ResolvingFileIO.java 222 core/src/main/java/org/apache/iceberg/io/RollingDataWriter.java 35 core/src/main/java/org/apache/iceberg/io/RollingEqualityDeleteWriter.java 40 core/src/main/java/org/apache/iceberg/io/RollingFileWriter.java 117 core/src/main/java/org/apache/iceberg/io/RollingPositionDeleteWriter.java 42 core/src/main/java/org/apache/iceberg/io/SingleBufferInputStream.java 138 core/src/main/java/org/apache/iceberg/io/SortedPosDeleteWriter.java 155 core/src/main/java/org/apache/iceberg/io/StorageCredential.java 15 core/src/main/java/org/apache/iceberg/io/SupportsStorageCredentials.java 6 core/src/main/java/org/apache/iceberg/io/TaskWriter.java 17 core/src/main/java/org/apache/iceberg/io/UnpartitionedWriter.java 25 core/src/main/java/org/apache/iceberg/io/WriteResult.java 98 core/src/main/java/org/apache/iceberg/jdbc/JdbcCatalog.java 733 core/src/main/java/org/apache/iceberg/jdbc/JdbcClientPool.java 72 core/src/main/java/org/apache/iceberg/jdbc/JdbcTableOperations.java 179 core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java 757 core/src/main/java/org/apache/iceberg/jdbc/JdbcViewOperations.java 160 core/src/main/java/org/apache/iceberg/jdbc/UncheckedInterruptedException.java 12 core/src/main/java/org/apache/iceberg/jdbc/UncheckedSQLException.java 12 core/src/main/java/org/apache/iceberg/mapping/MappedField.java 61 core/src/main/java/org/apache/iceberg/mapping/MappedFields.java 91 core/src/main/java/org/apache/iceberg/mapping/MappingUtil.java 225 core/src/main/java/org/apache/iceberg/mapping/NameMapping.java 69 core/src/main/java/org/apache/iceberg/mapping/NameMappingParser.java 72 core/src/main/java/org/apache/iceberg/metrics/CommitMetrics.java 24 core/src/main/java/org/apache/iceberg/metrics/CommitMetricsResult.java 179 core/src/main/java/org/apache/iceberg/metrics/CommitMetricsResultParser.java 201 core/src/main/java/org/apache/iceberg/metrics/CommitReport.java 12 core/src/main/java/org/apache/iceberg/metrics/CommitReportParser.java 59 core/src/main/java/org/apache/iceberg/metrics/CounterResult.java 19 core/src/main/java/org/apache/iceberg/metrics/CounterResultParser.java 50 core/src/main/java/org/apache/iceberg/metrics/InMemoryMetricsReporter.java 15 core/src/main/java/org/apache/iceberg/metrics/MetricsReporters.java 54 core/src/main/java/org/apache/iceberg/metrics/ScanMetrics.java 98 core/src/main/java/org/apache/iceberg/metrics/ScanMetricsResult.java 67 core/src/main/java/org/apache/iceberg/metrics/ScanMetricsResultParser.java 125 core/src/main/java/org/apache/iceberg/metrics/ScanMetricsUtil.java 31 core/src/main/java/org/apache/iceberg/metrics/ScanReport.java 16 core/src/main/java/org/apache/iceberg/metrics/ScanReportParser.java 77 core/src/main/java/org/apache/iceberg/metrics/TimerResult.java 29 core/src/main/java/org/apache/iceberg/metrics/TimerResultParser.java 96 core/src/main/java/org/apache/iceberg/puffin/Blob.java 67 core/src/main/java/org/apache/iceberg/puffin/BlobMetadata.java 63 core/src/main/java/org/apache/iceberg/puffin/FileMetadata.java 22 core/src/main/java/org/apache/iceberg/puffin/FileMetadataParser.java 90 core/src/main/java/org/apache/iceberg/puffin/Puffin.java 69 core/src/main/java/org/apache/iceberg/puffin/PuffinCompressionCodec.java 37 core/src/main/java/org/apache/iceberg/puffin/PuffinFormat.java 123 core/src/main/java/org/apache/iceberg/puffin/PuffinReader.java 167 core/src/main/java/org/apache/iceberg/puffin/PuffinWriter.java 159 core/src/main/java/org/apache/iceberg/puffin/StandardBlobTypes.java 6 core/src/main/java/org/apache/iceberg/puffin/StandardPuffinProperties.java 5 core/src/main/java/org/apache/iceberg/rest/BaseHTTPClient.java 86 core/src/main/java/org/apache/iceberg/rest/CatalogHandlers.java 459 core/src/main/java/org/apache/iceberg/rest/Endpoint.java 115 core/src/main/java/org/apache/iceberg/rest/ErrorHandler.java 6 core/src/main/java/org/apache/iceberg/rest/ErrorHandlers.java 215 core/src/main/java/org/apache/iceberg/rest/ExponentialHttpRequestRetryStrategy.java 96 core/src/main/java/org/apache/iceberg/rest/HTTPClient.java 373 core/src/main/java/org/apache/iceberg/rest/HTTPHeaders.java 64 core/src/main/java/org/apache/iceberg/rest/HTTPRequest.java 86 core/src/main/java/org/apache/iceberg/rest/RESTCatalog.java 249 core/src/main/java/org/apache/iceberg/rest/RESTClient.java 126 core/src/main/java/org/apache/iceberg/rest/RESTMessage.java 4 core/src/main/java/org/apache/iceberg/rest/RESTMetricsReporter.java 37 core/src/main/java/org/apache/iceberg/rest/RESTObjectMapper.java 32 core/src/main/java/org/apache/iceberg/rest/RESTRequest.java 2 core/src/main/java/org/apache/iceberg/rest/RESTResponse.java 2 core/src/main/java/org/apache/iceberg/rest/RESTSerializers.java 412 core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java 1177 core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java 193 core/src/main/java/org/apache/iceberg/rest/RESTUtil.java 113 core/src/main/java/org/apache/iceberg/rest/RESTViewOperations.java 59 core/src/main/java/org/apache/iceberg/rest/ResourcePaths.java 96 core/src/main/java/org/apache/iceberg/rest/auth/AuthConfig.java 72 core/src/main/java/org/apache/iceberg/rest/auth/AuthManager.java 23 core/src/main/java/org/apache/iceberg/rest/auth/AuthManagers.java 101 core/src/main/java/org/apache/iceberg/rest/auth/AuthProperties.java 21 core/src/main/java/org/apache/iceberg/rest/auth/AuthSession.java 16 core/src/main/java/org/apache/iceberg/rest/auth/AuthSessionCache.java 81 core/src/main/java/org/apache/iceberg/rest/auth/BasicAuthManager.java 27 core/src/main/java/org/apache/iceberg/rest/auth/DefaultAuthSession.java 24 core/src/main/java/org/apache/iceberg/rest/auth/NoopAuthManager.java 14 core/src/main/java/org/apache/iceberg/rest/auth/OAuth2Manager.java 213 core/src/main/java/org/apache/iceberg/rest/auth/OAuth2Properties.java 27 core/src/main/java/org/apache/iceberg/rest/auth/OAuth2Util.java 622 core/src/main/java/org/apache/iceberg/rest/auth/RefreshingAuthManager.java 57 core/src/main/java/org/apache/iceberg/rest/credentials/Credential.java 14 core/src/main/java/org/apache/iceberg/rest/credentials/CredentialParser.java 34 core/src/main/java/org/apache/iceberg/rest/requests/CommitTransactionRequest.java 24 core/src/main/java/org/apache/iceberg/rest/requests/CommitTransactionRequestParser.java 45 core/src/main/java/org/apache/iceberg/rest/requests/CreateNamespaceRequest.java 63 core/src/main/java/org/apache/iceberg/rest/requests/CreateTableRequest.java 139 core/src/main/java/org/apache/iceberg/rest/requests/CreateViewRequest.java 19 core/src/main/java/org/apache/iceberg/rest/requests/CreateViewRequestParser.java 60 core/src/main/java/org/apache/iceberg/rest/requests/RegisterTableRequest.java 11 core/src/main/java/org/apache/iceberg/rest/requests/RegisterTableRequestParser.java 37 core/src/main/java/org/apache/iceberg/rest/requests/RenameTableRequest.java 56 core/src/main/java/org/apache/iceberg/rest/requests/ReportMetricsRequest.java 44 core/src/main/java/org/apache/iceberg/rest/requests/ReportMetricsRequestParser.java 62 core/src/main/java/org/apache/iceberg/rest/requests/UpdateNamespacePropertiesRequest.java 88 core/src/main/java/org/apache/iceberg/rest/requests/UpdateTableRequest.java 50 core/src/main/java/org/apache/iceberg/rest/requests/UpdateTableRequestParser.java 72 core/src/main/java/org/apache/iceberg/rest/responses/ConfigResponse.java 100 core/src/main/java/org/apache/iceberg/rest/responses/ConfigResponseParser.java 53 core/src/main/java/org/apache/iceberg/rest/responses/CreateNamespaceResponse.java 63 core/src/main/java/org/apache/iceberg/rest/responses/ErrorResponse.java 91 core/src/main/java/org/apache/iceberg/rest/responses/ErrorResponseParser.java 55 core/src/main/java/org/apache/iceberg/rest/responses/GetNamespaceResponse.java 63 core/src/main/java/org/apache/iceberg/rest/responses/ListNamespacesResponse.java 62 core/src/main/java/org/apache/iceberg/rest/responses/ListTablesResponse.java 62 core/src/main/java/org/apache/iceberg/rest/responses/LoadCredentialsResponse.java 12 core/src/main/java/org/apache/iceberg/rest/responses/LoadCredentialsResponseParser.java 44 core/src/main/java/org/apache/iceberg/rest/responses/LoadTableResponse.java 94 core/src/main/java/org/apache/iceberg/rest/responses/LoadTableResponseParser.java 65 core/src/main/java/org/apache/iceberg/rest/responses/LoadViewResponse.java 14 core/src/main/java/org/apache/iceberg/rest/responses/LoadViewResponseParser.java 48 core/src/main/java/org/apache/iceberg/rest/responses/OAuthErrorResponseParser.java 25 core/src/main/java/org/apache/iceberg/rest/responses/OAuthTokenResponse.java 90 core/src/main/java/org/apache/iceberg/rest/responses/UpdateNamespacePropertiesResponse.java 89 core/src/main/java/org/apache/iceberg/schema/SchemaWithPartnerVisitor.java 122 core/src/main/java/org/apache/iceberg/schema/UnionByNameVisitor.java 185 core/src/main/java/org/apache/iceberg/types/FixupTypes.java 118 core/src/main/java/org/apache/iceberg/util/ArrayUtil.java 189 core/src/main/java/org/apache/iceberg/util/BinPacking.java 159 core/src/main/java/org/apache/iceberg/util/ContentFileUtil.java 141 core/src/main/java/org/apache/iceberg/util/CopySortOrderFields.java 53 core/src/main/java/org/apache/iceberg/util/DecimalUtil.java 35 core/src/main/java/org/apache/iceberg/util/EnvironmentUtil.java 27 core/src/main/java/org/apache/iceberg/util/Exceptions.java 28 core/src/main/java/org/apache/iceberg/util/Filter.java 21 core/src/main/java/org/apache/iceberg/util/JsonUtil.java 425 core/src/main/java/org/apache/iceberg/util/LocationUtil.java 14 core/src/main/java/org/apache/iceberg/util/LockManagers.java 241 core/src/main/java/org/apache/iceberg/util/ManifestFileUtil.java 110 core/src/main/java/org/apache/iceberg/util/Pair.java 94 core/src/main/java/org/apache/iceberg/util/ParallelIterable.java 226 core/src/main/java/org/apache/iceberg/util/PartitionMap.java 183 core/src/main/java/org/apache/iceberg/util/PartitionSet.java 169 core/src/main/java/org/apache/iceberg/util/PartitionUtil.java 81 core/src/main/java/org/apache/iceberg/util/PropertyUtil.java 167 core/src/main/java/org/apache/iceberg/util/SerializableMap.java 100 core/src/main/java/org/apache/iceberg/util/SerializableSupplier.java 4 core/src/main/java/org/apache/iceberg/util/SerializationUtil.java 57 core/src/main/java/org/apache/iceberg/util/SnapshotUtil.java 280 core/src/main/java/org/apache/iceberg/util/SortOrderUtil.java 85 core/src/main/java/org/apache/iceberg/util/SortedMerge.java 91 core/src/main/java/org/apache/iceberg/util/StructLikeMap.java 130 core/src/main/java/org/apache/iceberg/util/StructLikeSet.java 136 core/src/main/java/org/apache/iceberg/util/StructLikeUtil.java 37 core/src/main/java/org/apache/iceberg/util/StructLikeWrapper.java 57 core/src/main/java/org/apache/iceberg/util/TableScanUtil.java 185 core/src/main/java/org/apache/iceberg/util/Tasks.java 475 core/src/main/java/org/apache/iceberg/util/ThreadPools.java 50 core/src/main/java/org/apache/iceberg/util/WapUtil.java 37 core/src/main/java/org/apache/iceberg/util/ZOrderByteUtils.java 111 core/src/main/java/org/apache/iceberg/variants/PrimitiveWrapper.java 219 core/src/main/java/org/apache/iceberg/variants/ShreddedObject.java 185 core/src/main/java/org/apache/iceberg/variants/ValueArray.java 87 core/src/main/java/org/apache/iceberg/variants/VariantVisitor.java 53 core/src/main/java/org/apache/iceberg/variants/Variants.java 170 core/src/main/java/org/apache/iceberg/view/BaseMetastoreViewCatalog.java 227 core/src/main/java/org/apache/iceberg/view/BaseSQLViewRepresentation.java 10 core/src/main/java/org/apache/iceberg/view/BaseView.java 88 core/src/main/java/org/apache/iceberg/view/BaseViewHistoryEntry.java 9 core/src/main/java/org/apache/iceberg/view/BaseViewOperations.java 167 core/src/main/java/org/apache/iceberg/view/BaseViewVersion.java 19 core/src/main/java/org/apache/iceberg/view/PropertiesUpdate.java 69 core/src/main/java/org/apache/iceberg/view/SQLViewRepresentationParser.java 36 core/src/main/java/org/apache/iceberg/view/SetViewLocation.java 51 core/src/main/java/org/apache/iceberg/view/UnknownViewRepresentation.java 4 core/src/main/java/org/apache/iceberg/view/ViewHistoryEntryParser.java 33 core/src/main/java/org/apache/iceberg/view/ViewMetadata.java 441 core/src/main/java/org/apache/iceberg/view/ViewMetadataParser.java 152 core/src/main/java/org/apache/iceberg/view/ViewOperations.java 6 core/src/main/java/org/apache/iceberg/view/ViewProperties.java 12 core/src/main/java/org/apache/iceberg/view/ViewRepresentationParser.java 42 core/src/main/java/org/apache/iceberg/view/ViewUtil.java 8 core/src/main/java/org/apache/iceberg/view/ViewVersionParser.java 76 core/src/main/java/org/apache/iceberg/view/ViewVersionReplace.java 96 data/src/jmh/java/org/apache/iceberg/GenericOrcReaderBenchmark.java 24 data/src/jmh/java/org/apache/iceberg/GenericParquetReaderBenchmark.java 25 data/src/jmh/java/org/apache/iceberg/ReaderBenchmark.java 70 data/src/main/java/org/apache/iceberg/data/BaseDeleteLoader.java 246 data/src/main/java/org/apache/iceberg/data/BaseFileWriterFactory.java 234 data/src/main/java/org/apache/iceberg/data/DeleteFilter.java 243 data/src/main/java/org/apache/iceberg/data/DeleteLoader.java 9 data/src/main/java/org/apache/iceberg/data/GenericAppenderFactory.java 248 data/src/main/java/org/apache/iceberg/data/GenericDeleteFilter.java 28 data/src/main/java/org/apache/iceberg/data/GenericFileWriterFactory.java 149 data/src/main/java/org/apache/iceberg/data/GenericReader.java 128 data/src/main/java/org/apache/iceberg/data/IcebergGenerics.java 63 data/src/main/java/org/apache/iceberg/data/InternalRecordWrapper.java 78 data/src/main/java/org/apache/iceberg/data/PartitionStatsHandler.java 203 data/src/main/java/org/apache/iceberg/data/TableMigrationUtil.java 168 data/src/main/java/org/apache/iceberg/data/TableScanIterable.java 26 dell/src/main/java/org/apache/iceberg/dell/DellClientFactories.java 56 dell/src/main/java/org/apache/iceberg/dell/DellClientFactory.java 8 dell/src/main/java/org/apache/iceberg/dell/DellProperties.java 36 dell/src/main/java/org/apache/iceberg/dell/ecs/BaseEcsFile.java 56 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsAppendOutputStream.java 88 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsCatalog.java 386 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsFileIO.java 77 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsInputFile.java 32 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsOutputFile.java 43 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsSeekableInputStream.java 74 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsTableOperations.java 76 dell/src/main/java/org/apache/iceberg/dell/ecs/EcsURI.java 42 dell/src/main/java/org/apache/iceberg/dell/ecs/PropertiesSerDesUtil.java 58 delta-lake/src/integration/java/org/apache/iceberg/delta/DeltaLakeToIcebergMigrationSparkIntegration.java 29 delta-lake/src/integration/java/org/apache/iceberg/delta/SparkDeltaLakeSnapshotTestBase.java 49 delta-lake/src/integration/java/org/apache/iceberg/delta/TestSnapshotDeltaLakeTable.java 480 delta-lake/src/main/java/org/apache/iceberg/delta/BaseSnapshotDeltaLakeTableAction.java 336 delta-lake/src/main/java/org/apache/iceberg/delta/DeltaLakeDataTypeVisitor.java 34 delta-lake/src/main/java/org/apache/iceberg/delta/DeltaLakeToIcebergMigrationActionsProvider.java 18 delta-lake/src/main/java/org/apache/iceberg/delta/DeltaLakeTypeToType.java 115 delta-lake/src/main/java/org/apache/iceberg/delta/SnapshotDeltaLakeTable.java 21 doap.rdf 41 flink/v1.19/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java 2 flink/v1.19/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java 163 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java 158 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java 711 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java 139 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java 214 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java 63 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkCreateTableOptions.java 82 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java 167 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java 10 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java 200 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java 23 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java 166 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java 79 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkRowData.java 19 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java 119 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java 26 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java 152 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java 49 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java 162 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java 44 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java 100 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java 101 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java 103 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java 107 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java 25 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java 46 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java 48 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java 131 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java 101 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java 218 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java 130 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java 244 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java 699 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java 508 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkPlannedAvroReader.java 149 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java 112 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java 267 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java 213 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java 176 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java 243 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java 77 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java 244 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshots.java 69 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/JdbcLockFactory.java 247 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java 120 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java 126 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TableMaintenance.java 224 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TaskResult.java 37 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/Trigger.java 38 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TriggerLockFactory.java 17 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java 152 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java 164 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteRunner.java 211 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DeleteFilesProcessor.java 89 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ExpireSnapshotsProcessor.java 95 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java 88 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java 6 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java 153 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java 136 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java 192 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java 40 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java 58 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java 109 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java 248 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java 28 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java 94 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java 39 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java 37 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java 78 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java 58 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java 66 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java 40 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java 82 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java 49 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java 236 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java 217 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java 109 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java 481 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java 17 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java 57 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java 39 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java 227 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java 354 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java 48 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java 472 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java 77 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java 75 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java 58 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java 87 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java 67 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java 30 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java 67 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java 198 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java 64 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java 7 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java 46 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java 38 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java 209 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java 89 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java 141 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java 12 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java 451 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java 43 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java 191 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java 70 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java 158 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatistics.java 72 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java 153 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/KeyAssignment.java 105 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapAssignment.java 173 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java 55 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java 51 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RangePartitioner.java 62 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RequestGlobalStatisticsEvent.java 14 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchDataStatistics.java 53 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitioner.java 28 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchUtil.java 76 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java 338 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySketchSerializer.java 105 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeyUtil.java 33 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsEvent.java 43 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecord.java 66 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java 163 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordTypeInformation.java 81 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsType.java 6 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java 105 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java 20 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java 105 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java 24 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java 10 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java 104 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java 24 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java 227 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java 145 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java 516 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java 189 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java 194 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java 131 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java 40 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java 502 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java 42 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java 195 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java 163 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java 9 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java 79 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java 40 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java 19 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java 14 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java 22 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java 8 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java 12 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java 141 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java 28 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java 124 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java 7 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java 185 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java 51 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java 49 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java 60 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java 38 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java 156 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java 26 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java 95 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java 89 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java 44 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java 74 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java 55 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java 87 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java 11 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java 19 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java 49 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java 34 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java 115 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/LimitableDataIterator.java 32 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java 55 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java 58 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java 41 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java 11 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java 37 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java 6 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordLimiter.java 21 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowConverter.java 40 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java 7 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java 87 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java 43 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java 19 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java 6 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java 37 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java 167 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java 39 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java 15 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java 6 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java 4 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java 128 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java 44 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java 27 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java 20 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java 194 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java 19 flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java 30 flink/v1.20/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java 2 flink/v1.20/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java 163 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java 158 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java 711 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java 139 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java 214 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java 63 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkCreateTableOptions.java 82 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java 167 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java 10 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java 200 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java 23 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java 166 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java 79 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkRowData.java 19 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java 119 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java 26 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java 152 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java 49 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java 162 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java 44 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java 100 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java 101 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java 103 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java 107 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java 25 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java 46 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java 48 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java 131 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java 101 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java 218 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java 130 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java 244 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java 699 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java 508 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkPlannedAvroReader.java 149 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java 112 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java 267 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java 213 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java 172 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java 243 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java 77 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java 244 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshots.java 69 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/JdbcLockFactory.java 247 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java 120 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java 126 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TableMaintenance.java 224 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TaskResult.java 37 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/Trigger.java 38 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TriggerLockFactory.java 17 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java 152 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java 164 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteRunner.java 211 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DeleteFilesProcessor.java 89 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ExpireSnapshotsProcessor.java 95 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java 88 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java 6 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java 153 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java 136 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java 192 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java 40 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java 58 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java 109 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java 248 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java 28 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java 94 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java 39 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java 37 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java 78 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java 58 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java 66 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java 40 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java 82 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java 49 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java 236 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java 217 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java 109 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java 493 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java 17 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java 57 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java 39 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java 228 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java 354 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java 48 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java 484 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkBuilder.java 43 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java 77 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java 75 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java 58 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java 87 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java 67 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java 30 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java 67 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java 198 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java 64 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java 7 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java 46 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java 38 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java 209 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java 89 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java 141 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java 12 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java 451 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java 43 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java 191 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java 70 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java 158 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatistics.java 72 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java 153 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/KeyAssignment.java 105 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapAssignment.java 173 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java 55 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java 51 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RangePartitioner.java 62 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RequestGlobalStatisticsEvent.java 14 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchDataStatistics.java 53 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitioner.java 28 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchUtil.java 76 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java 333 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySketchSerializer.java 105 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeyUtil.java 32 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsEvent.java 43 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecord.java 66 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java 163 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordTypeInformation.java 81 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsType.java 6 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java 105 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java 20 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java 105 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java 24 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java 10 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java 104 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java 24 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java 227 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java 145 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java 516 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java 189 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java 194 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java 131 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java 40 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java 502 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java 42 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java 195 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java 163 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java 9 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java 79 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java 40 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java 19 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java 14 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java 22 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java 8 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java 12 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java 141 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java 28 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java 124 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java 7 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java 185 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java 51 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java 49 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java 60 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java 38 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java 156 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java 26 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java 95 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java 89 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java 44 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java 74 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java 55 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java 87 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java 11 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java 19 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java 49 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java 34 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java 115 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/LimitableDataIterator.java 32 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java 55 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java 58 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java 41 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java 11 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java 37 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java 6 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordLimiter.java 21 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowConverter.java 40 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java 7 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java 87 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java 43 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java 19 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java 6 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java 37 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java 167 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java 39 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java 15 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java 6 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java 4 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java 128 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java 44 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java 27 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java 20 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java 194 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java 19 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java 30 flink/v2.0/flink-runtime/src/integration/java/org/apache/iceberg/flink/IcebergConnectorSmokeTest.java 2 flink/v2.0/flink/src/jmh/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitionerBenchmark.java 163 flink/v2.0/flink/src/main/java/org/apache/flink/table/api/runtime/types/FlinkScalaKryoInstantiator.java 2 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java 158 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalog.java 714 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java 139 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkConfParser.java 214 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkConfigOptions.java 63 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkCreateTableOptions.java 82 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkDynamicTableFactory.java 166 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java 10 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkFilters.java 200 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkFixupTypes.java 23 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkReadConf.java 166 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkReadOptions.java 79 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkRowData.java 19 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkSchemaUtil.java 119 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkSourceFilter.java 26 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java 152 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeVisitor.java 49 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java 162 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java 44 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java 100 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/RowDataWrapper.java 101 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java 103 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/TypeToFlinkType.java 107 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/actions/Actions.java 25 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/actions/RewriteDataFilesAction.java 46 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/AvroWithFlinkSchemaVisitor.java 48 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkAvroWriter.java 131 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java 101 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java 218 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java 130 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java 244 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java 699 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java 508 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkPlannedAvroReader.java 149 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java 112 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueReaders.java 267 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/FlinkValueWriters.java 213 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/ParquetWithFlinkSchemaVisitor.java 172 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/RowDataProjection.java 243 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/RowDataUtil.java 77 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java 244 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/ExpireSnapshots.java 69 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/JdbcLockFactory.java 247 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java 120 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java 126 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TableMaintenance.java 224 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TaskResult.java 37 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/Trigger.java 38 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TriggerLockFactory.java 17 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java 152 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java 164 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteRunner.java 211 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DeleteFilesProcessor.java 89 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/ExpireSnapshotsProcessor.java 95 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java 88 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java 6 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java 153 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java 136 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java 192 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java 40 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java 58 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerEvaluator.java 109 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TriggerManager.java 248 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java 28 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/BaseDeltaTaskWriter.java 94 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionKeySelector.java 39 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitioner.java 37 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/BucketPartitionerUtil.java 78 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/CachingTableSupplier.java 58 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/CommitSummary.java 66 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifests.java 40 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/DeltaManifestsSerializer.java 82 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/EqualityFieldKeySelector.java 49 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java 236 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkFileWriterFactory.java 217 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkManifestUtil.java 109 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java 495 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java 17 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java 57 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java 39 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java 228 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java 357 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterFactory.java 46 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitterMetrics.java 48 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java 485 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkBuilder.java 43 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java 77 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriter.java 73 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergStreamWriterMetrics.java 58 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java 87 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/ManifestOutputFileFactory.java 67 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionKeySelector.java 30 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/PartitionedDeltaWriter.java 67 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/RowDataTaskWriterFactory.java 198 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java 64 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/TaskWriterFactory.java 7 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/UnpartitionedDeltaWriter.java 46 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java 38 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java 209 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java 89 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatisticsSerializer.java 141 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatistics.java 12 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java 451 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinatorProvider.java 43 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperator.java 194 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOperatorFactory.java 68 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsSerializer.java 158 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatistics.java 72 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/GlobalStatisticsSerializer.java 153 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/KeyAssignment.java 105 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapAssignment.java 173 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatistics.java 55 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapRangePartitioner.java 51 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RangePartitioner.java 62 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/RequestGlobalStatisticsEvent.java 14 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchDataStatistics.java 53 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchRangePartitioner.java 28 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SketchUtil.java 76 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySerializer.java 333 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeySketchSerializer.java 105 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/SortKeyUtil.java 32 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsEvent.java 43 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecord.java 66 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordSerializer.java 163 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsOrRecordTypeInformation.java 76 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsType.java 6 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java 105 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/AvroGenericRecordFileScanTaskReader.java 20 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/DataIterator.java 105 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java 24 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java 10 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputFormat.java 104 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/FlinkInputSplit.java 24 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java 227 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSplitPlanner.java 145 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java 516 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java 189 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java 194 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java 131 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/RowDataToAvroGenericRecordConverter.java 40 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java 502 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java 42 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/StreamingMonitorFunction.java 195 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/StreamingReaderOperator.java 164 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/StreamingStartingStrategy.java 9 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/DefaultSplitAssigner.java 79 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/GetSplitResult.java 40 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/OrderedSplitAssignerFactory.java 19 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SimpleSplitAssignerFactory.java 14 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssigner.java 22 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java 8 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java 12 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/AbstractIcebergEnumerator.java 141 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousEnumerationResult.java 28 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousIcebergEnumerator.java 124 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlanner.java 7 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/ContinuousSplitPlannerImpl.java 185 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/EnumerationHistory.java 51 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPosition.java 49 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorPositionSerializer.java 60 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorState.java 38 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/IcebergEnumeratorStateSerializer.java 156 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/enumerator/StaticIcebergEnumerator.java 26 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayBatchRecords.java 95 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ArrayPoolDataIteratorBatcher.java 89 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordConverter.java 44 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java 74 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ColumnStatsWatermarkExtractor.java 55 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ConverterReaderFunction.java 87 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorBatcher.java 11 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorReaderFunction.java 19 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReader.java 49 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceReaderMetrics.java 34 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java 115 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/LimitableDataIterator.java 32 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListBatchRecords.java 55 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ListDataIteratorBatcher.java 58 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/MetaDataReaderFunction.java 41 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/ReaderFunction.java 11 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordAndPosition.java 37 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordFactory.java 6 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RecordLimiter.java 21 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowConverter.java 40 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataConverter.java 7 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java 87 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataRecordFactory.java 43 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/SerializableRecordEmitter.java 19 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/SplitWatermarkExtractor.java 6 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/reader/WatermarkExtractorRecordEmitter.java 37 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplit.java 167 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitSerializer.java 39 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitState.java 15 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/IcebergSourceSplitStatus.java 6 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializableComparator.java 4 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/SerializerHelper.java 128 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitComparators.java 44 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/source/split/SplitRequestEvent.java 27 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/util/ElapsedTimeGauge.java 20 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/util/FlinkAlterTableUtil.java 194 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/util/FlinkCompatibilityUtil.java 19 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/util/FlinkPackage.java 30 gcp/src/main/java/org/apache/iceberg/gcp/GCPProperties.java 128 gcp/src/main/java/org/apache/iceberg/gcp/gcs/BaseGCSFile.java 51 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSFileIO.java 210 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSInputFile.java 43 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSInputStream.java 150 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSLocation.java 34 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSOutputFile.java 42 gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSOutputStream.java 99 gcp/src/main/java/org/apache/iceberg/gcp/gcs/OAuth2RefreshCredentialsHandler.java 102 gcp/src/main/java/org/apache/iceberg/gcp/gcs/PrefixedStorage.java 84 gradle/libs.versions.toml 213 hive-metastore/src/main/java/org/apache/iceberg/hive/CachedClientPool.java 158 hive-metastore/src/main/java/org/apache/iceberg/hive/HMSTablePropertyHelper.java 210 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalog.java 704 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveClientPool.java 85 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveHadoopUtil.java 23 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveLock.java 6 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveOperationsBase.java 164 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveSchemaConverter.java 124 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveSchemaUtil.java 99 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java 271 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveVersion.java 42 hive-metastore/src/main/java/org/apache/iceberg/hive/HiveViewOperations.java 290 hive-metastore/src/main/java/org/apache/iceberg/hive/LockException.java 12 hive-metastore/src/main/java/org/apache/iceberg/hive/MetastoreLock.java 433 hive-metastore/src/main/java/org/apache/iceberg/hive/MetastoreUtil.java 55 hive-metastore/src/main/java/org/apache/iceberg/hive/NoLock.java 18 hive-metastore/src/main/java/org/apache/iceberg/hive/RuntimeMetaException.java 16 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/AvroUtil.java 67 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitComplete.java 72 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitToTable.java 102 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataComplete.java 76 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataWritten.java 118 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Event.java 110 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Payload.java 7 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/PayloadType.java 15 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/StartCommit.java 56 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TableReference.java 107 kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TopicPartitionOffset.java 91 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationDynamicTableTest.java 53 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationMultiTableTest.java 57 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationTest.java 123 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationTestBase.java 180 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/KafkaConnectUtils.java 95 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestContext.java 95 kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestEvent.java 82 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/CdcConstants.java 13 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/CopyValue.java 92 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/DebeziumTransform.java 187 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/DmsTransform.java 70 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapException.java 9 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapTransform.java 120 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapUtils.java 256 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/KafkaMetadataTransform.java 242 kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/MongoDebeziumTransform.java 234 kafka-connect/kafka-connect-transforms/src/main/java/org/debezium/connector/mongodb/transforms/ArrayEncoding.java 30 kafka-connect/kafka-connect-transforms/src/main/java/org/debezium/connector/mongodb/transforms/MongoDataConverter.java 438 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/CatalogUtils.java 66 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/Committer.java 23 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/CommitterFactory.java 8 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkConfig.java 383 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkConnector.java 43 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkTask.java 72 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/TableSinkConfig.java 28 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Channel.java 123 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitState.java 126 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitterImpl.java 157 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Coordinator.java 264 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CoordinatorThread.java 42 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Envelope.java 21 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/KafkaClientFactory.java 44 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/KafkaUtils.java 70 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/NotRunningException.java 6 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Worker.java 88 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriter.java 95 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriterFactory.java 104 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriterResult.java 34 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/NoOpWriter.java 16 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/Offset.java 28 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/PartitionedAppendWriter.java 32 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordConverter.java 468 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordUtils.java 140 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordWriter.java 8 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SchemaUpdate.java 80 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SchemaUtils.java 300 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SinkWriter.java 103 kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SinkWriterResult.java 19 mr/src/main/java/org/apache/iceberg/mr/Catalogs.java 150 mr/src/main/java/org/apache/iceberg/mr/InputFormatConfig.java 136 mr/src/main/java/org/apache/iceberg/mr/mapred/AbstractMapredIcebergRecordReader.java 45 mr/src/main/java/org/apache/iceberg/mr/mapred/Container.java 21 mr/src/main/java/org/apache/iceberg/mr/mapred/MapredIcebergInputFormat.java 122 mr/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java 359 mr/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergSplit.java 68 mr/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergSplitContainer.java 4 nessie/src/main/java/org/apache/iceberg/nessie/NessieCatalog.java 327 nessie/src/main/java/org/apache/iceberg/nessie/NessieIcebergClient.java 687 nessie/src/main/java/org/apache/iceberg/nessie/NessieTableOperations.java 109 nessie/src/main/java/org/apache/iceberg/nessie/NessieUtil.java 255 nessie/src/main/java/org/apache/iceberg/nessie/NessieViewOperations.java 101 nessie/src/main/java/org/apache/iceberg/nessie/UpdateableReference.java 43 open-api/rest-catalog-open-api.yaml 4419 open-api/src/testFixtures/java/org/apache/iceberg/rest/RCKUtils.java 97 open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTCatalogServer.java 88 open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTServerCatalogAdapter.java 55 open-api/src/testFixtures/java/org/apache/iceberg/rest/RESTServerExtension.java 47 orc/src/main/java/org/apache/iceberg/data/orc/GenericOrcReader.java 133 orc/src/main/java/org/apache/iceberg/data/orc/GenericOrcReaders.java 235 orc/src/main/java/org/apache/iceberg/data/orc/GenericOrcWriter.java 132 orc/src/main/java/org/apache/iceberg/data/orc/GenericOrcWriters.java 548 orc/src/main/java/org/apache/iceberg/orc/ApplyNameMapping.java 71 orc/src/main/java/org/apache/iceberg/orc/EstimateOrcAvgWidthVisitor.java 52 orc/src/main/java/org/apache/iceberg/orc/ExpressionToSearchArgument.java 270 orc/src/main/java/org/apache/iceberg/orc/FileIOFSUtil.java 123 orc/src/main/java/org/apache/iceberg/orc/HasIds.java 27 orc/src/main/java/org/apache/iceberg/orc/IdToOrcName.java 89 orc/src/main/java/org/apache/iceberg/orc/ORC.java 671 orc/src/main/java/org/apache/iceberg/orc/ORCSchemaUtil.java 398 orc/src/main/java/org/apache/iceberg/orc/OrcBatchReader.java 6 orc/src/main/java/org/apache/iceberg/orc/OrcFileAppender.java 141 orc/src/main/java/org/apache/iceberg/orc/OrcIterable.java 149 orc/src/main/java/org/apache/iceberg/orc/OrcMetrics.java 313 orc/src/main/java/org/apache/iceberg/orc/OrcRowReader.java 6 orc/src/main/java/org/apache/iceberg/orc/OrcRowWriter.java 13 orc/src/main/java/org/apache/iceberg/orc/OrcSchemaVisitor.java 152 orc/src/main/java/org/apache/iceberg/orc/OrcSchemaWithTypeVisitor.java 86 orc/src/main/java/org/apache/iceberg/orc/OrcToIcebergVisitor.java 201 orc/src/main/java/org/apache/iceberg/orc/OrcValueReader.java 14 orc/src/main/java/org/apache/iceberg/orc/OrcValueReaders.java 175 orc/src/main/java/org/apache/iceberg/orc/OrcValueWriter.java 22 orc/src/main/java/org/apache/iceberg/orc/RemoveIds.java 37 orc/src/main/java/org/apache/iceberg/orc/VectorizedRowBatchIterator.java 48 parquet/src/main/java/org/apache/iceberg/InternalParquet.java 19 parquet/src/main/java/org/apache/iceberg/data/parquet/BaseParquetReaders.java 307 parquet/src/main/java/org/apache/iceberg/data/parquet/BaseParquetWriter.java 217 parquet/src/main/java/org/apache/iceberg/data/parquet/GenericParquetReaders.java 201 parquet/src/main/java/org/apache/iceberg/data/parquet/GenericParquetWriter.java 127 parquet/src/main/java/org/apache/iceberg/data/parquet/InternalReader.java 46 parquet/src/main/java/org/apache/iceberg/data/parquet/InternalWriter.java 45 parquet/src/main/java/org/apache/iceberg/parquet/ApplyNameMapping.java 114 parquet/src/main/java/org/apache/iceberg/parquet/BaseColumnIterator.java 46 parquet/src/main/java/org/apache/iceberg/parquet/BasePageIterator.java 166 parquet/src/main/java/org/apache/iceberg/parquet/ColumnIterator.java 131 parquet/src/main/java/org/apache/iceberg/parquet/ColumnWriter.java 101 parquet/src/main/java/org/apache/iceberg/parquet/MessageTypeToType.java 188 parquet/src/main/java/org/apache/iceberg/parquet/PageIterator.java 241 parquet/src/main/java/org/apache/iceberg/parquet/Parquet.java 1207 parquet/src/main/java/org/apache/iceberg/parquet/ParquetAvro.java 311 parquet/src/main/java/org/apache/iceberg/parquet/ParquetAvroReader.java 2 parquet/src/main/java/org/apache/iceberg/parquet/ParquetAvroValueReaders.java 304 parquet/src/main/java/org/apache/iceberg/parquet/ParquetAvroWriter.java 152 parquet/src/main/java/org/apache/iceberg/parquet/ParquetBloomRowGroupFilter.java 275 parquet/src/main/java/org/apache/iceberg/parquet/ParquetCodecFactory.java 57 parquet/src/main/java/org/apache/iceberg/parquet/ParquetConversions.java 103 parquet/src/main/java/org/apache/iceberg/parquet/ParquetDictionaryRowGroupFilter.java 355 parquet/src/main/java/org/apache/iceberg/parquet/ParquetFilters.java 208 parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java 140 parquet/src/main/java/org/apache/iceberg/parquet/ParquetIterable.java 67 parquet/src/main/java/org/apache/iceberg/parquet/ParquetMetrics.java 524 parquet/src/main/java/org/apache/iceberg/parquet/ParquetMetricsRowGroupFilter.java 412 parquet/src/main/java/org/apache/iceberg/parquet/ParquetReadSupport.java 83 parquet/src/main/java/org/apache/iceberg/parquet/ParquetReader.java 124 parquet/src/main/java/org/apache/iceberg/parquet/ParquetSchemaUtil.java 132 parquet/src/main/java/org/apache/iceberg/parquet/ParquetTypeVisitor.java 197 parquet/src/main/java/org/apache/iceberg/parquet/ParquetUtil.java 129 parquet/src/main/java/org/apache/iceberg/parquet/ParquetValueReader.java 12 parquet/src/main/java/org/apache/iceberg/parquet/ParquetValueReaders.java 915 parquet/src/main/java/org/apache/iceberg/parquet/ParquetValueWriter.java 13 parquet/src/main/java/org/apache/iceberg/parquet/ParquetValueWriters.java 585 parquet/src/main/java/org/apache/iceberg/parquet/ParquetVariantReaders.java 359 parquet/src/main/java/org/apache/iceberg/parquet/ParquetVariantUtil.java 428 parquet/src/main/java/org/apache/iceberg/parquet/ParquetVariantVisitor.java 133 parquet/src/main/java/org/apache/iceberg/parquet/ParquetVariantWriters.java 354 parquet/src/main/java/org/apache/iceberg/parquet/ParquetWriteAdapter.java 54 parquet/src/main/java/org/apache/iceberg/parquet/ParquetWriteSupport.java 44 parquet/src/main/java/org/apache/iceberg/parquet/ParquetWriter.java 212 parquet/src/main/java/org/apache/iceberg/parquet/PruneColumns.java 143 parquet/src/main/java/org/apache/iceberg/parquet/ReadConf.java 176 parquet/src/main/java/org/apache/iceberg/parquet/RemoveIds.java 57 parquet/src/main/java/org/apache/iceberg/parquet/TripleIterator.java 26 parquet/src/main/java/org/apache/iceberg/parquet/TripleWriter.java 24 parquet/src/main/java/org/apache/iceberg/parquet/TypeToMessageType.java 231 parquet/src/main/java/org/apache/iceberg/parquet/TypeWithSchemaVisitor.java 199 parquet/src/main/java/org/apache/iceberg/parquet/ValuesAsBytesReader.java 74 parquet/src/main/java/org/apache/iceberg/parquet/VariantReaderBuilder.java 228 parquet/src/main/java/org/apache/iceberg/parquet/VariantShreddingFunction.java 7 parquet/src/main/java/org/apache/iceberg/parquet/VariantWriterBuilder.java 235 parquet/src/main/java/org/apache/iceberg/parquet/VectorizedParquetReader.java 142 parquet/src/main/java/org/apache/iceberg/parquet/VectorizedReader.java 15 project/scalastyle_config.xml 108 site/overrides/home.html 291 site/overrides/partials/footer.html 120 site/overrides/partials/header.html 51 snowflake/src/main/java/org/apache/iceberg/snowflake/JdbcSnowflakeClient.java 306 snowflake/src/main/java/org/apache/iceberg/snowflake/NamespaceHelpers.java 61 snowflake/src/main/java/org/apache/iceberg/snowflake/SnowflakeCatalog.java 197 snowflake/src/main/java/org/apache/iceberg/snowflake/SnowflakeClient.java 11 snowflake/src/main/java/org/apache/iceberg/snowflake/SnowflakeIdentifier.java 84 snowflake/src/main/java/org/apache/iceberg/snowflake/SnowflakeTableMetadata.java 88 snowflake/src/main/java/org/apache/iceberg/snowflake/SnowflakeTableOperations.java 66 spark/v3.4/spark-extensions/src/jmh/java/org/apache/iceberg/DeleteFileIndexBenchmark.java 176 spark/v3.4/spark-extensions/src/jmh/java/org/apache/iceberg/spark/MergeCardinalityCheckBenchmark.java 175 spark/v3.4/spark-extensions/src/jmh/java/org/apache/iceberg/spark/PlanningBenchmark.java 271 spark/v3.4/spark-extensions/src/jmh/java/org/apache/iceberg/spark/TaskGroupPlanningBenchmark.java 247 spark/v3.4/spark-extensions/src/jmh/java/org/apache/iceberg/spark/UpdateProjectionBenchmark.java 167 spark/v3.4/spark-extensions/src/main/antlr/org.apache.spark.sql.catalyst.parser.extensions/IcebergSqlExtensions.g4 314 spark/v3.4/spark-extensions/src/main/scala/org/apache/iceberg/spark/extensions/IcebergSparkSessionExtensions.scala 46 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlignRowLevelCommandAssignments.scala 70 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlignedRowLevelIcebergCommandCheck.scala 16 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/AssignmentAlignmentSupport.scala 127 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckMergeIntoTableConditions.scala 41 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckViews.scala 83 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/MergeIntoIcebergTableResolutionCheck.scala 13 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ProcedureArgumentCoercion.scala 31 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveMergeIntoTableReferences.scala 102 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveProcedures.scala 132 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveViews.scala 125 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala 299 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteRowLevelIcebergCommand.scala 126 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteUpdateTable.scala 133 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteViewCommands.scala 125 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ViewUtil.scala 28 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/expressions/AssignmentUtils.scala 52 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ExtendedReplaceNullWithFalseInPredicate.scala 83 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ExtendedSimplifyConditionalsInPredicate.scala 62 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceStaticInvoke.scala 77 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/IcebergSparkSqlExtensionsParser.scala 294 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/IcebergSqlExtensionsAstBuilder.scala 259 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/planning/RewrittenRowLevelCommand.scala 60 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/AddPartitionField.scala 10 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/BranchOptions.scala 3 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Call.scala 11 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/CreateOrReplaceBranch.scala 15 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/CreateOrReplaceTag.scala 15 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropBranch.scala 9 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropIdentifierFields.scala 11 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropPartitionField.scala 10 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropTag.scala 9 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/MergeIntoIcebergTable.scala 48 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/MergeRows.scala 29 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/NoStatsUnaryNode.scala 9 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ReplaceIcebergData.scala 33 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ReplacePartitionField.scala 15 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/RowLevelCommand.scala 7 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SetIdentifierFields.scala 12 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/TagOptions.scala 2 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/UnresolvedMergeIntoIcebergTable.scala 17 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/UpdateIcebergTable.scala 28 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/UpdateRows.scala 20 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/V2WriteCommandLike.scala 14 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/WriteIcebergDelta.scala 89 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statements.scala 8 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/CreateIcebergView.scala 21 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/DropIcebergView.scala 9 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/ResolvedV2View.scala 10 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/ShowIcebergViews.scala 13 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AddPartitionFieldExec.scala 30 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterV2ViewSetPropertiesExec.scala 22 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterV2ViewUnsetPropertiesExec.scala 27 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CallExec.scala 17 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateOrReplaceBranchExec.scala 65 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateOrReplaceTagExec.scala 51 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateV2ViewExec.scala 91 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DescribeV2ViewExec.scala 48 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropBranchExec.scala 29 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropIdentifierFieldsExec.scala 38 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropPartitionFieldExec.scala 39 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropTagExec.scala 29 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropV2ViewExec.scala 22 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ExtendedDataSourceV2Implicits.scala 16 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ExtendedDataSourceV2Strategy.scala 152 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ExtendedV2Writes.scala 57 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/MergeRowsExec.scala 207 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RenameV2ViewExec.scala 18 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ReplaceDataExec.scala 14 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ReplacePartitionFieldExec.scala 44 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ReplaceRewrittenRowLevelCommand.scala 10 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RowLevelCommandScanRelationPushDown.scala 139 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/SetIdentifierFieldsExec.scala 28 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/SetWriteDistributionAndOrderingExec.scala 51 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowCreateV2ViewExec.scala 50 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowV2ViewPropertiesExec.scala 30 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowV2ViewsExec.scala 37 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/UpdateRowsExec.scala 54 spark/v3.4/spark-extensions/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelCommandDynamicPruning.scala 115 spark/v3.4/spark-runtime/src/integration/java/org/apache/iceberg/spark/SmokeTest.java 131 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/SparkBenchmarkUtil.java 31 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/action/DeleteOrphanFilesBenchmark.java 135 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/action/IcebergSortCompactionBenchmark.java 346 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/action/RandomGeneratingUDF.java 26 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetReadersFlatDataBenchmark.java 181 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetReadersNestedDataBenchmark.java 179 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetWritersFlatDataBenchmark.java 92 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetWritersNestedDataBenchmark.java 92 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/Action.java 5 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceBenchmark.java 165 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceDeleteBenchmark.java 282 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceFlatDataBenchmark.java 36 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceNestedDataBenchmark.java 36 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceNestedListDataBenchmark.java 39 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/WritersBenchmark.java 307 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/AvroWritersBenchmark.java 9 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/IcebergSourceFlatAvroDataReadBenchmark.java 103 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/IcebergSourceNestedAvroDataReadBenchmark.java 103 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceFlatORCDataBenchmark.java 36 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceFlatORCDataReadBenchmark.java 167 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceNestedListORCDataWriteBenchmark.java 71 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceNestedORCDataReadBenchmark.java 142 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataFilterBenchmark.java 87 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataReadBenchmark.java 124 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataWriteBenchmark.java 52 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedListParquetDataWriteBenchmark.java 52 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataFilterBenchmark.java 86 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataReadBenchmark.java 125 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataWriteBenchmark.java 51 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetEqDeleteBenchmark.java 23 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetMultiDeleteFileBenchmark.java 24 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetPosDeleteBenchmark.java 26 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetWithUnrelatedDeleteBenchmark.java 30 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/ParquetWritersBenchmark.java 9 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadDictionaryEncodedFlatParquetDataBenchmark.java 82 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadFlatParquetDataBenchmark.java 295 spark/v3.4/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadParquetDecimalBenchmark.java 157 spark/v3.4/spark/src/main/java/org/apache/iceberg/SparkDistributedDataScan.java 190 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/BaseCatalog.java 43 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/BaseFileRewriteCoordinator.java 45 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ChangelogIterator.java 75 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/CommitMetadata.java 30 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ComputeUpdateIterator.java 85 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ExtendedParser.java 44 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/FileRewriteCoordinator.java 9 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/IcebergSpark.java 34 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/JavaUtils.java 44 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/JobGroupInfo.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/JobGroupUtils.java 38 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/OrcBatchReadConf.java 7 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ParquetBatchReadConf.java 8 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ParquetReaderType.java 14 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/PathIdentifier.java 33 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/PositionDeletesRewriteCoordinator.java 10 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/PruneColumnsWithoutReordering.java 190 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RemoveCarryoverIterator.java 79 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RemoveNetCarryoverIterator.java 75 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java 88 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/ScanTaskSetManager.java 44 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SortOrderToSpark.java 69 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java 846 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkAggregates.java 56 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkCachedTableCatalog.java 163 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkCatalog.java 809 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkConfParser.java 213 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkContentFile.java 221 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkDataFile.java 22 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkDeleteFile.java 17 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkExceptionUtil.java 28 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkExecutorCache.java 144 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkFilters.java 228 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkFixupTypes.java 36 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkFunctionCatalog.java 17 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java 283 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkReadOptions.java 36 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkSQLProperties.java 48 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkSchemaUtil.java 149 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkSessionCatalog.java 430 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkStructLike.java 28 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableCache.java 26 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java 883 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTypeToType.java 118 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTypeVisitor.java 47 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkUtil.java 263 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkV2Filters.java 405 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkValueConverter.java 128 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java 547 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java 31 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkWriteRequirements.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkWriteUtil.java 179 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SupportsFunctions.java 38 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SupportsReplaceView.java 21 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/TypeToSparkType.java 108 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/BaseSnapshotUpdateSparkAction.java 22 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/BaseSparkAction.java 343 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/BaseTableCreationSparkAction.java 137 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/ComputeTableStatsSparkAction.java 142 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/DeleteOrphanFilesSparkAction.java 520 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/DeleteReachableFilesSparkAction.java 111 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/ExpireSnapshotsSparkAction.java 183 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/FileInfo.java 25 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/ManifestFileBean.java 127 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/MigrateTableSparkAction.java 190 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/NDVSketchUtil.java 62 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/RemoveDanglingDeletesSparkAction.java 131 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteDataFilesSparkAction.java 356 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java 432 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/RewritePositionDeleteFilesSparkAction.java 311 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java 626 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SetAccumulator.java 34 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SnapshotTableSparkAction.java 164 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkActions.java 75 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkBinPackFileRewriteRunner.java 43 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkDataFileRewriteRunner.java 36 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkRewritePositionDeleteRunner.java 112 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkRewriteRunner.java 43 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingDataRewritePlanner.java 41 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingFileRewriteRunner.java 151 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkSortFileRewriteRunner.java 38 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkZOrderFileRewriteRunner.java 141 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/actions/SparkZOrderUDF.java 263 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/AvroWithSparkSchemaVisitor.java 49 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/ParquetWithSparkSchemaVisitor.java 174 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkAvroWriter.java 128 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcReader.java 98 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcValueReaders.java 194 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcValueWriters.java 165 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcWriter.java 185 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkParquetReaders.java 643 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkParquetWriters.java 473 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkPlannedAvroReader.java 145 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkValueReaders.java 242 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/SparkValueWriters.java 199 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ArrowVectorAccessorFactory.java 98 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ArrowVectorAccessors.java 15 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnVectorBuilder.java 24 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnVectorWithFilter.java 100 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnarBatchReader.java 106 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnarBatchUtil.java 81 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometColumnReader.java 87 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometColumnarBatchReader.java 142 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometConstantColumnReader.java 35 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometDeleteColumnReader.java 47 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometPositionColumnReader.java 35 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometVectorizedReaderBuilder.java 114 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ConstantColumnVector.java 99 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/DeletedColumnVector.java 83 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/IcebergArrowColumnVector.java 110 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPositionColumnVector.java 81 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java 417 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkParquetReaders.java 116 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/BaseScalarFunction.java 18 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/BucketFunction.java 242 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/DaysFunction.java 95 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/HoursFunction.java 81 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/IcebergVersionFunction.java 57 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/MonthsFunction.java 95 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/SparkFunctions.java 41 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/TruncateFunction.java 273 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/UnaryUnboundFunction.java 19 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/functions/YearsFunction.java 95 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java 210 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/AncestorsOfProcedure.java 78 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/BaseProcedure.java 175 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/CherrypickSnapshotProcedure.java 60 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ComputeTableStatsProcedure.java 83 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/CreateChangelogViewProcedure.java 203 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java 128 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/FastForwardBranchProcedure.java 65 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/MigrateTableProcedure.java 87 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/ProcedureInput.java 177 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/PublishChangesProcedure.java 74 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RegisterTableProcedure.java 80 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RemoveOrphanFilesProcedure.java 169 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java 163 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java 78 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewritePositionDeleteFilesProcedure.java 84 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteTablePathProcedure.java 97 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RollbackToSnapshotProcedure.java 60 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/RollbackToTimestampProcedure.java 63 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/SetCurrentSnapshotProcedure.java 76 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/SnapshotTableProcedure.java 85 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/SparkProcedures.java 46 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/BaseBatchReader.java 108 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/BaseReader.java 199 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/BaseRowReader.java 97 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/BatchDataReader.java 84 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java 127 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/DVIterator.java 78 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/EqualityDeleteRowReader.java 30 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/HasIcebergCatalog.java 6 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java 184 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/InternalRowWrapper.java 75 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/PositionDeletesRowReader.java 82 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java 87 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SerializableTableWithSize.java 65 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkBatch.java 168 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkBatchQueryScan.java 227 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkChangelogScan.java 129 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkChangelogTable.java 84 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkCleanupUtil.java 88 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkColumnStatistics.java 59 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkColumnarReaderFactory.java 44 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteOperation.java 75 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteScan.java 144 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkFileWriterFactory.java 234 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkInputPartition.java 68 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkLocalScan.java 40 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkMetadataColumn.java 25 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkMicroBatchStream.java 393 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitionedFanoutWriter.java 33 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitionedWriter.java 33 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitioningAwareScan.java 194 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPlanningUtil.java 61 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java 387 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewriteBuilder.java 70 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaOperation.java 77 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java 705 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWriteBuilder.java 85 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkRowLevelOperationBuilder.java 84 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkRowReaderFactory.java 39 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkScan.java 277 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java 614 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScan.java 68 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScanBuilder.java 61 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkTable.java 357 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkView.java 106 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java 648 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWriteBuilder.java 155 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/StagedSparkTable.java 17 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/Stats.java 28 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/StreamingOffset.java 106 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java 314 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/EqualityDeleteFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/IndexedDeleteFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/NumDeletes.java 22 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/NumSplits.java 21 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/PositionalDeleteFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ResultDataFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ResultDeleteFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ScannedDataManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ScannedDeleteManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDataFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDataManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDeleteFiles.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDeleteManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskEqualityDeleteFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskIndexedDeleteFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskNumDeletes.java 16 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskNumSplits.java 16 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskPositionalDeleteFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskResultDataFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskResultDeleteFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskScannedDataManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskScannedDeleteManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDataFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDataManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDeleteFiles.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDeleteManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDataFileSize.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDataManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDeleteFileSize.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDeleteManifests.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalPlanningDuration.java 23 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDataFileSize.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDataManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDeleteFileSize.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDeleteManifests.java 13 spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalPlanningDuration.java 13 spark/v3.4/spark/src/main/java/org/apache/spark/sql/catalyst/analysis/NoSuchProcedureException.java 19 spark/v3.4/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/Procedure.java 11 spark/v3.4/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureCatalog.java 7 spark/v3.4/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureParameter.java 13 spark/v3.4/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureParameterImpl.java 46 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/OrderAwareCoalesce.scala 24 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SetWriteDistributionAndOrdering.scala 20 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SortOrderParserUtil.scala 18 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/catalyst/utils/PlanUtils.scala 20 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/execution/OrderAwareCoalesceExec.scala 30 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/execution/datasources/SparkExpressionConverter.scala 38 spark/v3.4/spark/src/main/scala/org/apache/spark/sql/stats/ThetaSketchAgg.scala 76 spark/v3.5/spark-extensions/src/jmh/java/org/apache/iceberg/DeleteFileIndexBenchmark.java 214 spark/v3.5/spark-extensions/src/jmh/java/org/apache/iceberg/spark/MergeCardinalityCheckBenchmark.java 176 spark/v3.5/spark-extensions/src/jmh/java/org/apache/iceberg/spark/PlanningBenchmark.java 326 spark/v3.5/spark-extensions/src/jmh/java/org/apache/iceberg/spark/TaskGroupPlanningBenchmark.java 215 spark/v3.5/spark-extensions/src/jmh/java/org/apache/iceberg/spark/UpdateProjectionBenchmark.java 167 spark/v3.5/spark-extensions/src/main/antlr/org.apache.spark.sql.catalyst.parser.extensions/IcebergSqlExtensions.g4 314 spark/v3.5/spark-extensions/src/main/scala/org/apache/iceberg/spark/extensions/IcebergSparkSessionExtensions.scala 26 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckViews.scala 87 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ProcedureArgumentCoercion.scala 31 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveProcedures.scala 132 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveViews.scala 125 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTableForRowLineage.scala 43 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteOperationForRowLineage.scala 52 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteUpdateTableForRowLineage.scala 27 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteViewCommands.scala 125 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/analysis/ViewUtil.scala 28 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RemoveRowLineageOutputFromOriginalTable.scala 26 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceStaticInvoke.scala 79 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/IcebergSparkSqlExtensionsParser.scala 247 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/IcebergSqlExtensionsAstBuilder.scala 259 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/AddPartitionField.scala 10 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/BranchOptions.scala 3 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Call.scala 12 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/CreateOrReplaceBranch.scala 15 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/CreateOrReplaceTag.scala 15 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropBranch.scala 9 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropIdentifierFields.scala 11 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropPartitionField.scala 10 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DropTag.scala 9 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ReplacePartitionField.scala 15 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SetIdentifierFields.scala 12 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/TagOptions.scala 2 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statements.scala 8 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/CreateIcebergView.scala 21 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/DropIcebergView.scala 9 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/ResolvedV2View.scala 10 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/views/ShowIcebergViews.scala 13 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AddPartitionFieldExec.scala 30 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterV2ViewSetPropertiesExec.scala 22 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterV2ViewUnsetPropertiesExec.scala 27 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CallExec.scala 17 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateOrReplaceBranchExec.scala 65 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateOrReplaceTagExec.scala 51 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateV2ViewExec.scala 91 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DescribeV2ViewExec.scala 48 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropBranchExec.scala 29 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropIdentifierFieldsExec.scala 38 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropPartitionFieldExec.scala 39 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropTagExec.scala 29 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropV2ViewExec.scala 22 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ExtendedDataSourceV2Strategy.scala 130 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RenameV2ViewExec.scala 18 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ReplacePartitionFieldExec.scala 44 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/SetIdentifierFieldsExec.scala 28 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/SetWriteDistributionAndOrderingExec.scala 51 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowCreateV2ViewExec.scala 50 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowV2ViewPropertiesExec.scala 30 spark/v3.5/spark-extensions/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowV2ViewsExec.scala 37 spark/v3.5/spark-runtime/src/integration/java/org/apache/iceberg/spark/SmokeTest.java 131 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/SparkBenchmarkUtil.java 32 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/action/DeleteOrphanFilesBenchmark.java 144 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/action/IcebergSortCompactionBenchmark.java 352 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/action/RandomGeneratingUDF.java 26 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetReadersFlatDataBenchmark.java 181 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetReadersNestedDataBenchmark.java 179 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetWritersFlatDataBenchmark.java 92 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/data/parquet/SparkParquetWritersNestedDataBenchmark.java 92 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/Action.java 5 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/DVReaderBenchmark.java 210 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/DVWriterBenchmark.java 190 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceBenchmark.java 165 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceDeleteBenchmark.java 282 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceFlatDataBenchmark.java 36 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceNestedDataBenchmark.java 36 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/IcebergSourceNestedListDataBenchmark.java 39 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/WritersBenchmark.java 307 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/AvroWritersBenchmark.java 9 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/IcebergSourceFlatAvroDataReadBenchmark.java 103 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/avro/IcebergSourceNestedAvroDataReadBenchmark.java 103 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceFlatORCDataBenchmark.java 36 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceFlatORCDataReadBenchmark.java 167 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceNestedListORCDataWriteBenchmark.java 71 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/orc/IcebergSourceNestedORCDataReadBenchmark.java 142 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataFilterBenchmark.java 87 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataReadBenchmark.java 124 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceFlatParquetDataWriteBenchmark.java 52 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedListParquetDataWriteBenchmark.java 52 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataFilterBenchmark.java 86 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataReadBenchmark.java 125 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceNestedParquetDataWriteBenchmark.java 51 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetEqDeleteBenchmark.java 23 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetMultiDeleteFileBenchmark.java 24 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetPosDeleteBenchmark.java 26 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/IcebergSourceParquetWithUnrelatedDeleteBenchmark.java 30 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/ParquetWritersBenchmark.java 9 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadDictionaryEncodedFlatParquetDataBenchmark.java 82 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadFlatParquetDataBenchmark.java 295 spark/v3.5/spark/src/jmh/java/org/apache/iceberg/spark/source/parquet/vectorized/VectorizedReadParquetDecimalBenchmark.java 157 spark/v3.5/spark/src/main/java/org/apache/iceberg/SparkDistributedDataScan.java 190 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/BaseCatalog.java 60 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/BaseFileRewriteCoordinator.java 45 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ChangelogIterator.java 75 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/CommitMetadata.java 30 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ComputeUpdateIterator.java 85 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ExtendedParser.java 44 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/FileRewriteCoordinator.java 9 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/IcebergSpark.java 34 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/JobGroupInfo.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/JobGroupUtils.java 38 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/OrcBatchReadConf.java 7 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ParquetBatchReadConf.java 8 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ParquetReaderType.java 14 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/PathIdentifier.java 33 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/PositionDeletesRewriteCoordinator.java 10 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/PruneColumnsWithoutReordering.java 190 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RemoveCarryoverIterator.java 79 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RemoveNetCarryoverIterator.java 75 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java 88 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/ScanTaskSetManager.java 44 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SortOrderToSpark.java 69 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java 850 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkAggregates.java 56 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkCachedTableCatalog.java 163 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkCatalog.java 809 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkCompressionUtil.java 97 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkConfParser.java 242 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkContentFile.java 221 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkDataFile.java 22 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkDeleteFile.java 17 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkExceptionUtil.java 28 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkExecutorCache.java 144 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkFilters.java 228 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkFixupTypes.java 36 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkFunctionCatalog.java 17 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java 280 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkReadOptions.java 33 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkSQLProperties.java 45 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkSchemaUtil.java 149 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkSessionCatalog.java 431 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkStructLike.java 28 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableCache.java 26 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java 883 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTypeToType.java 118 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTypeVisitor.java 47 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkUtil.java 237 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkV2Filters.java 405 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkValueConverter.java 121 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java 601 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java 28 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteRequirements.java 30 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteUtil.java 187 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SupportsFunctions.java 38 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SupportsReplaceView.java 21 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/TypeToSparkType.java 108 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/BaseSnapshotUpdateSparkAction.java 22 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/BaseSparkAction.java 342 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/BaseTableCreationSparkAction.java 137 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/ComputeTableStatsSparkAction.java 142 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/DeleteOrphanFilesSparkAction.java 520 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/DeleteReachableFilesSparkAction.java 111 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/ExpireSnapshotsSparkAction.java 183 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/FileInfo.java 25 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/ManifestFileBean.java 127 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/MigrateTableSparkAction.java 190 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/NDVSketchUtil.java 62 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RemoveDanglingDeletesSparkAction.java 131 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteDataFilesSparkAction.java 356 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java 432 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewritePositionDeleteFilesSparkAction.java 311 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteTablePathSparkAction.java 626 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SetAccumulator.java 34 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SnapshotTableSparkAction.java 164 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkActions.java 75 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkBinPackFileRewriteRunner.java 43 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkDataFileRewriteRunner.java 36 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkRewritePositionDeleteRunner.java 112 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkRewriteRunner.java 43 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingDataRewritePlanner.java 41 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingFileRewriteRunner.java 151 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkSortFileRewriteRunner.java 38 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkZOrderFileRewriteRunner.java 141 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkZOrderUDF.java 263 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/AvroWithSparkSchemaVisitor.java 49 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/ParquetWithSparkSchemaVisitor.java 168 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkAvroWriter.java 128 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcReader.java 98 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcValueReaders.java 194 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcValueWriters.java 165 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkOrcWriter.java 185 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkParquetReaders.java 601 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkParquetWriters.java 473 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkPlannedAvroReader.java 145 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkValueReaders.java 242 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/SparkValueWriters.java 199 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ArrowVectorAccessorFactory.java 98 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ArrowVectorAccessors.java 15 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnVectorBuilder.java 24 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnVectorWithFilter.java 104 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnarBatchReader.java 106 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ColumnarBatchUtil.java 81 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometColumnReader.java 87 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometColumnarBatchReader.java 142 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometConstantColumnReader.java 35 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometDeleteColumnReader.java 47 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometPositionColumnReader.java 35 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/CometVectorizedReaderBuilder.java 114 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/ConstantColumnVector.java 99 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/DeletedColumnVector.java 83 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/IcebergArrowColumnVector.java 112 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/RowPositionColumnVector.java 81 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkOrcReaders.java 417 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/VectorizedSparkParquetReaders.java 116 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/BaseScalarFunction.java 18 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/BucketFunction.java 242 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/DaysFunction.java 95 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/HoursFunction.java 81 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/IcebergVersionFunction.java 57 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/MonthsFunction.java 95 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/SparkFunctions.java 41 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/TruncateFunction.java 273 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/UnaryUnboundFunction.java 19 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/functions/YearsFunction.java 95 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java 210 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/AncestorsOfProcedure.java 78 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/BaseProcedure.java 175 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/CherrypickSnapshotProcedure.java 60 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/ComputeTableStatsProcedure.java 83 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/CreateChangelogViewProcedure.java 215 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java 128 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/FastForwardBranchProcedure.java 65 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/MigrateTableProcedure.java 87 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/ProcedureInput.java 177 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/PublishChangesProcedure.java 74 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RegisterTableProcedure.java 80 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RemoveOrphanFilesProcedure.java 169 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java 163 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteManifestsProcedure.java 78 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RewritePositionDeleteFilesProcedure.java 84 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteTablePathProcedure.java 97 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RollbackToSnapshotProcedure.java 60 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/RollbackToTimestampProcedure.java 63 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/SetCurrentSnapshotProcedure.java 76 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/SnapshotTableProcedure.java 85 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/SparkProcedures.java 46 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/BaseBatchReader.java 108 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/BaseReader.java 190 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/BaseRowReader.java 97 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/BatchDataReader.java 84 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java 127 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/DVIterator.java 78 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/EqualityDeleteRowReader.java 30 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/HasIcebergCatalog.java 6 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java 184 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/InternalRowWrapper.java 75 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/PositionDeletesRowReader.java 82 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java 87 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SerializableTableWithSize.java 65 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkBatch.java 171 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkBatchQueryScan.java 227 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkChangelogScan.java 129 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkChangelogTable.java 84 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkCleanupUtil.java 88 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkColumnStatistics.java 59 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkColumnarReaderFactory.java 44 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteOperation.java 82 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkCopyOnWriteScan.java 177 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkFileWriterFactory.java 234 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkInputPartition.java 68 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkLocalScan.java 40 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkMetadataColumn.java 25 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkMicroBatchStream.java 408 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitionedFanoutWriter.java 33 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitionedWriter.java 33 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPartitioningAwareScan.java 194 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPlanningUtil.java 61 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java 387 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewriteBuilder.java 70 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaOperation.java 90 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java 707 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWriteBuilder.java 93 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkRowLevelOperationBuilder.java 84 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkRowReaderFactory.java 39 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkScan.java 277 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java 614 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScan.java 68 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScanBuilder.java 61 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkTable.java 360 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkView.java 106 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java 662 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWriteBuilder.java 167 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/StagedSparkTable.java 17 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/Stats.java 28 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/StreamingOffset.java 106 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java 314 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/EqualityDeleteFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/IndexedDeleteFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/NumDeletes.java 22 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/NumSplits.java 21 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/PositionalDeleteFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ResultDataFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ResultDeleteFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ScannedDataManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/ScannedDeleteManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDataFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDataManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDeleteFiles.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/SkippedDeleteManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskEqualityDeleteFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskIndexedDeleteFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskNumDeletes.java 16 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskNumSplits.java 16 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskPositionalDeleteFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskResultDataFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskResultDeleteFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskScannedDataManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskScannedDeleteManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDataFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDataManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDeleteFiles.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskSkippedDeleteManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDataFileSize.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDataManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDeleteFileSize.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalDeleteManifests.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TaskTotalPlanningDuration.java 23 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDataFileSize.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDataManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDeleteFileSize.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalDeleteManifests.java 13 spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/metrics/TotalPlanningDuration.java 13 spark/v3.5/spark/src/main/java/org/apache/spark/sql/catalyst/analysis/NoSuchProcedureException.java 18 spark/v3.5/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/Procedure.java 11 spark/v3.5/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureCatalog.java 7 spark/v3.5/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureParameter.java 13 spark/v3.5/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/ProcedureParameterImpl.java 46 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/OrderAwareCoalesce.scala 24 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SetWriteDistributionAndOrdering.scala 20 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SortOrderParserUtil.scala 18 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/catalyst/utils/PlanUtils.scala 20 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/execution/OrderAwareCoalesceExec.scala 30 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/execution/datasources/SparkExpressionConverter.scala 38 spark/v3.5/spark/src/main/scala/org/apache/spark/sql/stats/ThetaSketchAgg.scala 76