path	# lines of code
spark-load/spark-load-common/src/main/java/org/apache/doris/common/io/Roaring64Map.java	845
spark-load/spark-load-common/src/main/java/org/apache/doris/common/io/Hll.java	327
spark-load/spark-load-common/src/main/java/org/apache/doris/common/io/BitmapValue.java	358
spark-load/spark-load-common/src/main/java/org/apache/doris/common/io/Codec.java	30
spark-load/spark-load-common/src/main/java/org/apache/doris/common/DppResult.java	38
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/AutoType.java	34
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/MethodReflection.java	123
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/FieldReflection.java	185
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/ParameterReflection.java	111
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/ConstructorReflection.java	113
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/GeneratedClasses.java	30
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/ThrowOfCheckedException.java	11
spark-load/spark-load-common/src/main/java/org/apache/doris/common/jmockit/Deencapsulation.java	42
spark-load/spark-load-common/src/main/java/org/apache/doris/config/EtlJobConfig.java	401
spark-load/spark-load-common/src/main/java/org/apache/doris/util/JsonUtils.java	34
spark-load/spark-load-dpp/src/main/java/org/apache/doris/common/SparkDppException.java	16
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/etl/SparkEtlJob.java	220
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/DorisRangePartitioner.java	60
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java	1016
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/StringAccumulator.java	34
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/RollupTreeNode.java	29
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/RollupTreeBuilder.java	5
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/MinimumCoverageRollupTreeBuilder.java	78
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/DppUtils.java	268
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/ColumnParser.java	241
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/GlobalDictBuilder.java	312
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkRDDAggregator.java	497
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/DppColumns.java	80
spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/DorisKryoRegistrator.java	12
spark-load/spark-load-core/src/main/java/org/apache/doris/SparkLoadRunner.java	186
spark-load/spark-load-core/src/main/java/org/apache/doris/common/CommandLineOptions.java	11
spark-load/spark-load-core/src/main/java/org/apache/doris/common/ResponseEntity.java	10
spark-load/spark-load-core/src/main/java/org/apache/doris/common/Constants.java	15
spark-load/spark-load-core/src/main/java/org/apache/doris/common/enums/JobStatus.java	6
spark-load/spark-load-core/src/main/java/org/apache/doris/common/enums/TaskType.java	5
spark-load/spark-load-core/src/main/java/org/apache/doris/common/enums/LoadMode.java	4
spark-load/spark-load-core/src/main/java/org/apache/doris/common/enums/StorageType.java	4
spark-load/spark-load-core/src/main/java/org/apache/doris/common/LoadInfo.java	13
spark-load/spark-load-core/src/main/java/org/apache/doris/common/meta/LoadMeta.java	131
spark-load/spark-load-core/src/main/java/org/apache/doris/common/meta/TableMeta.java	49
spark-load/spark-load-core/src/main/java/org/apache/doris/common/meta/LoadInfoResponse.java	9
spark-load/spark-load-core/src/main/java/org/apache/doris/config/JobConfig.java	201
spark-load/spark-load-core/src/main/java/org/apache/doris/util/FileSystemUtils.java	112
spark-load/spark-load-core/src/main/java/org/apache/doris/util/DateUtils.java	15
spark-load/spark-load-core/src/main/java/org/apache/doris/util/HttpUtils.java	34
spark-load/spark-load-core/src/main/java/org/apache/doris/client/DorisClient.java	197
spark-load/spark-load-core/src/main/java/org/apache/doris/exception/SparkLoadException.java	9
spark-load/spark-load-core/src/main/java/org/apache/doris/load/LoaderFactory.java	15
spark-load/spark-load-core/src/main/java/org/apache/doris/load/job/PullLoader.java	338
spark-load/spark-load-core/src/main/java/org/apache/doris/load/job/Loader.java	84
spark-load/spark-load-core/src/main/java/org/apache/doris/load/job/Recoverable.java	6
custom_env.sh.tpl	2
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala	9
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/read/expression/V2ExpressionBuilder.scala	79
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/read/DorisScanV2.scala	14
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/read/DorisScanBuilder.scala	26
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/catalog/DorisTable.scala	13
spark-doris-connector/spark-doris-connector-spark-3.3/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalog.scala	9
spark-doris-connector/spark-doris-connector-spark-3.2/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala	9
spark-doris-connector/spark-doris-connector-spark-3.2/src/main/scala/org/apache/doris/spark/read/DorisScanBuilder.scala	18
spark-doris-connector/spark-doris-connector-spark-3.2/src/main/scala/org/apache/doris/spark/catalog/DorisTable.scala	13
spark-doris-connector/spark-doris-connector-spark-3.2/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalog.scala	9
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala	9
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/read/expression/V2ExpressionBuilder.scala	79
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/read/DorisScanV2.scala	14
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/read/DorisScanBuilder.scala	26
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/catalog/DorisTable.scala	13
spark-doris-connector/spark-doris-connector-spark-3.4/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalog.scala	9
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/sql/sources/DorisSourceProvider.scala	8
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/write/DorisDataWriter.scala	85
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/write/DorisWriteBuilder.scala	24
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/write/DorisDataWriterFactory.scala	14
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/write/DorisWrite.scala	52
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/ScanMode.java	4
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/DorisScanBuilderBase.scala	29
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/DorisScan.scala	13
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/AbstractDorisScan.scala	30
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/DorisPartitionReaderFactory.scala	10
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/read/DorisPartitionReader.scala	48
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableProviderBase.scala	33
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala	44
spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalogBase.scala	68
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala	101
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowWriter.scala	296
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/Utils.scala	133
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/DorisRowFlightSqlReader.scala	22
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/ScalaDorisRowRDD.scala	28
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/sources/DorisSourceRegisterTrait.scala	5
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/sources/DorisRelation.scala	58
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/DorisRowThriftReader.scala	22
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/sql/DorisRow.scala	22
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/Retry.scala	26
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/URLs.scala	37
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/IPUtils.java	126
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/RowConvertors.scala	110
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/SchemaConvertors.scala	52
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/HttpUtils.scala	49
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/DorisDialects.scala	61
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/exception/OptionRequiredException.scala	2
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/testcase/TestStreamLoadForArrowType.scala	228
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/rdd/AbstractDorisRDDIterator.scala	56
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/rdd/DorisSpark.scala	16
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/rdd/DorisRDD.scala	29
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/rdd/AbstractDorisRDD.scala	32
spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/package.scala	15
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/config/DorisOptions.java	53
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/config/DorisConfig.java	157
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/config/ConfigOptions.java	41
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/config/ConfigOption.java	28
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/HttpPutBuilder.java	54
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/ErrorMessages.java	9
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/ResponseUtil.java	13
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/CopySQLBuilder.java	55
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/EscapeHandler.java	20
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/util/HttpPostBuilder.java	41
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisBackendThriftClient.java	192
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/AbstractStreamLoadProcessor.java	433
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/AbstractCopyIntoProcessor.java	226
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/DorisWriter.java	26
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/DorisCommitter.java	6
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/CopyIntoProcessor.java	31
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/write/StreamLoadProcessor.java	94
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java	349
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisBackendHttpClient.java	42
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/entity/DorisReaderPartition.java	93
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/entity/StreamLoadResponse.java	78
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/entity/Backend.java	49
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/entity/CopyIntoResponse.java	20
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/entity/Frontend.java	38
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/RowBatch.java	547
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/ReaderPartitionGenerator.java	127
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/AbstractThriftReader.java	253
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/DorisFlightSqlReader.java	154
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/DorisThriftReader.java	15
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/DorisReader.java	16
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/ShouldNeverHappenException.java	2
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/DorisException.java	20
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/CopyIntoException.java	20
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/StreamLoadException.java	20
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/ConnectedFailedException.java	9
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/DorisInternalException.java	8
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/DorisRuntimeException.java	22
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/exception/IllegalArgumentException.java	9
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/RespContent.java	72
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Field.java	86
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/DataModel.java	7
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Schema.java	79
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Tablet.java	61
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/DataFormat.java	6
spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java	45
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala	9
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/read/expression/V2ExpressionBuilder.scala	79
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/read/DorisScanV2.scala	14
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/read/DorisScanBuilder.scala	26
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/catalog/DorisTable.scala	13
spark-doris-connector/spark-doris-connector-spark-3.5/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalog.scala	9
spark-doris-connector/spark-doris-connector-spark-3.1/src/main/scala/org/apache/doris/spark/sql/sources/DorisDataSource.scala	9
spark-doris-connector/spark-doris-connector-spark-3.1/src/main/scala/org/apache/doris/spark/read/DorisScanBuilder.scala	17
spark-doris-connector/spark-doris-connector-spark-3.1/src/main/scala/org/apache/doris/spark/catalog/DorisTable.scala	13
spark-doris-connector/spark-doris-connector-spark-3.1/src/main/scala/org/apache/doris/spark/catalog/DorisTableCatalog.scala	9
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala	67
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala	24
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/txn/TransactionHandler.scala	49
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/txn/listener/DorisTxnStreamingQueryListener.scala	40
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/txn/listener/DorisTransactionListener.scala	40
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/load/CommitMessage.scala	2
spark-doris-connector/spark-doris-connector-spark-2/src/main/scala/org/apache/doris/spark/writer/DorisWriter.scala	165