Path	Lines of Code
azure-pipelines-20230430.yml	329
doap_HUDI.rdf	142
docker/compose/docker-compose_hadoop284_hive233_spark244.yml	287
docker/compose/docker-compose_hadoop284_hive233_spark244_mac_aarch64.yml	222
docker/hoodie/hadoop/hive_base/conf/hive-site.xml	4
docker/hoodie/hadoop/hive_base/conf/ivysettings.xml	18
docker/hoodie/hadoop/prestobase/etc/coordinator.properties.mustache	21
docker/hoodie/hadoop/prestobase/etc/jvm.config.mustache	24
docker/hoodie/hadoop/prestobase/etc/node.properties.mustache	18
docker/hoodie/hadoop/prestobase/etc/worker.properties.mustache	19
hudi-aws/src/main/java/org/apache/hudi/aws/cloudwatch/CloudWatchReporter.java	251
hudi-aws/src/main/java/org/apache/hudi/aws/credentials/HoodieAWSCredentialsProviderFactory.java	30
hudi-aws/src/main/java/org/apache/hudi/aws/credentials/HoodieConfigAWSAssumedRoleCredentialsProvider.java	35
hudi-aws/src/main/java/org/apache/hudi/aws/credentials/HoodieConfigAWSCredentialsProvider.java	35
hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java	785
hudi-aws/src/main/java/org/apache/hudi/aws/sync/AwsGlueCatalogSyncTool.java	32
hudi-aws/src/main/java/org/apache/hudi/aws/sync/HoodieGlueSyncException.java	10
hudi-aws/src/main/java/org/apache/hudi/aws/sync/util/GlueFilterGenVisitor.java	8
hudi-aws/src/main/java/org/apache/hudi/aws/sync/util/GluePartitionFilterGenerator.java	8
hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProvider.java	168
hudi-aws/src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java	93
hudi-aws/src/main/java/org/apache/hudi/aws/utils/S3Utils.java	6
hudi-aws/src/main/java/org/apache/hudi/config/DynamoDbBasedLockConfig.java	122
hudi-aws/src/main/java/org/apache/hudi/config/GlueCatalogSyncClientConfig.java	61
hudi-aws/src/main/java/org/apache/hudi/config/HoodieAWSConfig.java	139
hudi-cli/src/main/java/org/apache/hudi/cli/HoodieCLI.java	78
hudi-cli/src/main/java/org/apache/hudi/cli/HoodieCliSparkConfig.java	13
hudi-cli/src/main/java/org/apache/hudi/cli/HoodiePrintHelper.java	66
hudi-cli/src/main/java/org/apache/hudi/cli/HoodiePrompt.java	27
hudi-cli/src/main/java/org/apache/hudi/cli/HoodieTableHeaderFields.java	143
hudi-cli/src/main/java/org/apache/hudi/cli/Main.java	11
hudi-cli/src/main/java/org/apache/hudi/cli/Table.java	123
hudi-cli/src/main/java/org/apache/hudi/cli/TableHeader.java	29
hudi-cli/src/main/java/org/apache/hudi/cli/commands/ArchivedCommitsCommand.java	208
hudi-cli/src/main/java/org/apache/hudi/cli/commands/BootstrapCommand.java	143
hudi-cli/src/main/java/org/apache/hudi/cli/commands/CleansCommand.java	122
hudi-cli/src/main/java/org/apache/hudi/cli/commands/ClusteringCommand.java	99
hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java	343
hudi-cli/src/main/java/org/apache/hudi/cli/commands/CompactionCommand.java	592
hudi-cli/src/main/java/org/apache/hudi/cli/commands/DiffCommand.java	123
hudi-cli/src/main/java/org/apache/hudi/cli/commands/ExportCommand.java	186
hudi-cli/src/main/java/org/apache/hudi/cli/commands/FileSystemViewCommand.java	216
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HDFSParquetImportCommand.java	59
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java	252
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieSyncValidateCommand.java	74
hudi-cli/src/main/java/org/apache/hudi/cli/commands/KerberosAuthenticationCommand.java	49
hudi-cli/src/main/java/org/apache/hudi/cli/commands/MarkersCommand.java	34
hudi-cli/src/main/java/org/apache/hudi/cli/commands/MetadataCommand.java	303
hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java	273
hudi-cli/src/main/java/org/apache/hudi/cli/commands/RestoresCommand.java	127
hudi-cli/src/main/java/org/apache/hudi/cli/commands/RollbacksCommand.java	122
hudi-cli/src/main/java/org/apache/hudi/cli/commands/SavepointsCommand.java	125
hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkEnvCommand.java	38
hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkMain.java	589
hudi-cli/src/main/java/org/apache/hudi/cli/commands/StatsCommand.java	129
hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java	332
hudi-cli/src/main/java/org/apache/hudi/cli/commands/TempViewCommand.java	41
hudi-cli/src/main/java/org/apache/hudi/cli/commands/TimelineCommand.java	346
hudi-cli/src/main/java/org/apache/hudi/cli/commands/UpgradeOrDowngradeCommand.java	70
hudi-cli/src/main/java/org/apache/hudi/cli/commands/UtilsCommand.java	20
hudi-cli/src/main/java/org/apache/hudi/cli/utils/CLIUtils.java	30
hudi-cli/src/main/java/org/apache/hudi/cli/utils/CommitUtil.java	27
hudi-cli/src/main/java/org/apache/hudi/cli/utils/HiveUtil.java	73
hudi-cli/src/main/java/org/apache/hudi/cli/utils/InputStreamConsumer.java	32
hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkTempViewProvider.java	109
hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkUtil.java	77
hudi-cli/src/main/java/org/apache/hudi/cli/utils/TempViewProvider.java	10
hudi-cli/src/main/resources/application.yml	5
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/AsyncArchiveService.java	53
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/AsyncCleanerService.java	54
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/AsyncClusteringService.java	69
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/AsyncCompactService.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/HoodieAsyncService.java	131
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/HoodieAsyncTableService.java	23
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/HoodieClientInitCallback.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/HoodieWriteCommitCallback.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/client/http/HoodieWriteCommitHttpCallbackClient.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/common/HoodieWriteCommitCallbackMessage.java	55
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/impl/HoodieWriteCommitHttpCallback.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/util/HoodieCommitCallbackFactory.java	23
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/callback/util/HoodieWriteCommitCallbackUtil.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseClusterer.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseCompactor.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java	197
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java	800
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java	840
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/CompactionAdminClient.java	247
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/FailOnFirstErrorWriteStatus.java	25
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/HoodieTableServiceManagerClient.java	123
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/RunsTableService.java	18
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/WriteStatus.java	178
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/BootstrapMode.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/BootstrapRecordPayload.java	24
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/BootstrapWriteStatus.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/FullRecordBootstrapDataProvider.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/HoodieBootstrapSchemaProvider.java	25
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/BootstrapModeSelector.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/BootstrapRegexModeSelector.java	32
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/FullRecordBootstrapModeSelector.java	8
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/MetadataOnlyBootstrapModeSelector.java	8
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/UniformBootstrapModeSelector.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/translator/BootstrapPartitionPathTranslator.java	7
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/translator/DecodedBootstrapPartitionPathTranslator.java	11
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/translator/IdentityBootstrapPartitionPathTranslator.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineServerHelper.java	25
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineService.java	228
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HeartbeatUtils.java	49
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java	195
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/ActiveActionWithDetails.java	73
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/HoodieTimelineArchiver.java	233
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/LSMTimelineWriter.java	230
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/BucketIndexConcurrentFileWritesConflictResolutionStrategy.java	34
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/ConcurrentOperation.java	147
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/ConflictResolutionStrategy.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/DirectMarkerTransactionManager.java	49
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/PreferWriterConflictResolutionStrategy.java	65
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/SimpleConcurrentFileWritesConflictResolutionStrategy.java	69
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/TransactionManager.java	71
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/FileSystemBasedLockProvider.java	173
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockInfo.java	38
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java	94
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/ZookeeperBasedLockProvider.java	166
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/metrics/HoodieLockMetrics.java	84
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/ArchivalUtils.java	100
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/ClosableMergingIterator.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/ConcatenatingIterator.java	27
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/DeletePartitionUtils.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/FileSliceMetricUtils.java	36
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/LazyIterableIterator.java	63
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/LegacyArchivedMetaEntryReader.java	237
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/MergingIterator.java	25
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/MetadataTableUtils.java	13
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/OperationConverter.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/TransactionUtils.java	99
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/common/table/log/HoodieFileSliceReader.java	70
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/common/table/log/LogFileIterator.java	36
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieArchivalConfig.java	135
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieBootstrapConfig.java	166
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieCleanConfig.java	250
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java	515
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java	309
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieErrorTableConfig.java	71
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieHBaseIndexConfig.java	364
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieIndexConfig.java	528
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieInternalConfig.java	29
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLayoutConfig.java	63
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLockConfig.java	282
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodiePayloadConfig.java	77
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodiePreCommitValidatorConfig.java	85
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieTTLConfig.java	88
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteCommitCallbackConfig.java	109
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java	2526
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsCloudWatchConfig.java	56
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsConfig.java	154
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsDatadogConfig.java	150
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsGraphiteConfig.java	90
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsJmxConfig.java	68
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsM3Config.java	82
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsPrometheusConfig.java	140
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieAppendException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieClusteringException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieClusteringUpdateException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieCommitCallbackException.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieCommitException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieCompactionException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDeletePartitionException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieInsertException.java	6
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieKeyGeneratorException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieRestoreException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieRollbackException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieSavepointException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieUpgradeDowngradeException.java	12
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieUpsertException.java	9
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/execution/CopyOnWriteInsertHandler.java	85
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/execution/HoodieLazyInsertIterable.java	78
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/execution/bulkinsert/BulkInsertSortMode.java	24
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndex.java	121
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndexUtils.java	261
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieInternalProxyIndex.java	37
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/BaseHoodieBloomIndexHelper.java	19
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/BloomIndexFileInfo.java	59
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndex.java	204
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndexCheckFunction.java	76
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieGlobalBloomIndex.java	66
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/IndexFileFilter.java	7
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/IntervalTreeBasedGlobalIndexFileFilter.java	39
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/IntervalTreeBasedIndexFileFilter.java	43
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/KeyRangeLookupTree.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/KeyRangeNode.java	84
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/ListBasedGlobalIndexFileFilter.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/ListBasedHoodieBloomIndexHelper.java	54
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/ListBasedIndexFileFilter.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/BucketIdentifier.java	82
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIdentifier.java	125
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIndexUtils.java	190
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieBucketIndex.java	64
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieConsistentBucketIndex.java	77
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieSimpleBucketIndex.java	68
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/hbase/DefaultHBaseQPSResourceAllocator.java	24
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/hbase/HBaseIndexQPSResourceAllocator.java	7
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/inmemory/HoodieInMemoryHashIndex.java	91
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/simple/HoodieGlobalSimpleIndex.java	61
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/simple/HoodieSimpleIndex.java	103
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/AppendHandleFactory.java	13
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/CreateHandleFactory.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java	519
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieBootstrapHandle.java	31
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCDCLogger.java	198
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieConcatHandle.java	63
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCreateHandle.java	177
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieIOHandle.java	19
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLocationFetchHandle.java	48
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLookupHandle.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLookupResult.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java	370
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandleFactory.java	64
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandleWithChangeLog.java	85
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergedReadHandle.java	143
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieRangeInfoHandle.java	23
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieReadHandle.java	48
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieSortedMergeHandle.java	81
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieSortedMergeHandleWithChangeLog.java	32
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieUnboundedCreateHandle.java	23
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java	191
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/IOUtils.java	43
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/SingleFileHandleCreateFactory.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/WriteHandleFactory.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/AutoRecordGenWrapperAvroKeyGenerator.java	49
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/AutoRecordKeyGeneratorWrapper.java	4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/ComplexAvroKeyGenerator.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/CustomAvroKeyGenerator.java	89
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/GlobalAvroDeleteKeyGenerator.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/KeyGenUtils.java	186
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/NonpartitionedAvroKeyGenerator.java	31
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/SimpleAvroKeyGenerator.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/TimestampBasedAvroKeyGenerator.java	160
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/factory/HoodieAvroKeyGeneratorFactory.java	70
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/parser/BaseHoodieDateTimeParser.java	32
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/parser/HoodieDateTimeParser.java	84
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java	1115
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataWriteUtils.java	177
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataKeyGenerator.java	18
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataWriter.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/ConsoleMetricsReporter.java	39
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/HoodieGauge.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/HoodieMetrics.java	341
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/InMemoryMetricsReporter.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/JmxMetricsReporter.java	88
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/JmxReporterServer.java	112
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricUtils.java	48
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java	134
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsGraphiteReporter.java	59
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporter.java	6
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporterFactory.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporterType.java	4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/cloudwatch/CloudWatchMetricsReporter.java	45
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/custom/CustomizableMetricsReporter.java	18
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/datadog/DatadogHttpClient.java	92
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/datadog/DatadogMetricsReporter.java	52
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/datadog/DatadogReporter.java	127
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/m3/M3MetricsReporter.java	72
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/m3/M3ScopeReporterAdaptor.java	102
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/prometheus/PrometheusReporter.java	96
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/prometheus/PushGatewayMetricsReporter.java	66
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/prometheus/PushGatewayReporter.java	132
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/userdefined/AbstractUserDefinedMetricsReporter.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/optimize/HilbertCurveUtils.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/BucketIndexBulkInsertPartitioner.java	47
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/BulkInsertPartitioner.java	38
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/ConsistentHashingBucketInsertPartitioner.java	6
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/FileIdPrefixProvider.java	12
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieCompactionHandler.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java	562
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/RandomFileIdPrefixProvider.java	12
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/WorkloadProfile.java	68
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/WorkloadStat.java	58
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java	87
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/HoodieWriteMetadata.java	90
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapRecordConsumer.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java	93
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/HoodieBootstrapWriteMetadata.java	18
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanActionExecutor.java	228
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanActionExecutor.java	143
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java	408
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleaningTriggerStrategy.java	8
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/PartitionCleanStat.java	69
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanActionExecutor.java	77
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanPartitionFilter.java	59
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanPartitionFilterMode.java	19
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/BaseConsistentHashingBucketClusteringPlanStrategy.java	223
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/ClusteringExecutionStrategy.java	34
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/ClusteringPlanStrategy.java	105
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java	134
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/UpdateStrategy.java	18
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java	69
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseBulkInsertHelper.java	24
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java	249
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseDeleteHelper.java	16
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseMergeHelper.java	24
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseWriteHelper.java	58
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BucketInfo.java	48
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BucketType.java	4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieDeleteHelper.java	97
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieMergeHelper.java	165
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieWriteHelper.java	54
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/InsertBucket.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/InsertBucketCumulativeWeightPair.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/ParallelismHelper.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/Partitioner.java	6
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/SmallFile.java	15
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/CompactHelpers.java	83
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/CompactionExecutionHelper.java	49
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/CompactionTriggerStrategy.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/HoodieCompactor.java	186
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/LogCompactionExecutionHelper.java	54
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/OperationResult.java	39
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/RunCompactionActionExecutor.java	97
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/ScheduleCompactionActionExecutor.java	178
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/plan/generators/BaseHoodieCompactionPlanGenerator.java	121
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/plan/generators/HoodieCompactionPlanGenerator.java	34
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/plan/generators/HoodieLogCompactionPlanGenerator.java	76
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/BoundedIOCompactionStrategy.java	23
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/BoundedPartitionAwareCompactionStrategy.java	38
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/CompactionStrategy.java	38
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java	41
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/LogFileNumBasedCompactionStrategy.java	22
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/LogFileSizeBasedCompactionStrategy.java	25
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/UnBoundedCompactionStrategy.java	12
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/UnBoundedPartitionAwareCompactionStrategy.java	33
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/AbstractIndexingCatchupTask.java	128
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/IndexingCatchupTask.java	6
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/IndexingCatchupTaskFactory.java	45
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/RecordBasedIndexingCatchupTask.java	58
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/RunIndexActionExecutor.java	250
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/ScheduleIndexActionExecutor.java	107
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/WriteStatBasedIndexingCatchupTask.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/functional/BaseHoodieFunctionalIndexClient.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/BaseRestoreActionExecutor.java	117
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/CopyOnWriteRestoreActionExecutor.java	40
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/MergeOnReadRestoreActionExecutor.java	41
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/RestoreUtils.java	30
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java	248
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java	150
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackPlanActionExecutor.java	80
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/CopyOnWriteRollbackActionExecutor.java	53
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/ListingBasedRollbackRequest.java	57
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/ListingBasedRollbackStrategy.java	223
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/MarkerBasedRollbackStrategy.java	61
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/MergeOnReadRollbackActionExecutor.java	52
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java	62
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RollbackUtils.java	52
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java	36
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializablePathFilter.java	5
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/savepoint/SavepointActionExecutor.java	109
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/savepoint/SavepointHelpers.java	41
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/HoodiePartitionTTLStrategyFactory.java	51
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByCreationTimeStrategy.java	27
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByTimeStrategy.java	65
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java	35
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategyType.java	43
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/TTLStrategy.java	3
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/ConflictDetectionUtils.java	14
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/DirectWriteMarkers.java	148
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/MarkerBasedRollbackUtils.java	53
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/SimpleDirectMarkerBasedDetectionStrategy.java	52
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/SimpleTransactionDirectMarkerBasedDetectionStrategy.java	33
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/TimelineServerBasedWriteMarkers.java	146
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java	83
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java	34
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/repair/RepairUtils.java	104
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/storage/HoodieConsistentBucketLayout.java	38
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/storage/HoodieDefaultLayout.java	21
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/storage/HoodieLayoutFactory.java	22
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/storage/HoodieSimpleBucketLayout.java	39
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/storage/HoodieStorageLayout.java	26
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/DowngradeHandler.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/FiveToFourDowngradeHandler.java	12
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/FiveToSixUpgradeHandler.java	44
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/FourToFiveUpgradeHandler.java	61
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/FourToThreeDowngradeHandler.java	16
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/OneToTwoUpgradeHandler.java	20
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/OneToZeroDowngradeHandler.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/SixToFiveDowngradeHandler.java	76
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/SupportsUpgradeDowngrade.java	11
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ThreeToFourUpgradeHandler.java	28
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ThreeToTwoDowngradeHandler.java	16
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java	84
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToThreeUpgradeHandler.java	32
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeDowngrade.java	121
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeHandler.java	10
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ZeroToOneUpgradeHandler.java	83
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/util/ExecutorFactory.java	51
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/util/HttpRequestClient.java	69
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/FlinkTaskContextSupplier.java	35
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkTableServiceClient.java	174
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java	367
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkConsistentBucketClusteringPlanStrategy.java	26
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkSizeBasedClusteringPlanStrategy.java	45
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkSizeBasedClusteringPlanStrategyRecently.java	89
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/common/HoodieFlinkEngineContext.java	157
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/AbstractHoodieRowData.java	116
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieRowData.java	20
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieRowDataCreation.java	17
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/model/HoodieRowDataWithMetaFields.java	20
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/execution/ExplicitWriteHandler.java	30
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/execution/FlinkLazyInsertIterable.java	51
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndex.java	45
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java	45
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/state/FlinkInMemoryStateIndex.java	47
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/ExplicitWriteHandleFactory.java	21
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java	73
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkConcatAndReplaceHandle.java	45
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkConcatHandle.java	44
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkCreateHandle.java	108
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeAndReplaceHandle.java	134
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeAndReplaceHandleWithChangeLog.java	68
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeHandle.java	141
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeHandleWithChangeLog.java	66
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkWriteHandleFactory.java	199
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/MiniBatchHandle.java	8
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataCreateHandle.java	158
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataFileWriter.java	9
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataFileWriterFactory.java	43
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java	44
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriter.java	24
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/RowDataParquetWriteSupport.java	36
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetRowDataWriter.java	462
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java	572
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/metadata/FlinkHoodieBackedTableMetadataWriter.java	131
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/ExplicitWriteHandleTable.java	50
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkCopyOnWriteTable.java	280
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkMergeOnReadTable.java	125
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkTable.java	83
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java	142
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkBulkInsertPreppedCommitActionExecutor.java	24
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkDeleteCommitActionExecutor.java	26
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkDeleteHelper.java	92
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkDeletePartitionCommitActionExecutor.java	73
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkDeletePreppedCommitActionExecutor.java	24
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkInsertCommitActionExecutor.java	27
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkInsertOverwriteCommitActionExecutor.java	42
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkInsertOverwriteTableCommitActionExecutor.java	26
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkInsertPreppedCommitActionExecutor.java	24
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkUpsertCommitActionExecutor.java	27
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkUpsertPreppedCommitActionExecutor.java	24
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkWriteHelper.java	77
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/delta/BaseFlinkDeltaCommitActionExecutor.java	37
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/delta/FlinkUpsertDeltaCommitActionExecutor.java	28
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/delta/FlinkUpsertPreppedDeltaCommitActionExecutor.java	27
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/compact/HoodieFlinkMergeOnReadTableCompactor.java	30
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/upgrade/FlinkUpgradeDowngradeHelper.java	30
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/FlinkClientUtil.java	47
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java	111
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/HoodieJavaTableServiceClient.java	51
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/HoodieJavaWriteClient.java	187
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/JavaSizeBasedClusteringPlanStrategy.java	45
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaExecutionStrategy.java	162
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaSortAndSizeExecutionStrategy.java	39
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/common/HoodieJavaEngineContext.java	123
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/common/JavaTaskContextSupplier.java	27
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/execution/JavaLazyInsertIterable.java	54
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/execution/bulkinsert/JavaBulkInsertInternalPartitionerFactory.java	16
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/execution/bulkinsert/JavaCustomColumnsSortPartitioner.java	39
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/execution/bulkinsert/JavaGlobalSortPartitioner.java	35
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/execution/bulkinsert/JavaNonSortPartitioner.java	16
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/index/JavaHoodieIndex.java	45
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/index/JavaHoodieIndexFactory.java	42
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/metadata/JavaHoodieBackedTableMetadataWriter.java	82
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/metadata/JavaHoodieMetadataBulkInsertPartitioner.java	26
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaCopyOnWriteTable.java	263
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaMergeOnReadTable.java	84
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaTable.java	78
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/cluster/JavaExecuteClusteringCommitActionExecutor.java	39
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/BaseJavaCommitActionExecutor.java	238
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaBulkInsertCommitActionExecutor.java	41
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaBulkInsertHelper.java	88
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaBulkInsertPreppedCommitActionExecutor.java	37
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaDeleteCommitActionExecutor.java	22
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaDeleteHelper.java	94
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaDeletePreppedCommitActionExecutor.java	23
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaInsertCommitActionExecutor.java	25
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaInsertOverwriteCommitActionExecutor.java	49
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaInsertOverwriteTableCommitActionExecutor.java	37
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaInsertPreppedCommitActionExecutor.java	23
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertCommitActionExecutor.java	25
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java	246
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPreppedCommitActionExecutor.java	23
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaWriteHelper.java	54
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/compact/HoodieJavaMergeOnReadTableCompactor.java	30
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/deltacommit/BaseJavaDeltaCommitActionExecutor.java	45
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/deltacommit/JavaUpsertDeltaCommitActionExecutor.java	26
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/deltacommit/JavaUpsertPreppedDeltaCommitActionExecutor.java	68
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/upgrade/JavaUpgradeDowngradeHelper.java	28
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/HoodieSparkRecordMerger.java	84
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/async/SparkAsyncClusteringService.java	14
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/async/SparkAsyncCompactService.java	14
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java	20
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieSparkClusteringClient.java	32
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieSparkCompactor.java	37
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieWriteResult.java	36
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDReadClient.java	130
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDTableServiceClient.java	51
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDWriteClient.java	262
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkTaskContextSupplier.java	57
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/bootstrap/HoodieSparkBootstrapSchemaProvider.java	71
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/SparkConsistentBucketClusteringPlanStrategy.java	31
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/SparkSingleFileSortPlanStrategy.java	27
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/SparkSizeBasedClusteringPlanStrategy.java	46
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/ExecutionStrategyUtil.java	39
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java	358
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SingleSparkJobExecutionStrategy.java	117
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkConsistentBucketClusteringExecutionStrategy.java	74
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkSingleFileSortExecutionStrategy.java	72
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkSortAndSizeExecutionStrategy.java	64
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/update/strategy/BaseSparkUpdateStrategy.java	20
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/update/strategy/SparkAllowUpdateStrategy.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/update/strategy/SparkConsistentBucketDuplicateUpdateStrategy.java	53
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/update/strategy/SparkRejectUpdateStrategy.java	33
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/common/HoodieSparkEngineContext.java	188
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/model/HoodieInternalRow.java	179
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkInternalSchemaConverter.java	396
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkMemoryUtils.java	10
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkMetadataWriterUtils.java	201
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkPartitionUtils.java	30
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkRowSerDe.java	8
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkValidatorUtils.java	122
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SparkPreCommitValidator.java	86
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQueryEqualityPreCommitValidator.java	44
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQueryInequalityPreCommitValidator.java	43
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQueryPreCommitValidator.java	55
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SqlQuerySingleResultPreCommitValidator.java	45
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/common/model/HoodieSparkRecord.java	333
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/data/HoodieJavaPairRDD.java	89
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/data/HoodieJavaRDD.java	112
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/data/HoodieSparkLongAccumulator.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/SparkLazyInsertIterable.java	60
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/BucketIndexBulkInsertPartitionerWithRows.java	21
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/BulkInsertInternalPartitionerFactory.java	43
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/BulkInsertInternalPartitionerWithRowsFactory.java	30
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/BulkInsertMapFunction.java	39
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/ConsistentBucketIndexBulkInsertPartitionerWithRows.java	131
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/GlobalSortPartitioner.java	32
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/GlobalSortPartitionerWithRows.java	27
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/NonSortPartitioner.java	26
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/NonSortPartitionerWithRows.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionPathRDDPartitioner.java	22
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionPathRepartitionAndSortPartitioner.java	38
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionPathRepartitionAndSortPartitionerWithRows.java	32
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionPathRepartitionPartitioner.java	38
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionPathRepartitionPartitionerWithRows.java	31
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/PartitionSortPartitionerWithRows.java	25
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDBucketIndexPartitioner.java	61
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDConsistentBucketBulkInsertPartitioner.java	108
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java	47
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDPartitionSortPartitioner.java	45
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDSimpleBucketBulkInsertPartitioner.java	75
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDSpatialCurveSortPartitioner.java	78
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RowCustomColumnsSortPartitioner.java	31
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RowRecordKeyExtractor.java	54
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RowSpatialCurveSortPartitioner.java	19
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/SpatialCurveSortPartitionerBase.java	51
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/SparkHoodieIndex.java	47
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/SparkHoodieIndexFactory.java	87
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/SparkMetadataTableRecordIndex.java	120
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/BucketizedBloomCheckPartitioner.java	76
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/HoodieBloomFilterProbingResult.java	11
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/HoodieFileProbingFunction.java	90
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/HoodieMetadataBloomFilterProbingFunction.java	100
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/SparkHoodieBloomIndexHelper.java	190
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bucket/HoodieSparkConsistentBucketIndex.java	72
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/functional/HoodieSparkFunctionalIndex.java	190
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/RebalancedSparkHoodieHBaseIndex.java	13
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java	544
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkBootstrapFileReader.java	14
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileReader.java	3
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileReaderFactory.java	35
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileWriter.java	21
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileWriterFactory.java	76
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkParquetReader.java	113
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkParquetStreamWriter.java	69
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkParquetWriter.java	70
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieInternalRowFileWriter.java	10
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieInternalRowFileWriterFactory.java	58
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieInternalRowParquetWriter.java	25
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowCreateHandle.java	197
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowParquetConfig.java	11
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowParquetWriteSupport.java	62
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/AutoRecordGenWrapperKeyGenerator.java	69
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/BuiltinKeyGenerator.java	334
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/ComplexKeyGenerator.java	50
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/CustomKeyGenerator.java	115
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java	47
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/NonpartitionedKeyGenerator.java	49
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/PartitionPathFormatterBase.java	52
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/SimpleKeyGenerator.java	81
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/SparkKeyGeneratorInterface.java	17
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/StringPartitionPathFormatter.java	40
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/TimestampBasedKeyGenerator.java	69
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/UTF8StringPartitionPathFormatter.java	46
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/factory/HoodieSparkKeyGeneratorFactory.java	125
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/merge/SparkRecordMergingUtils.java	117
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieBackedTableMetadataWriter.java	163
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieMetadataBulkInsertPartitioner.java	63
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metrics/DistributedRegistry.java	72
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/sort/SpaceCurveSortingHelper.java	206
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java	241
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkMergeOnReadTable.java	169
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java	107
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BaseBootstrapMetadataHandler.java	56
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapMetadataHandler.java	6
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/MetadataBootstrapHandlerFactory.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/OrcBootstrapMetadataHandler.java	73
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/ParquetBootstrapMetadataHandler.java	99
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java	250
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapDeltaCommitActionExecutor.java	32
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/cluster/SparkExecuteClusteringCommitActionExecutor.java	35
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java	303
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BucketBulkInsertDataInternalWriterHelper.java	88
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BulkInsertDataInternalWriterHelper.java	164
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/ConsistentBucketBulkInsertDataInternalWriterHelper.java	81
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBucketIndexPartitioner.java	108
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBulkInsertCommitActionExecutor.java	41
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBulkInsertHelper.java	84
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBulkInsertPreppedCommitActionExecutor.java	37
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkDeleteCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkDeletePartitionCommitActionExecutor.java	67
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkDeletePreppedCommitActionExecutor.java	21
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkHoodiePartitioner.java	18
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertCommitActionExecutor.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertOverwriteCommitActionExecutor.java	81
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertOverwritePartitioner.java	33
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertOverwriteTableCommitActionExecutor.java	33
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertPreppedCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkPartitionTTLActionExecutor.java	34
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkUpsertCommitActionExecutor.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkUpsertPreppedCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java	281
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/compact/HoodieSparkMergeOnReadTableCompactor.java	32
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/BaseSparkDeltaCommitActionExecutor.java	68
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkBulkInsertDeltaCommitActionExecutor.java	43
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkBulkInsertPreppedDeltaCommitActionExecutor.java	38
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkDeleteDeltaCommitActionExecutor.java	24
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkDeletePreppedDeltaCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkInsertDeltaCommitActionExecutor.java	25
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkInsertPreppedDeltaCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkUpsertDeltaCommitActionExecutor.java	25
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkUpsertDeltaCommitPartitioner.java	97
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkUpsertPreppedDeltaCommitActionExecutor.java	23
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/upgrade/SparkUpgradeDowngradeHelper.java	29
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala	153
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/BaseSparkInternalRowReaderContext.java	104
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala	24
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala	190
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala	247
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieUnsafeRDD.scala	10
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/SparkAdapterSupport.scala	26
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/SparkConversionUtils.scala	15
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/SparkFileFormatInternalRowReaderContext.scala	101
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/SparkJdbcUtils.scala	12
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/unsafe/UTF8StringBuilder.java	65
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/CloseableInternalRowIterator.scala	52
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/CloseableScalaIterator.scala	12
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala	15
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/JFunction.scala	33
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/PathUtils.scala	34
hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/SparkKeyGenUtils.scala	34
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/HoodieSparkKryoRegistrar.scala	37
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/BucketPartitionUtils.scala	33
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/DataFrameUtil.scala	14
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalogUtils.scala	2
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystExpressionUtils.scala	143
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystPlansUtils.scala	30
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieDataTypeUtils.scala	20
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieInternalRowUtils.scala	323
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieSchemaUtils.scala	9
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieUnsafeRowUtils.scala	74
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieUnsafeUtils.scala	38
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/avro/HoodieAvroDeserializer.scala	4
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/avro/HoodieAvroSchemaConverters.scala	7
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/avro/HoodieAvroSerializer.scala	4
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/catalyst/expressions/AttributeEq.scala	2
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/SQLConfInjectingRDD.scala	25
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSparkPartitionedFileUtils.scala	13
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/SparkParsePartitionUtil.scala	13
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/SparkAdapter.scala	78
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/execution/RangeSample.scala	433
hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/parser/HoodieExtendedParserInterface.scala	11
hudi-common/src/main/avro/HoodieArchivedMetaEntry.avsc	138
hudi-common/src/main/avro/HoodieBootstrapFilePartitionInfo.avsc	44
hudi-common/src/main/avro/HoodieBootstrapIndexInfo.avsc	44
hudi-common/src/main/avro/HoodieBootstrapPartitionMetadata.avsc	47
hudi-common/src/main/avro/HoodieCleanMetadata.avsc	55
hudi-common/src/main/avro/HoodieCleanPartitionMetadata.avsc	30
hudi-common/src/main/avro/HoodieCleanerPlan.avsc	119
hudi-common/src/main/avro/HoodieClusteringGroup.avsc	63
hudi-common/src/main/avro/HoodieClusteringPlan.avsc	55
hudi-common/src/main/avro/HoodieClusteringStrategy.avsc	42
hudi-common/src/main/avro/HoodieCommitMetadata.avsc	192
hudi-common/src/main/avro/HoodieCompactionMetadata.avsc	64
hudi-common/src/main/avro/HoodieCompactionOperation.avsc	101
hudi-common/src/main/avro/HoodieCompactionStrategy.avsc	44
hudi-common/src/main/avro/HoodieDeleteRecordList.avsc	76
hudi-common/src/main/avro/HoodieFSPermission.avsc	49
hudi-common/src/main/avro/HoodieFileStatus.avsc	84
hudi-common/src/main/avro/HoodieIndexCommitMetadata.avsc	54
hudi-common/src/main/avro/HoodieIndexPartitionInfo.avsc	59
hudi-common/src/main/avro/HoodieIndexPlan.avsc	43
hudi-common/src/main/avro/HoodieInstantInfo.avsc	32
hudi-common/src/main/avro/HoodieLSMTimelineInstant.avsc	54
hudi-common/src/main/avro/HoodieMergeArchiveFilePlan.avsc	42
hudi-common/src/main/avro/HoodieMetadata.avsc	436
hudi-common/src/main/avro/HoodiePath.avsc	34
hudi-common/src/main/avro/HoodieReplaceCommitMetadata.avsc	64
hudi-common/src/main/avro/HoodieRequestedReplaceMetadata.avsc	47
hudi-common/src/main/avro/HoodieRestoreMetadata.avsc	49
hudi-common/src/main/avro/HoodieRestorePlan.avsc	43
hudi-common/src/main/avro/HoodieRollbackMetadata.avsc	71
hudi-common/src/main/avro/HoodieRollbackPlan.avsc	76
hudi-common/src/main/avro/HoodieSavePointMetadata.avsc	42
hudi-common/src/main/avro/HoodieSliceInfo.avsc	56
hudi-common/src/main/java/org/apache/hudi/BaseHoodieTableFileIndex.java	356
hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaCompatibility.java	603
hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaUtils.java	322
hudi-common/src/main/java/org/apache/hudi/avro/ConvertingGenericData.java	98
hudi-common/src/main/java/org/apache/hudi/avro/GenericAvroSerializer.java	98
hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java	982
hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroWriteSupport.java	51
hudi-common/src/main/java/org/apache/hudi/avro/HoodieBloomFilterWriteSupport.java	42
hudi-common/src/main/java/org/apache/hudi/avro/JsonEncoder.java	230
hudi-common/src/main/java/org/apache/hudi/avro/MercifulJsonConverter.java	295
hudi-common/src/main/java/org/apache/hudi/client/transaction/lock/InProcessLockProvider.java	87
hudi-common/src/main/java/org/apache/hudi/common/HoodieCleanStat.java	159
hudi-common/src/main/java/org/apache/hudi/common/HoodieJsonPayload.java	72
hudi-common/src/main/java/org/apache/hudi/common/HoodiePendingRollbackInfo.java	17
hudi-common/src/main/java/org/apache/hudi/common/HoodieRollbackStat.java	89
hudi-common/src/main/java/org/apache/hudi/common/HoodieSchemaNotFoundException.java	7
hudi-common/src/main/java/org/apache/hudi/common/bloom/BloomFilter.java	8
hudi-common/src/main/java/org/apache/hudi/common/bloom/BloomFilterFactory.java	33
hudi-common/src/main/java/org/apache/hudi/common/bloom/BloomFilterTypeCode.java	10
hudi-common/src/main/java/org/apache/hudi/common/bloom/BloomFilterUtils.java	10
hudi-common/src/main/java/org/apache/hudi/common/bloom/HashFunction.java	38
hudi-common/src/main/java/org/apache/hudi/common/bloom/HoodieDynamicBoundedBloomFilter.java	69
hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalBloomFilter.java	128
hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalDynamicBloomFilter.java	148
hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalFilter.java	72
hudi-common/src/main/java/org/apache/hudi/common/bloom/Key.java	72
hudi-common/src/main/java/org/apache/hudi/common/bloom/SimpleBloomFilter.java	93
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/FileStatusUtils.java	82
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/BootstrapIndex.java	60
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java	584
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/NoOpBootstrapIndex.java	23
hudi-common/src/main/java/org/apache/hudi/common/config/AdvancedConfig.java	6
hudi-common/src/main/java/org/apache/hudi/common/config/ConfigClassProperty.java	14
hudi-common/src/main/java/org/apache/hudi/common/config/ConfigGroups.java	131
hudi-common/src/main/java/org/apache/hudi/common/config/ConfigProperty.java	187
hudi-common/src/main/java/org/apache/hudi/common/config/DFSPropertiesConfiguration.java	169
hudi-common/src/main/java/org/apache/hudi/common/config/EnumDescription.java	12
hudi-common/src/main/java/org/apache/hudi/common/config/EnumFieldDescription.java	12
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java	140
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieConfig.java	190
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieFunctionalIndexConfig.java	220
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMemoryConfig.java	120
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMetadataConfig.java	547
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMetaserverConfig.java	77
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieReaderConfig.java	46
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieStorageConfig.java	330
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieTableServiceManagerConfig.java	137
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieTimeGeneratorConfig.java	82
hudi-common/src/main/java/org/apache/hudi/common/config/LockConfiguration.java	73
hudi-common/src/main/java/org/apache/hudi/common/config/OrderedProperties.java	65
hudi-common/src/main/java/org/apache/hudi/common/config/SerializableConfiguration.java	36
hudi-common/src/main/java/org/apache/hudi/common/config/SerializableSchema.java	47
hudi-common/src/main/java/org/apache/hudi/common/config/TimestampKeyGeneratorConfig.java	75
hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java	95
hudi-common/src/main/java/org/apache/hudi/common/conflict/detection/DirectMarkerBasedDetectionStrategy.java	68
hudi-common/src/main/java/org/apache/hudi/common/conflict/detection/EarlyConflictDetectionStrategy.java	10
hudi-common/src/main/java/org/apache/hudi/common/conflict/detection/TimelineServerBasedDetectionStrategy.java	23
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieAccumulator.java	6
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieAtomicLongAccumulator.java	19
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieBaseListData.java	41
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java	61
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieListData.java	120
hudi-common/src/main/java/org/apache/hudi/common/data/HoodieListPairData.java	145
hudi-common/src/main/java/org/apache/hudi/common/data/HoodiePairData.java	26
hudi-common/src/main/java/org/apache/hudi/common/engine/EngineProperty.java	10
hudi-common/src/main/java/org/apache/hudi/common/engine/EngineType.java	4
hudi-common/src/main/java/org/apache/hudi/common/engine/HoodieEngineContext.java	60
hudi-common/src/main/java/org/apache/hudi/common/engine/HoodieLocalEngineContext.java	122
hudi-common/src/main/java/org/apache/hudi/common/engine/HoodieReaderContext.java	65
hudi-common/src/main/java/org/apache/hudi/common/engine/LocalTaskContextSupplier.java	25
hudi-common/src/main/java/org/apache/hudi/common/engine/TaskContextSupplier.java	11
hudi-common/src/main/java/org/apache/hudi/common/fs/ConsistencyGuardConfig.java	145
hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java	557
hudi-common/src/main/java/org/apache/hudi/common/fs/FailSafeConsistencyGuard.java	131
hudi-common/src/main/java/org/apache/hudi/common/fs/FileSystemRetryConfig.java	99
hudi-common/src/main/java/org/apache/hudi/common/fs/OptimisticConsistencyGuard.java	41
hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareDataInputStream.java	34
hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareDataOutputStream.java	39
hudi-common/src/main/java/org/apache/hudi/common/function/FunctionWrapper.java	64
hudi-common/src/main/java/org/apache/hudi/common/function/SerializableBiFunction.java	6
hudi-common/src/main/java/org/apache/hudi/common/function/SerializableConsumer.java	6
hudi-common/src/main/java/org/apache/hudi/common/function/SerializableFunction.java	6
hudi-common/src/main/java/org/apache/hudi/common/function/SerializableFunctionUnchecked.java	7
hudi-common/src/main/java/org/apache/hudi/common/function/SerializablePairFlatMapFunction.java	8
hudi-common/src/main/java/org/apache/hudi/common/function/SerializablePairFunction.java	7
hudi-common/src/main/java/org/apache/hudi/common/function/SerializableSupplier.java	6
hudi-common/src/main/java/org/apache/hudi/common/function/ThrowingConsumer.java	5
hudi-common/src/main/java/org/apache/hudi/common/heartbeat/HoodieHeartbeatUtils.java	29
hudi-common/src/main/java/org/apache/hudi/common/lock/LockProvider.java	30
hudi-common/src/main/java/org/apache/hudi/common/lock/LockState.java	5
hudi-common/src/main/java/org/apache/hudi/common/model/AWSDmsAvroPayload.java	54
hudi-common/src/main/java/org/apache/hudi/common/model/ActionType.java	4
hudi-common/src/main/java/org/apache/hudi/common/model/BaseAvroPayload.java	37
hudi-common/src/main/java/org/apache/hudi/common/model/BaseFile.java	80
hudi-common/src/main/java/org/apache/hudi/common/model/BootstrapBaseFileMapping.java	25
hudi-common/src/main/java/org/apache/hudi/common/model/BootstrapFileMapping.java	74
hudi-common/src/main/java/org/apache/hudi/common/model/BootstrapIndexType.java	48
hudi-common/src/main/java/org/apache/hudi/common/model/CleanFileInfo.java	36
hudi-common/src/main/java/org/apache/hudi/common/model/ClusteringGroupInfo.java	51
hudi-common/src/main/java/org/apache/hudi/common/model/ClusteringOperation.java	85
hudi-common/src/main/java/org/apache/hudi/common/model/CompactionOperation.java	123
hudi-common/src/main/java/org/apache/hudi/common/model/ConsistentHashingNode.java	57
hudi-common/src/main/java/org/apache/hudi/common/model/DefaultHoodieRecordPayload.java	126
hudi-common/src/main/java/org/apache/hudi/common/model/DeleteRecord.java	58
hudi-common/src/main/java/org/apache/hudi/common/model/EmptyHoodieRecordPayload.java	23
hudi-common/src/main/java/org/apache/hudi/common/model/EventTimeAvroPayload.java	39
hudi-common/src/main/java/org/apache/hudi/common/model/FileSlice.java	102
hudi-common/src/main/java/org/apache/hudi/common/model/FirstValueAvroPayload.java	45
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieArchivedLogFile.java	16
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroIndexedRecord.java	175
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroPayload.java	41
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroRecord.java	172
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroRecordMerger.java	36
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieBaseFile.java	116
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCleaningPolicy.java	21
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieColumnRangeMetadata.java	141
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java	422
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieConsistentHashingMetadata.java	125
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieDeltaWriteStat.java	78
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieEmptyRecord.java	119
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFailedWritesCleaningPolicy.java	23
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileFormat.java	43
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java	139
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroupId.java	44
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFunctionalIndexDefinition.java	48
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFunctionalIndexMetadata.java	46
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieKey.java	47
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieLSMTimelineManifest.java	73
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieLogFile.java	195
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieMetadataWrapper.java	23
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieOperation.java	66
hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePartitionMetadata.java	172
hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePayloadProps.java	16
hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePreCombineAvroRecordMerger.java	27
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecord.java	269
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordCompatibilityInterface.java	20
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordDelegate.java	99
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordGlobalLocation.java	72
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordLocation.java	80
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordMerger.java	43
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordPayload.java	46
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieReplaceCommitMetadata.java	96
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRollingStat.java	63
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRollingStatMetadata.java	70
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieSyncTableStrategy.java	4
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieTableQueryType.java	6
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieTableType.java	4
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieTimelineTimeZone.java	19
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieWriteStat.java	251
hudi-common/src/main/java/org/apache/hudi/common/model/IOType.java	6
hudi-common/src/main/java/org/apache/hudi/common/model/MetadataValues.java	72
hudi-common/src/main/java/org/apache/hudi/common/model/OperationModeAwareness.java	4
hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteNonDefaultsWithLatestAvroPayload.java	50
hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java	50
hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java	118
hudi-common/src/main/java/org/apache/hudi/common/model/RecordPayloadType.java	67
hudi-common/src/main/java/org/apache/hudi/common/model/RewriteAvroPayload.java	24
hudi-common/src/main/java/org/apache/hudi/common/model/TableServiceType.java	21
hudi-common/src/main/java/org/apache/hudi/common/model/WriteConcurrencyMode.java	32
hudi-common/src/main/java/org/apache/hudi/common/model/WriteOperationType.java	107
hudi-common/src/main/java/org/apache/hudi/common/model/debezium/AbstractDebeziumAvroPayload.java	56
hudi-common/src/main/java/org/apache/hudi/common/model/debezium/DebeziumConstants.java	42
hudi-common/src/main/java/org/apache/hudi/common/model/debezium/MySqlDebeziumAvroPayload.java	46
hudi-common/src/main/java/org/apache/hudi/common/model/debezium/PostgresDebeziumAvroPayload.java	74
hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableConfig.java	613
hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java	976
hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableVersion.java	27
hudi-common/src/main/java/org/apache/hudi/common/table/TableSchemaResolver.java	392
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCExtractor.java	246
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java	63
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCInferenceCase.java	8
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCOperation.java	26
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCSupplementalLoggingMode.java	16
hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCUtils.java	91
hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java	699
hudi-common/src/main/java/org/apache/hudi/common/table/log/AppendResult.java	22
hudi-common/src/main/java/org/apache/hudi/common/table/log/BaseHoodieLogRecordReader.java	592
hudi-common/src/main/java/org/apache/hudi/common/table/log/FullKeySpec.java	16
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieCDCLogRecordIterator.java	91
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFileReader.java	376
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormat.java	198
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java	85
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReverseReader.java	102
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatVersion.java	74
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java	192
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordReader.java	249
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java	327
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java	135
hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java	184
hudi-common/src/main/java/org/apache/hudi/common/table/log/KeySpec.java	12
hudi-common/src/main/java/org/apache/hudi/common/table/log/LogFileCreationCallback.java	7
hudi-common/src/main/java/org/apache/hudi/common/table/log/LogReaderUtils.java	83
hudi-common/src/main/java/org/apache/hudi/common/table/log/PrefixKeySpec.java	16
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java	257
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlockVersion.java	14
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCDCDataBlock.java	31
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCommandBlock.java	33
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCommandBlockVersion.java	6
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCorruptBlock.java	24
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDataBlock.java	288
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDeleteBlock.java	158
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDeleteBlockVersion.java	6
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java	194
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieLogBlock.java	203
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieLogBlockVersion.java	11
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieParquetDataBlock.java	143
hudi-common/src/main/java/org/apache/hudi/common/table/marker/MarkerOperation.java	13
hudi-common/src/main/java/org/apache/hudi/common/table/marker/MarkerType.java	14
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieBaseFileGroupRecordBuffer.java	214
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupReader.java	264
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupReaderState.java	10
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupRecordBuffer.java	32
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieKeyBasedFileGroupRecordBuffer.java	122
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodiePositionBasedFileGroupRecordBuffer.java	154
hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieUnmergedFileGroupRecordBuffer.java	105
hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java	266
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/ActiveAction.java	132
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/CompletionTimeQueryView.java	183
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java	583
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieArchivedTimeline.java	217
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java	447
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstant.java	256
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstantTimeGenerator.java	114
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java	299
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/LSMTimeline.java	132
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/MetadataConversionUtils.java	227
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGenerator.java	6
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGeneratorBase.java	82
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGeneratorType.java	10
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGenerators.java	26
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineDiffHelper.java	111
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineLayout.java	38
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineMetadataUtils.java	168
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineUtils.java	338
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/WaitBasedTimeGenerator.java	43
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/BaseFileDTO.java	63
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/ClusteringOpDTO.java	32
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/CompactionOpDTO.java	50
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/DTOUtils.java	33
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FSPermissionDTO.java	34
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FileGroupDTO.java	33
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FilePathDTO.java	30
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FileSliceDTO.java	34
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FileStatusDTO.java	67
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/InstantDTO.java	29
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/InstantStateDTO.java	27
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/LogFileDTO.java	27
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/TimelineDTO.java	22
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/AbstractMigratorBase.java	8
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/MetadataMigrator.java	59
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/TimelineLayoutVersion.java	45
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/VersionMigrator.java	7
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanMetadataMigrator.java	13
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanMetadataV1MigrationHandler.java	69
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanMetadataV2MigrationHandler.java	61
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanPlanMigrator.java	11
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanPlanV1MigrationHandler.java	39
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanPlanV2MigrationHandler.java	39
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/compaction/CompactionPlanMigrator.java	11
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/compaction/CompactionV1MigrationHandler.java	51
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/compaction/CompactionV2MigrationHandler.java	42
hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java	1039
hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewManager.java	172
hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewStorageConfig.java	349
hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewStorageType.java	8
hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTableFileSystemView.java	295
hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTablePreCommitFileSystemView.java	41
hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java	316
hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java	264
hudi-common/src/main/java/org/apache/hudi/common/table/view/RemoteHoodieTableFileSystemView.java	547
hudi-common/src/main/java/org/apache/hudi/common/table/view/RocksDbBasedFileSystemView.java	484
hudi-common/src/main/java/org/apache/hudi/common/table/view/SpillableMapBasedFileSystemView.java	198
hudi-common/src/main/java/org/apache/hudi/common/table/view/SyncableFileSystemView.java	9
hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java	54
hudi-common/src/main/java/org/apache/hudi/common/util/ArchivedInstantReadSchemas.java	97
hudi-common/src/main/java/org/apache/hudi/common/util/AvroOrcUtils.java	703
hudi-common/src/main/java/org/apache/hudi/common/util/Base64CodecUtil.java	16
hudi-common/src/main/java/org/apache/hudi/common/util/BaseFileUtils.java	93
hudi-common/src/main/java/org/apache/hudi/common/util/BinaryUtil.java	144
hudi-common/src/main/java/org/apache/hudi/common/util/BufferedRandomAccessFile.java	189
hudi-common/src/main/java/org/apache/hudi/common/util/CleanerUtils.java	148
hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java	211
hudi-common/src/main/java/org/apache/hudi/common/util/CollectionUtils.java	173
hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java	156
hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java	213
hudi-common/src/main/java/org/apache/hudi/common/util/ConfigUtils.java	356
hudi-common/src/main/java/org/apache/hudi/common/util/CustomizedThreadFactory.java	42
hudi-common/src/main/java/org/apache/hudi/common/util/DateTimeUtils.java	138
hudi-common/src/main/java/org/apache/hudi/common/util/DefaultSizeEstimator.java	8
hudi-common/src/main/java/org/apache/hudi/common/util/Either.java	51
hudi-common/src/main/java/org/apache/hudi/common/util/ExternalFilePathUtil.java	10
hudi-common/src/main/java/org/apache/hudi/common/util/Functions.java	20
hudi-common/src/main/java/org/apache/hudi/common/util/FutureUtils.java	21
hudi-common/src/main/java/org/apache/hudi/common/util/HoodieCommonKryoRegistrar.java	46
hudi-common/src/main/java/org/apache/hudi/common/util/HoodieRecordSizeEstimator.java	18
hudi-common/src/main/java/org/apache/hudi/common/util/HoodieRecordUtils.java	78
hudi-common/src/main/java/org/apache/hudi/common/util/InternalSchemaCache.java	150
hudi-common/src/main/java/org/apache/hudi/common/util/JsonUtils.java	33
hudi-common/src/main/java/org/apache/hudi/common/util/MapUtils.java	14
hudi-common/src/main/java/org/apache/hudi/common/util/MarkerUtils.java	187
hudi-common/src/main/java/org/apache/hudi/common/util/NetworkUtils.java	51
hudi-common/src/main/java/org/apache/hudi/common/util/NumericUtils.java	36
hudi-common/src/main/java/org/apache/hudi/common/util/ObjectSizeCalculator.java	7
hudi-common/src/main/java/org/apache/hudi/common/util/OrcReaderIterator.java	83
hudi-common/src/main/java/org/apache/hudi/common/util/OrcUtils.java	219
hudi-common/src/main/java/org/apache/hudi/common/util/ParquetReaderIterator.java	48
hudi-common/src/main/java/org/apache/hudi/common/util/ParquetUtils.java	365
hudi-common/src/main/java/org/apache/hudi/common/util/PartitionPathEncodeUtils.java	76
hudi-common/src/main/java/org/apache/hudi/common/util/RateLimiter.java	63
hudi-common/src/main/java/org/apache/hudi/common/util/RocksDBSchemaHelper.java	101
hudi-common/src/main/java/org/apache/hudi/common/util/SerializationUtils.java	74
hudi-common/src/main/java/org/apache/hudi/common/util/SizeEstimator.java	4
hudi-common/src/main/java/org/apache/hudi/common/util/SpillableMapUtils.java	110
hudi-common/src/main/java/org/apache/hudi/common/util/TablePathUtils.java	80
hudi-common/src/main/java/org/apache/hudi/common/util/ThreadUtils.java	14
hudi-common/src/main/java/org/apache/hudi/common/util/TypeUtils.java	20
hudi-common/src/main/java/org/apache/hudi/common/util/VisibleForTesting.java	3
hudi-common/src/main/java/org/apache/hudi/common/util/collection/ArrayUtils.java	16
hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java	333
hudi-common/src/main/java/org/apache/hudi/common/util/collection/CachingIterator.java	48
hudi-common/src/main/java/org/apache/hudi/common/util/collection/ClosableIterator.java	21
hudi-common/src/main/java/org/apache/hudi/common/util/collection/CloseableMappingIterator.java	12
hudi-common/src/main/java/org/apache/hudi/common/util/collection/DiskMap.java	51
hudi-common/src/main/java/org/apache/hudi/common/util/collection/EmptyIterator.java	14
hudi-common/src/main/java/org/apache/hudi/common/util/collection/ExternalSpillableMap.java	242
hudi-common/src/main/java/org/apache/hudi/common/util/collection/FlatLists.java	88
hudi-common/src/main/java/org/apache/hudi/common/util/collection/FlatteningIterator.java	27
hudi-common/src/main/java/org/apache/hudi/common/util/collection/ImmutablePair.java	26
hudi-common/src/main/java/org/apache/hudi/common/util/collection/ImmutableTriple.java	28
hudi-common/src/main/java/org/apache/hudi/common/util/collection/LazyFileIterable.java	93
hudi-common/src/main/java/org/apache/hudi/common/util/collection/MappingIterator.java	19
hudi-common/src/main/java/org/apache/hudi/common/util/collection/Pair.java	60
hudi-common/src/main/java/org/apache/hudi/common/util/collection/RocksDBBasedMap.java	81
hudi-common/src/main/java/org/apache/hudi/common/util/collection/RocksDBDAO.java	334
hudi-common/src/main/java/org/apache/hudi/common/util/collection/RocksDbDiskMap.java	121
hudi-common/src/main/java/org/apache/hudi/common/util/collection/Triple.java	55
hudi-common/src/main/java/org/apache/hudi/common/util/collection/Tuple3.java	16
hudi-common/src/main/java/org/apache/hudi/common/util/hash/ColumnIndexID.java	36
hudi-common/src/main/java/org/apache/hudi/common/util/hash/FileIndexID.java	36
hudi-common/src/main/java/org/apache/hudi/common/util/hash/Hash.java	33
hudi-common/src/main/java/org/apache/hudi/common/util/hash/HashID.java	76
hudi-common/src/main/java/org/apache/hudi/common/util/hash/HoodieIndexID.java	36
hudi-common/src/main/java/org/apache/hudi/common/util/hash/JenkinsHash.java	117
hudi-common/src/main/java/org/apache/hudi/common/util/hash/MurmurHash.java	51
hudi-common/src/main/java/org/apache/hudi/common/util/hash/PartitionIndexID.java	36
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/HotSpotMemoryLayoutSpecification32bit.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/HotSpotMemoryLayoutSpecification64bit.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/HotSpotMemoryLayoutSpecification64bitCompressed.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/MemoryLayoutSpecification.java	8
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/OpenJ9MemoryLayoutSpecification32bit.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/OpenJ9MemoryLayoutSpecification64bit.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/jvm/OpenJ9MemoryLayoutSpecification64bitCompressed.java	23
hudi-common/src/main/java/org/apache/hudi/common/util/queue/BaseHoodieQueueBasedExecutor.java	126
hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryExecutor.java	54
hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java	167
hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorExecutor.java	33
hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorMessageQueue.java	113
hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorWaitStrategyType.java	33
hudi-common/src/main/java/org/apache/hudi/common/util/queue/ExecutorType.java	18
hudi-common/src/main/java/org/apache/hudi/common/util/queue/FunctionBasedQueueProducer.java	19
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieConsumer.java	5
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieExecutor.java	6
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieMessageQueue.java	14
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieProducer.java	7
hudi-common/src/main/java/org/apache/hudi/common/util/queue/IteratorBasedQueueProducer.java	26
hudi-common/src/main/java/org/apache/hudi/common/util/queue/SimpleExecutor.java	44
hudi-common/src/main/java/org/apache/hudi/common/util/queue/WaitStrategyFactory.java	26
hudi-common/src/main/java/org/apache/hudi/exception/CorruptedLogFileException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/ExceptionUtil.java	13
hudi-common/src/main/java/org/apache/hudi/exception/HoodieAvroSchemaException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/HoodieCatalogException.java	15
hudi-common/src/main/java/org/apache/hudi/exception/HoodieCompactException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieCorruptedDataException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieDebeziumAvroPayloadException.java	7
hudi-common/src/main/java/org/apache/hudi/exception/HoodieDuplicateKeyException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/HoodieEarlyConflictDetectionException.java	12
hudi-common/src/main/java/org/apache/hudi/exception/HoodieFunctionalIndexException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieHeartbeatException.java	16
hudi-common/src/main/java/org/apache/hudi/exception/HoodieIncrementalPathNotFoundException.java	8
hudi-common/src/main/java/org/apache/hudi/exception/HoodieIndexException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieKeyException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieLockException.java	12
hudi-common/src/main/java/org/apache/hudi/exception/HoodieLogCompactException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieMetaSyncException.java	15
hudi-common/src/main/java/org/apache/hudi/exception/HoodieMetadataException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieNotSupportedException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/HoodieNullSchemaTypeException.java	7
hudi-common/src/main/java/org/apache/hudi/exception/HoodieRecordCreationException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/HoodieRecordMissingException.java	8
hudi-common/src/main/java/org/apache/hudi/exception/HoodieRemoteException.java	10
hudi-common/src/main/java/org/apache/hudi/exception/HoodieSecondaryIndexException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieSerializationException.java	18
hudi-common/src/main/java/org/apache/hudi/exception/HoodieTimeTravelException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieValidationException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/HoodieWriteConflictException.java	12
hudi-common/src/main/java/org/apache/hudi/exception/InvalidHoodiePathException.java	7
hudi-common/src/main/java/org/apache/hudi/exception/InvalidTableException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/InvalidUnionTypeException.java	6
hudi-common/src/main/java/org/apache/hudi/exception/MetadataNotFoundException.java	9
hudi-common/src/main/java/org/apache/hudi/exception/MissingSchemaFieldException.java	14
hudi-common/src/main/java/org/apache/hudi/exception/SchemaBackwardsCompatibilityException.java	16
hudi-common/src/main/java/org/apache/hudi/exception/SchemaCompatibilityException.java	13
hudi-common/src/main/java/org/apache/hudi/exception/TableNotFoundException.java	29
hudi-common/src/main/java/org/apache/hudi/expression/ArrayData.java	16
hudi-common/src/main/java/org/apache/hudi/expression/BinaryExpression.java	30
hudi-common/src/main/java/org/apache/hudi/expression/BindVisitor.java	135
hudi-common/src/main/java/org/apache/hudi/expression/BoundReference.java	27
hudi-common/src/main/java/org/apache/hudi/expression/Comparators.java	29
hudi-common/src/main/java/org/apache/hudi/expression/Expression.java	37
hudi-common/src/main/java/org/apache/hudi/expression/ExpressionVisitor.java	11
hudi-common/src/main/java/org/apache/hudi/expression/LeafExpression.java	8
hudi-common/src/main/java/org/apache/hudi/expression/Literal.java	79
hudi-common/src/main/java/org/apache/hudi/expression/NameReference.java	23
hudi-common/src/main/java/org/apache/hudi/expression/PartialBindVisitor.java	100
hudi-common/src/main/java/org/apache/hudi/expression/Predicate.java	14
hudi-common/src/main/java/org/apache/hudi/expression/Predicates.java	311
hudi-common/src/main/java/org/apache/hudi/expression/StructLike.java	5
hudi-common/src/main/java/org/apache/hudi/index/functional/HoodieFunctionalIndex.java	9
hudi-common/src/main/java/org/apache/hudi/index/secondary/HoodieSecondaryIndex.java	90
hudi-common/src/main/java/org/apache/hudi/index/secondary/SecondaryIndexManager.java	124
hudi-common/src/main/java/org/apache/hudi/index/secondary/SecondaryIndexType.java	27
hudi-common/src/main/java/org/apache/hudi/index/secondary/SecondaryIndexUtils.java	46
hudi-common/src/main/java/org/apache/hudi/internal/schema/HoodieSchemaException.java	16
hudi-common/src/main/java/org/apache/hudi/internal/schema/InternalSchema.java	179
hudi-common/src/main/java/org/apache/hudi/internal/schema/InternalSchemaBuilder.java	191
hudi-common/src/main/java/org/apache/hudi/internal/schema/Type.java	121
hudi-common/src/main/java/org/apache/hudi/internal/schema/Types.java	569
hudi-common/src/main/java/org/apache/hudi/internal/schema/action/InternalSchemaChangeApplier.java	88
hudi-common/src/main/java/org/apache/hudi/internal/schema/action/InternalSchemaMerger.java	141
hudi-common/src/main/java/org/apache/hudi/internal/schema/action/TableChange.java	177
hudi-common/src/main/java/org/apache/hudi/internal/schema/action/TableChanges.java	285
hudi-common/src/main/java/org/apache/hudi/internal/schema/action/TableChangesHelper.java	44
hudi-common/src/main/java/org/apache/hudi/internal/schema/convert/AvroInternalSchemaConverter.java	326
hudi-common/src/main/java/org/apache/hudi/internal/schema/io/AbstractInternalSchemaStorageManager.java	9
hudi-common/src/main/java/org/apache/hudi/internal/schema/io/FileBasedInternalSchemaStorageManager.java	155
hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/AvroSchemaEvolutionUtils.java	98
hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/Conversions.java	25
hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/InternalSchemaUtils.java	187
hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/SchemaChangeUtils.java	217
hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/SerDeHelper.java	271
hudi-common/src/main/java/org/apache/hudi/internal/schema/visitor/InternalSchemaVisitor.java	47
hudi-common/src/main/java/org/apache/hudi/internal/schema/visitor/NameToIDVisitor.java	74
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroBootstrapFileReader.java	15
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReader.java	3
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderBase.java	20
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderFactory.java	51
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileWriter.java	30
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileWriterFactory.java	88
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroHFileReaderImplBase.java	97
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroHFileWriter.java	152
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroOrcReader.java	85
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroOrcWriter.java	125
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroParquetReader.java	119
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroParquetWriter.java	53
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieBaseParquetWriter.java	103
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieBootstrapFileReader.java	89
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieBootstrapRecordIterator.java	54
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileReader.java	24
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileReaderFactory.java	104
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileWriter.java	18
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileWriterFactory.java	102
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHBaseAvroHFileReader.java	517
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHBaseKVComparator.java	4
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileConfig.java	71
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHFileUtils.java	48
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieNativeAvroHFileReader.java	459
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieOrcConfig.java	43
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieParquetConfig.java	48
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieParquetStreamWriter.java	67
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieSeekingFileReader.java	21
hudi-common/src/main/java/org/apache/hudi/keygen/BaseKeyGenerator.java	43
hudi-common/src/main/java/org/apache/hudi/keygen/KeyGenerator.java	22
hudi-common/src/main/java/org/apache/hudi/keygen/KeyGeneratorInterface.java	9
hudi-common/src/main/java/org/apache/hudi/keygen/constant/KeyGeneratorOptions.java	79
hudi-common/src/main/java/org/apache/hudi/keygen/constant/KeyGeneratorType.java	90
hudi-common/src/main/java/org/apache/hudi/metadata/AbstractHoodieTableMetadata.java	64
hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java	314
hudi-common/src/main/java/org/apache/hudi/metadata/FileSystemBackedTableMetadata.java	221
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java	597
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataFileSystemView.java	81
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataLogRecordReader.java	166
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataMetrics.java	109
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java	551
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadata.java	101
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java	1273
hudi-common/src/main/java/org/apache/hudi/metadata/MetadataPartitionType.java	32
hudi-common/src/main/java/org/apache/hudi/metadata/MetadataRecordsGenerationParams.java	50
hudi-common/src/main/java/org/apache/hudi/parquet/io/ByteBufferBackedInputFile.java	32
hudi-common/src/main/java/org/apache/hudi/parquet/io/OutputStreamBackedOutputFile.java	54
hudi-common/src/main/java/org/apache/hudi/util/Lazy.java	37
hudi-common/src/main/java/org/apache/hudi/util/Transient.java	58
hudi-common/src/main/java/org/apache/parquet/avro/HoodieAvroParquetReaderBuilder.java	44
hudi-common/src/main/java/org/apache/parquet/avro/HoodieAvroReadSupport.java	68
hudi-common/src/main/resources/hbase-site.xml	2077
hudi-examples/hudi-examples-dbt/dbt_project.yml	16
hudi-examples/hudi-examples-dbt/models/example/hudi_insert_overwrite_table.sql	13
hudi-examples/hudi-examples-dbt/models/example/hudi_insert_table.sql	15
hudi-examples/hudi-examples-dbt/models/example/hudi_upsert_partitioned_cow_table.sql	16
hudi-examples/hudi-examples-dbt/models/example/hudi_upsert_partitioned_mor_table.sql	16
hudi-examples/hudi-examples-dbt/models/example/hudi_upsert_table.sql	14
hudi-examples/hudi-examples-dbt/models/example/schema.yml	82
hudi-examples/hudi-examples-dbt/models/example_cdc/profile_changes.sql	20
hudi-examples/hudi-examples-dbt/models/example_cdc/profiles.sql	25
hudi-examples/hudi-examples-dbt/models/example_cdc/raw_updates.sql	16
hudi-examples/hudi-examples-dbt/models/example_cdc/schema.yml	52
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java	900
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/HadoopConfigurations.java	31
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsInference.java	38
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java	212
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkClusteringMetrics.java	50
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkCompactionMetrics.java	59
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkStreamReadMetrics.java	45
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkStreamWriteMetrics.java	87
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkWriteMetrics.java	75
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/HoodieFlinkMetrics.java	31
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/FilebasedSchemaProvider.java	70
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java	10
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaRegistryProvider.java	87
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/CleanFunction.java	78
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java	335
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperator.java	13
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java	432
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/append/AppendWriteFunction.java	105
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/append/AppendWriteOperator.java	13
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java	196
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/IndexRecord.java	14
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAccumulator.java	24
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAggFunction.java	22
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/batch/BatchBootstrapOperator.java	40
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketBulkInsertWriterHelper.java	78
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java	107
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteOperator.java	15
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/ConsistentBucketAssignFunction.java	116
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/ConsistentBucketStreamWriteFunction.java	45
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/AutoRowDataKeyGen.java	31
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java	110
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteOperator.java	20
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java	172
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java	222
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGens.java	19
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/WriterHelpers.java	15
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperator.java	90
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperatorGen.java	33
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitEvent.java	46
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitSink.java	157
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java	303
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanEvent.java	38
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java	98
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanSourceFunction.java	43
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java	138
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/HoodieFlinkClusteringJob.java	231
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/update/strategy/FlinkConsistentBucketUpdateStrategy.java	103
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java	145
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractWriteFunction.java	10
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractWriteOperator.java	26
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/WriteOperatorFactory.java	42
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactOperator.java	118
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitEvent.java	49
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java	119
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanEvent.java	26
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java	99
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanSourceFunction.java	48
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java	132
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java	209
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/strategy/CompactionPlanStrategies.java	48
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/strategy/CompactionPlanStrategy.java	10
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/CommitAckEvent.java	20
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/WriteMetadataEvent.java	142
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java	65
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java	156
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadataFactory.java	19
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/TimelineBasedCkpMetadata.java	71
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/overwrite/PartitionOverwriteMode.java	10
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java	158
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java	185
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigners.java	22
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketIndexPartitioner.java	19
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/DeltaWriteProfile.java	71
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/EmptyWriteProfile.java	15
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java	153
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java	128
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/ChainedTransformer.java	22
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java	56
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctionWithRateLimit.java	28
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctions.java	18
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/Transformer.java	6
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java	93
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java	110
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/PayloadCreation.java	62
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java	314
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/TimeWait.java	57
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionEvaluators.java	412
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionPredicates.java	396
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java	244
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java	391
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java	189
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadOperator.java	186
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadAppendPartitioner.java	12
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadBucketIndexPartitioner.java	13
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/selector/StreamReadAppendKeySelector.java	9
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/selector/StreamReadBucketIndexKeySelector.java	9
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/DataPruner.java	97
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java	85
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PrimaryKeyPruners.java	43
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStats.java	41
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStatsIndices.java	199
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java	378
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java	88
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java	318
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java	130
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java	541
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/CatalogOptions.java	44
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HiveSchemaUtils.java	171
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java	516
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogFactory.java	49
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogUtil.java	211
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java	809
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java	192
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TypeInfoLogicalTypeVisitor.java	142
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/CastMap.java	75
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FilePathUtils.java	314
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java	238
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/InternalSchemaManager.java	130
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/ParquetSplitRecordIterator.java	32
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/RecordIterators.java	112
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/SchemaEvolvedRecordIterator.java	24
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/TypeConverters.java	304
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputFormat.java	607
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputSplit.java	32
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cow/CopyOnWriteInputFormat.java	285
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputFormat.java	707
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputSplit.java	93
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadTableState.java	70
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java	298
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroToRowDataConverters.java	263
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ChangelogModes.java	18
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClientIds.java	174
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClusteringUtil.java	64
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java	97
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/DataModificationInfos.java	7
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/DataTypeUtils.java	108
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ExpressionUtils.java	241
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java	20
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkTables.java	33
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkWriteClients.java	167
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/HoodiePipeline.java	181
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ImplicitTypeConverter.java	102
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/InputFormats.java	9
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/JsonDeserializationFunction.java	43
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/RowDataCastProjection.java	20
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/RowDataProjection.java	56
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/RowDataToAvroConverters.java	284
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java	371
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StringToRowDataConverter.java	83
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ViewStorageProperties.java	54
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java	4
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java	4
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java	17
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java	34
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java	4
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java	10
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java	6
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java	8
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/Utils.java	44
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java	524
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java	40
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java	14
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java	47
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java	27
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java	22
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java	196
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java	366
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java	221
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java	11
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java	53
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java	82
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java	42
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java	262
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java	37
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java	219
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java	31
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java	216
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java	11
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java	13
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java	17
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java	34
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java	4
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java	10
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java	6
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java	8
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/Utils.java	45
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java	524
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java	40
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java	14
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java	47
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java	27
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java	22
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java	196
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java	366
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java	221
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java	11
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java	53
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java	82
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java	42
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java	262
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java	37
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java	219
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java	31
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java	216
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java	11
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java	13
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java	17
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java	34
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java	21
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java	10
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java	6
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java	8
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/Utils.java	45
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java	524
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java	40
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java	14
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java	47
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java	27
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java	22
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java	196
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java	366
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java	221
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java	11
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java	53
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java	82
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java	42
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java	262
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java	37
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java	219
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java	31
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java	216
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java	11
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java	13
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java	17
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java	34
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java	21
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java	10
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java	13
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java	15
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/Utils.java	124
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java	524
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java	40
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java	14
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java	47
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java	27
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java	22
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java	196
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java	366
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java	221
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java	11
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java	53
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java	82
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java	42
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java	262
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java	37
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java	219
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java	31
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java	216
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java	11
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java	13
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java	15
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java	34
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java	21
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java	10
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java	13
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java	15
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/Utils.java	124
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java	524
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java	40
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java	14
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java	47
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java	27
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java	22
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java	196
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java	366
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java	221
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java	11
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java	53
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java	82
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java	42
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java	262
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java	37
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java	219
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java	31
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java	216
hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySchemaResolver.java	148
hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncConfig.java	144
hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java	139
hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java	257
hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncException.java	18
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/BoundedFsDataInputStream.java	43
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/CachingPath.java	105
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/ConsistencyGuard.java	29
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HadoopFSUtils.java	100
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HadoopSeekableDataInputStream.java	19
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieRetryWrapperFileSystem.java	216
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieSerializableFileStatus.java	97
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieWrapperFileSystem.java	865
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/NoOpConsistencyGuard.java	15
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/SchemeAwareFSDataInputStream.java	24
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/SerializablePath.java	39
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/SizeAwareFSDataOutputStream.java	51
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/TimedFSDataInputStream.java	47
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFSUtils.java	47
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFileSystem.java	86
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFsDataInputStream.java	92
hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InMemoryFileSystem.java	94
hudi-hadoop-common/src/main/java/org/apache/hudi/storage/hadoop/HadoopStorageConfiguration.java	60
hudi-hadoop-common/src/main/java/org/apache/hudi/storage/hadoop/HoodieHadoopStorage.java	144
hudi-hadoop-mr/src/main/java/com/uber/hoodie/hadoop/HoodieInputFormat.java	4
hudi-hadoop-mr/src/main/java/com/uber/hoodie/hadoop/realtime/HoodieRealtimeInputFormat.java	4
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/BootstrapBaseFileSplit.java	33
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/BootstrapColumnStichingRecordReader.java	75
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/FileStatusWithBootstrapBaseFile.java	15
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HiveHoodieTableFileIndex.java	59
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieColumnProjectionUtils.java	108
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java	249
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHFileInputFormat.java	27
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHFileRecordReader.java	79
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java	116
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormatBase.java	49
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieROTablePathFilter.java	173
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieTableInputFormat.java	40
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/InputPathHandler.java	86
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/InputSplitUtils.java	24
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/LocatedFileStatusWithBootstrapBaseFile.java	17
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/PathWithBootstrapFileStatus.java	13
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/RealtimeFileStatus.java	50
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/RecordReaderValueIterator.java	46
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/SafeParquetRecordReaderWrapper.java	42
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/SchemaEvolutionContext.java	299
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/UseFileSplitsFromInputFormat.java	13
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/UseRecordReaderFromInputFormat.java	13
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/avro/HoodieAvroParquetReader.java	66
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/avro/HoodieTimestampAwareParquetInputFormat.java	18
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineHiveInputFormat.java	732
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineRealtimeFileSplit.java	110
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineRealtimeHiveSplit.java	19
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java	165
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java	69
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieEmptyRecordReader.java	36
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieHFileRealtimeInputFormat.java	53
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadSnapshotReader.java	168
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadTableInputFormat.java	305
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieParquetRealtimeInputFormat.java	77
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieParquetSerde.java	7
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimeBootstrapBaseFileSplit.java	82
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimeFileSplit.java	90
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimePath.java	55
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimeRecordReader.java	70
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieVirtualKeyInfo.java	36
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java	172
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeSplit.java	76
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java	104
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HiveAvroSerializer.java	324
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieHiveUtils.java	112
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieInputFormatUtils.java	349
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java	102
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeRecordReaderUtils.java	245
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/shims/Hive2Shim.java	26
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/shims/Hive3Shim.java	75
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/shims/HiveShim.java	8
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/shims/HiveShims.java	6
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieContinuousTestSuiteWriter.java	84
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java	58
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java	173
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieMultiWriterTestSuiteJob.java	157
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteJob.java	262
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java	129
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/SparkDataSourceContinuousIngestTool.java	100
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/configuration/DFSDeltaConfig.java	54
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/configuration/DeltaConfig.java	388
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/converter/Converter.java	6
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/converter/DeleteConverter.java	18
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/converter/UpdateConverter.java	24
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/DagUtils.java	362
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/ExecutionContext.java	26
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/SimpleWorkflowDagGenerator.java	40
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/WorkflowDag.java	33
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/WorkflowDagGenerator.java	4
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/WriterContext.java	113
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/BaseQueryNode.java	37
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/BaseValidateDatasetNode.java	182
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/BulkInsertNode.java	17
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/CleanNode.java	13
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ClusteringNode.java	21
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/CompactNode.java	26
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/DagNode.java	95
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/DelayNode.java	16
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/DeleteInputDatasetNode.java	27
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/DeleteNode.java	27
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/HiveQueryNode.java	46
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/HiveSyncNode.java	20
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/InsertNode.java	43
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/InsertOverwriteNode.java	18
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/InsertOverwriteTableNode.java	18
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/PrestoQueryNode.java	44
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/RollbackNode.java	42
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ScheduleCompactNode.java	30
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/SparkSQLQueryNode.java	37
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/TrinoQueryNode.java	36
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/UpsertNode.java	28
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java	83
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateDatasetNode.java	32
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateNode.java	24
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java	96
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/SaferSchemaDagScheduler.java	29
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/DeleteGeneratorIterator.java	22
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/DeltaGenerator.java	276
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/FlexibleSchemaRecordGenerationIterator.java	50
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/GenericRecordFullPayloadGenerator.java	289
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/GenericRecordFullPayloadSizeEstimator.java	79
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/GenericRecordPartialPayloadGenerator.java	46
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/LazyRecordGeneratorIterator.java	20
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/UpdateGeneratorIterator.java	33
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/helpers/DFSTestSuitePathSelector.java	77
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/helpers/HiveServiceProvider.java	43
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/helpers/ZookeeperServiceProvider.java	26
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSAvroDeltaInputReader.java	59
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSDeltaInputReader.java	61
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSHoodieDatasetInputReader.java	295
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DeltaInputReader.java	10
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DeltaInputType.java	4
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/SparkBasedReader.java	46
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/schema/SchemaUtils.java	4
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/schema/TestSuiteFileBasedSchemaProvider.java	37
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkUtil.java	103
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/AvroFileDeltaInputWriter.java	80
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DFSDeltaWriterAdapter.java	40
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DFSSparkAvroDeltaWriter.java	16
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DeltaInputWriter.java	9
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DeltaOutputMode.java	4
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DeltaWriteStats.java	35
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DeltaWriterAdapter.java	11
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/DeltaWriterFactory.java	31
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/writer/SparkAvroDeltaInputWriter.java	37
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/SparkDataSourceContinuousIngest.scala	67
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkBulkInsertNode.scala	10
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkDeleteNode.scala	34
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkDeletePartitionNode.scala	28
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkInsertNode.scala	47
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkInsertOverwriteNode.scala	8
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkInsertOverwriteTableNode.scala	8
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkUpsertNode.scala	17
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/BaseSparkSqlNode.scala	38
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlCreateTableNode.scala	51
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlDeleteNode.scala	23
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlInsertNode.scala	15
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlInsertOverwriteNode.scala	15
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlMergeNode.scala	22
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlUpdateNode.scala	23
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/spark/sql/SparkSqlValidateDatasetNode.scala	31
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkTestWriter.scala	71
hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/utils/SparkSqlUtils.scala	231
hudi-io/src/main/java/org/apache/hudi/ApiMaturityLevel.java	6
hudi-io/src/main/java/org/apache/hudi/PublicAPIClass.java	14
hudi-io/src/main/java/org/apache/hudi/PublicAPIMethod.java	14
hudi-io/src/main/java/org/apache/hudi/common/metrics/Counter.java	18
hudi-io/src/main/java/org/apache/hudi/common/metrics/LocalRegistry.java	42
hudi-io/src/main/java/org/apache/hudi/common/metrics/Metric.java	5
hudi-io/src/main/java/org/apache/hudi/common/metrics/Registry.java	41
hudi-io/src/main/java/org/apache/hudi/common/util/ComparableVersion.java	252
hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java	175
hudi-io/src/main/java/org/apache/hudi/common/util/HoodieTimer.java	50
hudi-io/src/main/java/org/apache/hudi/common/util/Option.java	115
hudi-io/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java	124
hudi-io/src/main/java/org/apache/hudi/common/util/RetryHelper.java	107
hudi-io/src/main/java/org/apache/hudi/common/util/StringUtils.java	149
hudi-io/src/main/java/org/apache/hudi/common/util/ValidationUtils.java	27
hudi-io/src/main/java/org/apache/hudi/common/util/io/ByteBufferBackedInputStream.java	64
hudi-io/src/main/java/org/apache/hudi/exception/HoodieException.java	15
hudi-io/src/main/java/org/apache/hudi/exception/HoodieIOException.java	15
hudi-io/src/main/java/org/apache/hudi/io/ByteArraySeekableDataInputStream.java	18
hudi-io/src/main/java/org/apache/hudi/io/SeekableDataInputStream.java	11
hudi-io/src/main/java/org/apache/hudi/io/compress/CompressionCodec.java	17
hudi-io/src/main/java/org/apache/hudi/io/compress/HoodieDecompressor.java	9
hudi-io/src/main/java/org/apache/hudi/io/compress/HoodieDecompressorFactory.java	16
hudi-io/src/main/java/org/apache/hudi/io/compress/airlift/HoodieAirliftGzipDecompressor.java	23
hudi-io/src/main/java/org/apache/hudi/io/compress/builtin/HoodieNoneDecompressor.java	15
hudi-io/src/main/java/org/apache/hudi/io/hfile/BlockIndexEntry.java	42
hudi-io/src/main/java/org/apache/hudi/io/hfile/DataSize.java	9
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileBlock.java	125
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileBlockReader.java	47
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileBlockType.java	57
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileContext.java	33
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileCursor.java	55
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileDataBlock.java	61
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileFileInfoBlock.java	35
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileInfo.java	54
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileMetaBlock.java	14
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileReader.java	20
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileReaderImpl.java	233
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileRootIndexBlock.java	43
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileTrailer.java	122
hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileUtils.java	57
hudi-io/src/main/java/org/apache/hudi/io/hfile/Key.java	59
hudi-io/src/main/java/org/apache/hudi/io/hfile/KeyValue.java	44
hudi-io/src/main/java/org/apache/hudi/io/hfile/UTF8StringKey.java	24
hudi-io/src/main/java/org/apache/hudi/io/util/IOUtils.java	175
hudi-io/src/main/java/org/apache/hudi/storage/HoodieStorage.java	143
hudi-io/src/main/java/org/apache/hudi/storage/StorageConfiguration.java	35
hudi-io/src/main/java/org/apache/hudi/storage/StoragePath.java	222
hudi-io/src/main/java/org/apache/hudi/storage/StoragePathFilter.java	10
hudi-io/src/main/java/org/apache/hudi/storage/StoragePathInfo.java	81
hudi-io/src/main/java/org/apache/hudi/storage/StorageSchemes.java	66
hudi-io/src/main/protobuf/HFile.proto	47
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/HoodieSinkConnector.java	46
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/HoodieSinkTask.java	165
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/KafkaConnectFileIdPrefixProvider.java	28
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaConnectControlAgent.java	149
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaControlAgent.java	11
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaControlProducer.java	41
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionCoordinator.java	347
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionParticipant.java	221
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/CoordinatorEvent.java	37
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionCoordinator.java	9
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionInfo.java	32
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionParticipant.java	13
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/utils/KafkaConnectUtils.java	176
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/AbstractConnectWriter.java	66
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java	92
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectTransactionServices.java	10
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectWriter.java	8
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectWriterProvider.java	4
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectConfigs.java	184
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java	127
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectWriterProvider.java	80
hudi-kafka-connect/src/main/resources/ControlMessage.proto	56
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/common/table/HoodieTableMetaserverClient.java	110
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/common/table/timeline/HoodieMetaserverBasedTimeline.java	67
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/common/table/view/HoodieMetaserverFileSystemView.java	18
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClient.java	21
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java	146
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientProxy.java	33
hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/util/EntityConversions.java	80
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/HoodieMetaserver.java	88
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/HoodieMetaserverPreparations.java	15
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/service/HoodieMetaserverGateway.java	57
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/service/HoodieMetaserverProxyHandler.java	36
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/service/TableService.java	50
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/service/TimelineService.java	112
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/MetaserverStorage.java	37
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/RelationalDBBasedStorage.java	205
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/bean/InstantBean.java	66
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/bean/TableBean.java	92
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/jdbc/BasicDao.java	61
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/jdbc/BatchDaoOperation.java	40
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/jdbc/HikariDataSourceFactory.java	16
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/jdbc/SqlSessionFactoryUtils.java	33
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/jdbc/WrapperDao.java	77
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/util/MetaserverTableUtils.java	13
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/util/TServerSocketWrapper.java	23
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/resources/mybatis-config.xml	25
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/resources/mybatis/DDLMapper.xml	102
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/resources/mybatis/TableMapper.xml	50
hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/resources/mybatis/TimelineMapper.xml	120
hudi-platform-service/hudi-metaserver/src/main/thrift/hudi-metaserver.thrift	65
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/DataSourceUtils.java	231
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/HoodieSparkFunctionalIndexClient.java	105
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/async/SparkStreamingAsyncClusteringService.java	15
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/async/SparkStreamingAsyncCompactService.java	15
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/commit/BaseDatasetBulkInsertCommitActionExecutor.java	98
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/commit/DatasetBulkInsertCommitActionExecutor.java	64
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/commit/DatasetBulkInsertOverwriteCommitActionExecutor.java	53
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/commit/DatasetBulkInsertOverwriteTableCommitActionExecutor.java	36
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/commit/HoodieStreamerDatasetBulkInsertCommitActionExecutor.java	31
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/internal/BaseDefaultSource.java	19
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/internal/BaseWriterCommitMessage.java	17
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/internal/DataSourceInternalWriterHelper.java	81
hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/sql/InsertMode.java	26
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/AutoRecordKeyGenerationUtils.scala	33
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/AvroProjection.scala	18
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala	106
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala	285
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala	758
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DefaultSource.scala	301
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/EmptyRelation.scala	11
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/FileSystemRelation.scala	88
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/FunctionalIndexSupport.scala	140
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBaseRelation.scala	532
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRDD.scala	57
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala	57
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRDD.scala	85
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala	162
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieCDCFileIndex.scala	56
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieCLIUtils.scala	82
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieCatalystUtils.scala	23
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieCreateRecordUtils.scala	216
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieDataSourceHelper.scala	99
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieEmptyRelation.scala	8
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileIndex.scala	373
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieHadoopFsRelationFactory.scala	297
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieIncrementalFileIndex.scala	100
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieMergeOnReadRDD.scala	107
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodiePartitionCDCFileGroupMapping.scala	11
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodiePartitionFileSliceMapping.scala	14
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodiePartitionValues.scala	67
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSchemaUtils.scala	131
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkConfUtils.scala	17
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala	870
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieStreamingSink.scala	275
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieWriterUtils.scala	202
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/IncrementalRelation.scala	242
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/Iterators.scala	327
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelation.scala	201
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala	100
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/RecordLevelIndexSupport.scala	123
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkConfigs.scala	5
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkFilterHelper.scala	96
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala	299
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/TimelineRelation.scala	76
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCFileGroupIterator.scala	415
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCRelation.scala	147
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala	439
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/InternalRowToJsonStringConverter.scala	29
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/package.scala	10
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/util/CachingIterator.scala	11
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/HoodieHadoopFSUtils.scala	233
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/execution/datasources/HoodieInMemoryFileIndex.scala	122
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/FileFormatUtilsForFileGroupReader.scala	89
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/HoodieSparkTypeUtils.scala	12
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/avro/HoodieSparkAvroSchemaConverters.scala	12
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/avro/SchemaConverters.scala	155
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/catalog/HoodieCatalogTable.scala	236
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/HoodieUnaryLikeSham.scala	5
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/trees/HoodieLeafLike.scala	6
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieMultipleBaseFileFormat.scala	217
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala	343
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieParquetFileFormatHelper.scala	55
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/LegacyHoodieParquetFileFormat.scala	34
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hive/HiveClientUtils.scala	27
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala	236
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieOptionConfig.scala	194
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala	253
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala	396
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableAddColumnsCommand.scala	105
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableAddPartitionCommand.scala	64
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableChangeColumnCommand.scala	61
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala	48
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableRenameCommand.scala	29
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableCommand.scala	180
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableLikeCommand.scala	74
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/DropHoodieTableCommand.scala	86
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/HoodieLeafRunnableCommand.scala	16
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/HoodieSparkValidateDuplicateKeyRecordMerger.scala	16
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoKeyGenerator.scala	59
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/RepairHoodieTableCommand.scala	117
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/ShowHoodieTablePartitionsCommand.scala	36
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala	140
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/TruncateHoodieTableCommand.scala	70
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/ValidateDuplicateKeyPayload.scala	18
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieMetadataLog.scala	39
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieOffsetRangeLimit.scala	5
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieSourceOffset.scala	44
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieStreamSource.scala	142
hudi-spark-datasource/hudi-spark/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlCommon.g4	239
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/HoodieDataSourceHelpers.java	56
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/QuickstartUtils.java	185
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/bootstrap/SparkFullBootstrapDataProviderBase.java	82
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/bootstrap/SparkOrcBootstrapDataProvider.java	13
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/bootstrap/SparkParquetBootstrapDataProvider.java	13
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/ArchiveExecutorUtils.java	42
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java	258
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/HDFSParquetImporterUtils.java	251
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/SchemaProvider.java	26
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/payload/AWSDmsAvroPayload.java	12
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Call.scala	13
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Compaction.scala	33
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DeDupeType.scala	7
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DedupeSparkJob.scala	167
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/HoodieSparkSessionExtension.scala	23
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/SparkHelpers.scala	79
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala	383
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodiePruneFileSourcePartitions.scala	81
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CallProcedureHoodieCommand.scala	14
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala	32
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodieTableCommand.scala	21
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionShowHoodiePathCommand.scala	24
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionShowHoodieTableCommand.scala	18
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala	88
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/DeleteHoodieTableCommand.scala	45
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/IndexCommands.scala	90
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/InsertIntoHoodieTableCommand.scala	117
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoHoodieTableCommand.scala	474
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/UpdateHoodieTableCommand.scala	51
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/UuidKeyGenerator.scala	9
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala	353
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ArchiveCommitsProcedure.scala	48
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BaseProcedure.scala	71
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CommitsCompareProcedure.scala	50
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CopyToTableProcedure.scala	95
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CopyToTempViewProcedure.scala	83
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CreateMetadataTableProcedure.scala	49
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CreateSavepointProcedure.scala	61
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteMarkerProcedure.scala	60
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteMetadataTableProcedure.scala	46
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteSavepointProcedure.scala	65
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ExportInstantsProcedure.scala	177
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HdfsParquetImportProcedure.scala	51
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HelpProcedure.scala	89
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HiveSyncProcedure.scala	77
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HoodieProcedureUtils.scala	70
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HoodieProcedures.scala	75
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/InitMetadataTableProcedure.scala	52
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/Procedure.scala	12
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ProcedureArgs.scala	7
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ProcedureBuilder.scala	4
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ProcedureParameter.scala	17
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ProcedureParameterImpl.scala	19
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairAddpartitionmetaProcedure.scala	57
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairCorruptedCleanFilesProcedure.scala	56
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairDeduplicateProcedure.scala	57
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairMigratePartitionMetaProcedure.scala	79
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairOverwriteHoodiePropsProcedure.scala	64
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RollbackToInstantTimeProcedure.scala	62
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RollbackToSavepointProcedure.scala	63
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunBootstrapProcedure.scala	116
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunCleanProcedure.scala	88
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunClusteringProcedure.scala	187
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunCompactionProcedure.scala	122
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunTTLProcedure.scala	62
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowArchivedCommitsProcedure.scala	138
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowBootstrapMappingProcedure.scala	77
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowBootstrapPartitionsProcedure.scala	38
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowClusteringProcedure.scala	62
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowColumnStatsOverlapProcedure.scala	234
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitExtraMetadataProcedure.scala	99
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitFilesProcedure.scala	90
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitPartitionsProcedure.scala	105
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitWriteStatsProcedure.scala	80
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitsProcedure.scala	120
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCompactionProcedure.scala	53
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowFileSystemViewProcedure.scala	228
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowFsPathDetailProcedure.scala	85
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowHoodieLogFileMetadataProcedure.scala	114
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowHoodieLogFileRecordsProcedure.scala	99
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowInvalidParquetProcedure.scala	59
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowMetadataTableColumnStatsProcedure.scala	125
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowMetadataTableFilesProcedure.scala	61
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowMetadataTablePartitionsProcedure.scala	49
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowMetadataTableStatsProcedure.scala	42
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowRollbacksProcedure.scala	103
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowSavepointsProcedure.scala	39
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowTablePropertiesProcedure.scala	39
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/StatsFileSizeProcedure.scala	97
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/StatsWriteAmplificationProcedure.scala	58
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/UpgradeOrDowngradeProcedure.scala	79
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ValidateHoodieSyncProcedure.scala	153
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ValidateMetadataTableFilesProcedure.scala	112
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/parser/HoodieCommonSqlParser.scala	90
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/parser/HoodieSqlCommonAstBuilder.scala	98
hudi-spark-datasource/hudi-spark2/src/main/antlr4/imports/SqlBase.g4	971
hudi-spark-datasource/hudi-spark2/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlBase.g4	87
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/DefaultSource.java	49
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/HoodieBulkInsertDataInternalWriter.java	43
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/HoodieBulkInsertDataInternalWriterFactory.java	30
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/HoodieDataSourceInternalWriter.java	65
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/HoodieWriterCommitMessage.java	10
hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/spark/sql/execution/datasources/parquet/Spark24HoodieVectorizedParquetRecordReader.java	136
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/hudi/Spark2DefaultSource.scala	5
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/hudi/Spark2HoodieFileScanRDD.scala	11
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/hudi/Spark2RowSerDe.scala	13
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/HoodieSpark2CatalystExpressionUtils.scala	98
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/HoodieSpark2CatalystPlanUtils.scala	84
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/HoodieSpark2SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/adapter/Spark2Adapter.scala	138
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	315
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	234
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/HoodieSpark2_4AvroDeserializer.scala	8
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/HoodieSpark2_4AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/analysis/HoodieSpark2Analysis.scala	125
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/encoders/DummyExpressionHolder.scala	7
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/expressions/SafeProjection.scala	26
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DeleteFromTable.scala	7
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/MergeInto.scala	38
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/UpdateTable.scala	9
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark2PartitionedFileUtils.scala	23
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/Spark2ParsePartitionUtil.scala	18
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark24LegacyHoodieParquetFileFormat.scala	186
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/hudi/parser/HoodieSpark2ExtendedSqlAstBuilder.scala	162
hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/hudi/parser/HoodieSpark2ExtendedSqlParser.scala	116
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/DefaultSource.java	38
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieBulkInsertDataInternalWriter.java	47
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieBulkInsertDataInternalWriterFactory.java	30
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieDataSourceInternalBatchWrite.java	66
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieDataSourceInternalBatchWriteBuilder.java	35
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieDataSourceInternalTable.java	56
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/HoodieWriterCommitMessage.java	11
hudi-spark-datasource/hudi-spark3-common/src/main/java/org/apache/hudi/spark3/internal/ReflectUtil.java	51
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/hudi/Spark3RowSerDe.scala	15
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/HoodieSpark3CatalogUtils.scala	13
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/HoodieSpark3CatalystExpressionUtils.scala	7
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/HoodieSpark3CatalystPlanUtils.scala	60
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/adapter/BaseSpark3Adapter.scala	63
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/connector/catalog/HoodieIdentifier.scala	16
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/execution/datasources/Spark3ParsePartitionUtil.scala	190
hudi-spark-datasource/hudi-spark3.0.x/src/main/java/org/apache/spark/sql/execution/datasources/parquet/Spark30HoodieVectorizedParquetRecordReader.java	137
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/hudi/Spark30DefaultSource.scala	5
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/hudi/Spark30HoodieFileScanRDD.scala	14
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/HoodieSpark30CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/HoodieSpark30CatalystExpressionUtils.scala	99
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/HoodieSpark30CatalystPlanUtils.scala	49
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/HoodieSpark30SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_0Adapter.scala	75
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	360
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	297
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	52
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_0AvroDeserializer.scala	13
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_0AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/catalyst/analysis/HoodieSpark30Analysis.scala	121
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/HStatments.scala	23
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark30PartitionedFileUtils.scala	23
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark30NestedSchemaPruning.scala	166
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark30LegacyHoodieParquetFileFormat.scala	319
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi/Spark30ResolveHudiAlterTableCommand.scala	236
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi/command/Spark30AlterTableCommand.scala	258
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark30SqlAstBuilder.scala	42
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_0ExtendedSqlParser.scala	11
hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/vectorized/ColumnarUtils.scala	5
hudi-spark-datasource/hudi-spark3.1.x/src/main/java/org/apache/spark/sql/execution/datasources/parquet/Spark31HoodieVectorizedParquetRecordReader.java	138
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/hudi/Spark31DefaultSource.scala	5
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/hudi/Spark31HoodieFileScanRDD.scala	14
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/HoodieSpark31CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/HoodieSpark31CatalystExpressionUtils.scala	75
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/HoodieSpark31CatalystPlanUtils.scala	50
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/HoodieSpark31SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_1Adapter.scala	77
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	364
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	296
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	45
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_1AvroDeserializer.scala	15
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_1AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/catalyst/analysis/HoodieSpark31Analysis.scala	130
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/HStatments.scala	23
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark31PartitionedFileUtils.scala	23
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark31NestedSchemaPruning.scala	116
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark31LegacyHoodieParquetFileFormat.scala	325
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/hudi/Spark31ResolveHudiAlterTableCommand.scala	224
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/hudi/command/Spark31AlterTableCommand.scala	258
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark31SqlAstBuilder.scala	42
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_1ExtendedSqlParser.scala	12
hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/vectorized/ColumnarUtils.scala	5
hudi-spark-datasource/hudi-spark3.2.x/src/main/antlr4/imports/SqlBase.g4	1760
hudi-spark-datasource/hudi-spark3.2.x/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlBase.g4	36
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/hudi/Spark32HoodieFileScanRDD.scala	11
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/HoodieSpark32CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/HoodieSpark32CatalystExpressionUtils.scala	78
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/HoodieSpark32CatalystPlanUtils.scala	95
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/HoodieSpark32SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_2Adapter.scala	83
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	377
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	331
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	49
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_2AvroDeserializer.scala	11
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_2AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark32PartitionedFileUtils.scala	23
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark32NestedSchemaPruning.scala	117
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32DataSourceUtils.scala	33
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32LegacyHoodieParquetFileFormat.scala	383
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala	44
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark32Analysis.scala	28
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_2ExtendedSqlAstBuilder.scala	2345
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_2ExtendedSqlParser.scala	139
hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/vectorized/ColumnarUtils.scala	5
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/java/org/apache/spark/sql/execution/datasources/parquet/Spark32PlusHoodieVectorizedParquetRecordReader.java	141
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/hudi/Spark32PlusDefaultSource.scala	5
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logcal/HoodieFileSystemViewTableValuedFunction.scala	31
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logcal/HoodieMetadataTableValuedFunction.scala	19
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logcal/HoodieQuery.scala	24
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logcal/HoodieTableChanges.scala	42
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logcal/HoodieTimelineTableValuedFunction.scala	34
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Index.scala	47
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark32PlusAnalysis.scala	256
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/analysis/TableValuedFunctions.scala	33
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/BasicStagedTable.scala	24
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/HoodieCatalog.scala	348
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/HoodieInternalV2Table.scala	85
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/HoodieStagedTable.scala	66
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/TableCreationMode.java	4
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterTableCommand.scala	278
hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/logical/TimeTravelRelation.scala	11
hudi-spark-datasource/hudi-spark3.3.x/src/main/antlr4/imports/SqlBase.g4	1760
hudi-spark-datasource/hudi-spark3.3.x/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlBase.g4	36
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/hudi/Spark33HoodieFileScanRDD.scala	15
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/HoodieSpark33CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/HoodieSpark33CatalystExpressionUtils.scala	78
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/HoodieSpark33CatalystPlanUtils.scala	84
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/HoodieSpark33SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_3Adapter.scala	83
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	375
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	327
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	128
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_3AvroDeserializer.scala	11
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_3AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark33PartitionedFileUtils.scala	23
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark33NestedSchemaPruning.scala	116
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark33DataSourceUtils.scala	33
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark33LegacyHoodieParquetFileFormat.scala	389
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/hudi/Spark33ResolveHudiAlterTableCommand.scala	44
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark33Analysis.scala	28
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_3ExtendedSqlAstBuilder.scala	2351
hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_3ExtendedSqlParser.scala	140
hudi-spark-datasource/hudi-spark3.4.x/src/main/antlr4/imports/SqlBase.g4	1760
hudi-spark-datasource/hudi-spark3.4.x/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlBase.g4	36
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/hudi/Spark34HoodieFileScanRDD.scala	15
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/HoodieSpark34CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/HoodieSpark34CatalystExpressionUtils.scala	76
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/HoodieSpark34CatalystPlanUtils.scala	87
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/HoodieSpark34SchemaUtils.scala	14
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_4Adapter.scala	83
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	375
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	325
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	128
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_4AvroDeserializer.scala	11
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_4AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark34PartitionedFileUtils.scala	24
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark34NestedSchemaPruning.scala	116
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark34DataSourceUtils.scala	33
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark34LegacyHoodieParquetFileFormat.scala	399
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/hudi/Spark34ResolveHudiAlterTableCommand.scala	44
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark34Analysis.scala	28
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_4ExtendedSqlAstBuilder.scala	2353
hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_4ExtendedSqlParser.scala	140
hudi-spark-datasource/hudi-spark3.5.x/src/main/antlr4/imports/SqlBase.g4	1760
hudi-spark-datasource/hudi-spark3.5.x/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlBase.g4	36
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/hudi/Spark35HoodieFileScanRDD.scala	15
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/HoodieSpark35CatalogUtils.scala	9
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/HoodieSpark35CatalystExpressionUtils.scala	76
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/HoodieSpark35CatalystPlanUtils.scala	87
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/HoodieSpark35SchemaUtils.scala	15
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_5Adapter.scala	83
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	375
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala	324
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala	128
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_5AvroDeserializer.scala	10
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/HoodieSpark3_5AvroSerializer.scala	8
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieSpark35PartitionedFileUtils.scala	24
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark35NestedSchemaPruning.scala	116
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark35DataSourceUtils.scala	32
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark35LegacyHoodieParquetFileFormat.scala	401
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/hudi/Spark35ResolveHudiAlterTableCommand.scala	44
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark35Analysis.scala	28
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_5ExtendedSqlAstBuilder.scala	2354
hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_5ExtendedSqlParser.scala	140
hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/AdbSyncConfig.java	173
hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/AdbSyncTool.java	204
hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/HoodieAdbJdbcClient.java	413
hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/HoodieAdbSyncException.java	9
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java	161
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncTool.java	30
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DatahubResponseLogger.java	23
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/HoodieDataHubSyncException.java	10
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/config/DataHubEmitterSupplier.java	5
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/config/DataHubSyncConfig.java	96
hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/config/HoodieDataHubDatasetIdentifier.java	31
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveStylePartitionValueExtractor.java	16
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java	161
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfigHolder.java	126
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java	358
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncClient.java	378
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncException.java	9
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/MultiPartKeysValueExtractor.java	24
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/NonPartitionedExtractor.java	10
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/SchemaDifference.java	78
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/SinglePartPartitionValueExtractor.java	10
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/SlashEncodedDayPartitionValueExtractor.java	33
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/SlashEncodedHourPartitionValueExtractor.java	34
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/DDLExecutor.java	17
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HMSDDLExecutor.java	250
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HiveQueryDDLExecutor.java	121
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HiveSyncMode.java	11
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/JDBCExecutor.java	162
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/QueryBasedDDLExecutor.java	174
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/GlobalHiveSyncConfig.java	39
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/GlobalHiveSyncTool.java	56
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/HiveSyncGlobalCommit.java	5
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/HiveSyncGlobalCommitParams.java	72
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/HiveSyncGlobalCommitTool.java	100
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/ReplicationStateSync.java	47
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java	188
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/ColumnNameXLator.java	24
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/FilterGenVisitor.java	89
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/HivePartitionUtil.java	50
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/HiveSchemaUtil.java	390
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/IMetaStoreClientUtil.java	19
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/PartitionFilterGenerator.java	166
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieMetaSyncOperations.java	86
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncClient.java	160
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncConfig.java	242
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncException.java	18
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncTool.java	29
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/model/FieldSchema.java	49
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/model/Partition.java	16
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/model/PartitionEvent.java	21
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/model/PartitionValueExtractor.java	6
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/ManifestFileWriter.java	98
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/Parquet2SparkSchemaUtils.java	136
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SparkDataSourceTableUtils.java	64
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java	102
hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/TableUtils.java	6
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java	536
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java	365
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/BaseFileHandler.java	55
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java	124
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/Handler.java	19
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/InstantStateHandler.java	59
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/MarkerHandler.java	196
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/TimelineHandler.java	24
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/AsyncTimelineServerBasedDetectionStrategy.java	52
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/BatchedMarkerCreationContext.java	27
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/BatchedMarkerCreationRunnable.java	22
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerBasedEarlyConflictDetectionRunnable.java	87
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerCreationDispatchingRunnable.java	42
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerCreationFuture.java	38
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerDirState.java	251
hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java	224
hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java	280
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCleaner.java	74
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java	245
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactionAdminTool.java	124
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java	245
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableUtils.java	21
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java	280
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java	302
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieIndexer.java	267
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java	1158
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieRepairTool.java	338
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java	143
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotExporter.java	238
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieTTLJob.java	88
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java	89
hudi-utilities/src/main/java/org/apache/hudi/utilities/IdentitySplitter.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/SqlQueryBuilder.java	69
hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java	326
hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java	514
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/SourceCommitCallback.java	5
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java	88
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallbackConfig.java	62
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/pulsar/HoodieWriteCommitPulsarCallback.java	124
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/pulsar/HoodieWriteCommitPulsarCallbackConfig.java	92
hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckPointProvider.java	32
hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckpointFromAnotherHoodieTimelineProvider.java	34
hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/KafkaConnectHdfsProvider.java	107
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/CloudSourceConfig.java	109
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/DFSPathSelectorConfig.java	26
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/DatePartitionPathSelectorConfig.java	46
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/FilebasedSchemaProviderConfig.java	25
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/GCSEventsSourceConfig.java	27
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HiveIncrPullSourceConfig.java	22
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HiveSchemaProviderConfig.java	39
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieIncrSourceConfig.java	69
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieSchemaProviderConfig.java	62
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java	105
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/JdbcSourceConfig.java	81
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/JdbcbasedSchemaProviderConfig.java	60
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/JsonKafkaPostProcessorConfig.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/KafkaSourceConfig.java	85
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/ParquetDFSSourceConfig.java	22
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/ProtoClassBasedSchemaProviderConfig.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/PulsarSourceConfig.java	46
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/S3EventsHoodieIncrSourceConfig.java	56
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/S3SourceConfig.java	59
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/SchemaProviderPostProcessorConfig.java	59
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/SqlFileBasedSourceConfig.java	27
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/SqlSourceConfig.java	20
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/SqlTransformerConfig.java	24
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java	28
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java	36
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamerMetrics.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieMultiTableDeltaStreamer.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/NoNewDataTerminationStrategy.java	8
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/PostWriteTerminationStrategy.java	4
hudi-utilities/src/main/java/org/apache/hudi/utilities/deser/KafkaAvroSchemaDeserializer.java	46
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieIncrementalPullException.java	11
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieIncrementalPullSQLException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieReadFromSourceException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSchemaFetchException.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSchemaPostProcessException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSchemaProviderException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSnapshotExporterException.java	7
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSourcePostProcessException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieSourceTimeoutException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieStreamerException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieStreamerWriteException.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieTransformException.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieTransformExecutionException.java	6
hudi-utilities/src/main/java/org/apache/hudi/utilities/exception/HoodieTransformPlanException.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionException.java	15
hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionMetrics.java	20
hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionService.java	114
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/ArchiveTask.java	56
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/CleanTask.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/ClusteringTask.java	71
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/CompactionTask.java	78
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/HoodieMultiTableServicesMain.java	197
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/MultiTableServiceUtils.java	166
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/TableServicePipeline.java	15
hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/TableServiceTask.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/perf/TimelineServerPerf.java	269
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/DelegatingSchemaProvider.java	29
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/FilebasedSchemaProvider.java	68
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/HiveSchemaProvider.java	63
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/JdbcbasedSchemaProvider.java	36
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/KafkaOffsetPostProcessor.java	58
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/LazyCastingIterator.java	17
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/NullTargetSchemaRegistryProvider.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/ProtoClassBasedSchemaProvider.java	67
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/RowBasedSchemaProvider.java	22
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaPostProcessor.java	22
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaProvider.java	28
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaProviderWithPostProcessor.java	28
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java	174
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaSet.java	17
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SimpleSchemaProvider.java	15
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SparkAvroPostProcessor.java	26
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/JsonToAvroSchemaConverter.java	203
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/postprocessor/ChainedSchemaPostProcessor.java	24
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/postprocessor/DeleteSupportSchemaPostProcessor.java	30
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/postprocessor/DropColumnSchemaPostProcessor.java	52
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/postprocessor/add/AddPrimitiveColumnSchemaPostProcessor.java	58
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroDFSSource.java	39
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroKafkaSource.java	104
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroSource.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/CsvDFSSource.java	72
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsHoodieIncrSource.java	111
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsSource.java	132
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HiveIncrPullSource.java	84
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HoodieIncrSource.java	147
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JdbcSource.java	198
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonDFSSource.java	28
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonKafkaSource.java	93
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonSource.java	12
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/KafkaSource.java	71
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ORCDFSSource.java	29
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ParquetDFSSource.java	32
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ProtoKafkaSource.java	84
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/PulsarSource.java	199
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java	34
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java	130
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsSource.java	65
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SnapshotLoadQuerySplitter.java	28
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java	55
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SqlFileBasedSource.java	58
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SqlSource.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/debezium/DebeziumSource.java	160
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/debezium/MysqlDebeziumSource.java	62
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/debezium/PostgresDebeziumSource.java	51
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/AvroConvertor.java	128
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudDataFetcher.java	34
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectIncrCheckpoint.java	39
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectMetadata.java	16
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelector.java	193
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelectorCommon.java	227
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudStoreIngestionConfig.java	29
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DFSPathSelector.java	109
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DatePartitionPathSelector.java	149
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceCloudStorageHelper.java	45
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java	170
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java	332
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/ProtoConversionUtil.java	400
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/QueryInfo.java	85
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/QueryRunner.java	75
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/S3EventsMetaSelector.java	107
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/SanitizationUtils.java	140
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/GcsIngestionConfig.java	9
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/GcsObjectMetadataFetcher.java	36
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/MessageBatch.java	14
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/MessageValidity.java	23
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/MetadataMessage.java	72
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/PubsubMessagesFetcher.java	106
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/PubsubQueueClient.java	54
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/ChainedJsonKafkaSourcePostProcessor.java	19
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/JsonKafkaSourcePostProcessor.java	11
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java	91
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/PreCombineFieldType.java	7
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/BaseErrorTableWriter.java	20
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/BootstrapExecutor.java	165
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ConfigurationHotUpdateStrategy.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ConfigurationHotUpdateStrategyUtils.java	20
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/DefaultStreamContext.java	19
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ErrorEvent.java	40
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ErrorTableUtils.java	58
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieMultiTableStreamer.java	383
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java	742
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerMetrics.java	116
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java	137
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/NoNewDataTerminationStrategy.java	26
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/PostWriteTerminationStrategy.java	7
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SchedulerConfGenerator.java	78
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java	212
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceProfile.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceProfileSupplier.java	10
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SparkSampleWritesUtils.java	130
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamContext.java	13
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java	969
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/TableExecutionContext.java	48
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/TerminationStrategyUtils.java	18
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/AWSDmsTransformer.java	23
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/ChainedTransformer.java	140
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/ErrorTableAwareChainedTransformer.java	36
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/FlatteningTransformer.java	49
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/SqlFileBasedTransformer.java	57
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/SqlQueryBasedTransformer.java	38
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/Transformer.java	21
hudi-utilities/src/main/java/org/apache/hudi/utilities/util/BloomFilterData.java	68
packaging/bundle-validation/conf/core-site.xml	8
packaging/bundle-validation/conf/hdfs-site.xml	15
packaging/bundle-validation/conf/hive-site.hive2.xml	36
packaging/bundle-validation/conf/hive-site.xml	36
packaging/bundle-validation/docker_java17/TestHiveClientUtils.scala	6
packaging/bundle-validation/flink/insert.sql	17
packaging/bundle-validation/service/read.scala	10
packaging/bundle-validation/service/write.scala	29
packaging/bundle-validation/spark_hadoop_mr/write.scala	29
packaging/bundle-validation/utilities/validate.scala	7
packaging/hudi-aws-bundle/src/main/java/org/apache/hudi/aws/bundle/Main.java	7
packaging/hudi-cli-bundle/src/main/java/org/apache/hudi/cli/bundle/Main.java	7
packaging/hudi-datahub-sync-bundle/src/main/java/org/apache/hudi/datahub/bundle/Main.java	7
packaging/hudi-flink-bundle/src/main/java/org/apache/hudi/flink/bundle/Main.java	7
packaging/hudi-gcp-bundle/src/main/java/org/apache/hudi/gcp/bigquery/bundle/Main.java	7
packaging/hudi-hadoop-mr-bundle/src/main/java/org/apache/hudi/hadoop/bundle/Main.java	7
packaging/hudi-hive-sync-bundle/src/main/java/org/apache/hudi/hive/bundle/Main.java	7
packaging/hudi-kafka-connect-bundle/src/main/java/org/apache/hudi/kafka/connect/bundle/Main.java	7
packaging/hudi-presto-bundle/src/main/java/org/apache/hudi/presto/bundle/Main.java	7
packaging/hudi-spark-bundle/src/main/java/org/apache/hudi/spark/bundle/Main.java	7
packaging/hudi-timeline-server-bundle/src/main/java/org/apache/hudi/timeline/server/bundle/Main.java	7
packaging/hudi-trino-bundle/src/main/java/org/apache/hudi/trino/bundle/Main.java	7
packaging/hudi-utilities-bundle/src/main/java/org/apache/hudi/utilities/bundle/Main.java	7
packaging/hudi-utilities-slim-bundle/src/main/java/org/apache/hudi/utilities/bundle/Main.java	7
scripts/pr_compliance.py	333
scripts/release/generate_jar_path.py	17
style/import-control.xml	7
style/scalastyle.xml	114