Path	Lines of Code
hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java	284
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCleaner.java	77
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java	248
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactionAdminTool.java	125
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java	249
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableUtils.java	23
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java	287
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java	305
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieIndexer.java	271
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java	1556
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieRepairTool.java	341
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotExporter.java	305
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieTTLJob.java	91
hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java	90
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	329
hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java	510
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/SourceCommitCallback.java	7
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	36
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	126
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	76
hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieSchemaProviderConfig.java	56
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	135
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	59
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	28
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	29
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	14
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/HoodieJsonToRowConversionException.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	27
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	167
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	278
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	103
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	59
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	266
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/converter/JsonToAvroSchemaConverter.java	451
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/JsonToAvroSchemaConverterConfig.java	26
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/ProtoSchemaToAvroSchemaConverter.java	17
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	40
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroKafkaSource.java	99
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroSource.java	18
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/CsvDFSSource.java	73
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsHoodieIncrSource.java	118
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsSource.java	135
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HiveIncrPullSource.java	86
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HoodieIncrSource.java	321
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HoodieRetryingKafkaConsumer.java	66
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java	57
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JdbcSource.java	202
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonDFSSource.java	29
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonKafkaSource.java	139
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonSource.java	17
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/KafkaSource.java	115
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ORCDFSSource.java	30
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ParquetDFSSource.java	33
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ProtoKafkaSource.java	109
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/PulsarSource.java	201
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java	44
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java	109
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsSource.java	66
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SnapshotLoadQuerySplitter.java	46
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java	160
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SqlFileBasedSource.java	60
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/SqlSource.java	50
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/debezium/DebeziumSource.java	164
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	129
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudDataFetcher.java	109
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectIncrCheckpoint.java	40
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	189
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelectorCommon.java	389
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	112
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DatePartitionPathSelector.java	152
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	251
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java	448
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaSourceUtil.java	24
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/MercifulJsonToRowConverter.java	246
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/ProtoConversionUtil.java	439
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/QueryInfo.java	128
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/QueryRunner.java	82
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/RowConverter.java	60
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/S3EventsMetaSelector.java	109
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/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	60
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	90
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	38
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/BootstrapExecutor.java	169
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	69
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieMultiTableStreamer.java	390
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java	802
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerMetrics.java	162
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java	145
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	77
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java	241
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	1013
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamerCheckpointUtils.java	153
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	52
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/SqlQueryBasedTransformer.java	34
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