Path	Lines of Code
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