Path	Lines of Code
cpp-ch/local-engine/AggregateFunctions/AggregateFunctionGroupBloomFilter.cpp	69
cpp-ch/local-engine/AggregateFunctions/AggregateFunctionGroupBloomFilter.h	131
cpp-ch/local-engine/AggregateFunctions/AggregateFunctionPartialMerge.cpp	86
cpp-ch/local-engine/AggregateFunctions/AggregateFunctionPartialMerge.h	70
cpp-ch/local-engine/Builder/SerializedPlanBuilder.cpp	335
cpp-ch/local-engine/Builder/SerializedPlanBuilder.h	72
cpp-ch/local-engine/Common/AggregateUtil.cpp	139
cpp-ch/local-engine/Common/AggregateUtil.h	31
cpp-ch/local-engine/Common/BlockIterator.cpp	39
cpp-ch/local-engine/Common/BlockIterator.h	18
cpp-ch/local-engine/Common/CHUtil.cpp	694
cpp-ch/local-engine/Common/CHUtil.h	152
cpp-ch/local-engine/Common/ChunkBuffer.cpp	31
cpp-ch/local-engine/Common/ChunkBuffer.h	14
cpp-ch/local-engine/Common/ConcurrentMap.h	44
cpp-ch/local-engine/Common/DebugUtils.cpp	52
cpp-ch/local-engine/Common/DebugUtils.h	7
cpp-ch/local-engine/Common/ExceptionUtils.cpp	10
cpp-ch/local-engine/Common/ExceptionUtils.h	11
cpp-ch/local-engine/Common/FileCacheConcurrentMap.h	76
cpp-ch/local-engine/Common/GlutenSignalHandler.cpp	338
cpp-ch/local-engine/Common/GlutenSignalHandler.h	20
cpp-ch/local-engine/Common/JNIUtils.cpp	29
cpp-ch/local-engine/Common/JNIUtils.h	20
cpp-ch/local-engine/Common/LoggerExtend.cpp	32
cpp-ch/local-engine/Common/LoggerExtend.h	11
cpp-ch/local-engine/Common/MergeTreeTool.cpp	109
cpp-ch/local-engine/Common/MergeTreeTool.h	44
cpp-ch/local-engine/Common/QueryContext.cpp	71
cpp-ch/local-engine/Common/QueryContext.h	22
cpp-ch/local-engine/Common/StringUtils.cpp	25
cpp-ch/local-engine/Common/StringUtils.h	14
cpp-ch/local-engine/Common/common.cpp	15
cpp-ch/local-engine/Functions/FunctionsBloomFilter.cpp	9
cpp-ch/local-engine/Functions/FunctionsBloomFilter.h	179
cpp-ch/local-engine/Functions/SparkFunctionArrayDistinct.cpp	241
cpp-ch/local-engine/Functions/SparkFunctionArraySort.cpp	51
cpp-ch/local-engine/Functions/SparkFunctionArraySort.h	52
cpp-ch/local-engine/Functions/SparkFunctionCastFloatToInt.cpp	45
cpp-ch/local-engine/Functions/SparkFunctionCastFloatToInt.h	85
cpp-ch/local-engine/Functions/SparkFunctionCheckDecimalOverflow.cpp	158
cpp-ch/local-engine/Functions/SparkFunctionCheckDecimalOverflow.h	59
cpp-ch/local-engine/Functions/SparkFunctionConv.cpp	175
cpp-ch/local-engine/Functions/SparkFunctionConv.h	33
cpp-ch/local-engine/Functions/SparkFunctionFloor.cpp	8
cpp-ch/local-engine/Functions/SparkFunctionFloor.h	191
cpp-ch/local-engine/Functions/SparkFunctionGetJsonObject.cpp	13
cpp-ch/local-engine/Functions/SparkFunctionGetJsonObject.h	322
cpp-ch/local-engine/Functions/SparkFunctionHashingExtended.cpp	10
cpp-ch/local-engine/Functions/SparkFunctionHashingExtended.h	517
cpp-ch/local-engine/Functions/SparkFunctionMakeDecimal.cpp	187
cpp-ch/local-engine/Functions/SparkFunctionMonthsBetween.cpp	118
cpp-ch/local-engine/Functions/SparkFunctionMonthsBetween.h	27
cpp-ch/local-engine/Functions/SparkFunctionNextDay.cpp	263
cpp-ch/local-engine/Functions/SparkFunctionNextDay.h	35
cpp-ch/local-engine/Functions/SparkFunctionPositionUTF8.cpp	221
cpp-ch/local-engine/Functions/SparkFunctionRegexpExtractAll.cpp	309
cpp-ch/local-engine/Functions/SparkFunctionReinterpretAsString.cpp	71
cpp-ch/local-engine/Functions/SparkFunctionRoundHalfUp.cpp	16
cpp-ch/local-engine/Functions/SparkFunctionRoundHalfUp.h	205
cpp-ch/local-engine/Functions/SparkFunctionStrToMap.cpp	134
cpp-ch/local-engine/Functions/SparkFunctionToDate.cpp	136
cpp-ch/local-engine/Functions/SparkFunctionTrim.cpp	142
cpp-ch/local-engine/Functions/SparkFunctionTupleElement.cpp	185
cpp-ch/local-engine/Functions/SparkFunctionUnixTimestamp.cpp	8
cpp-ch/local-engine/Functions/SparkFunctionUnixTimestamp.h	61
cpp-ch/local-engine/Functions/SparkFunctionUnscaleValue.cpp	99
cpp-ch/local-engine/Functions/SparkParseURL.cpp	555
cpp-ch/local-engine/Join/BroadCastJoinBuilder.cpp	92
cpp-ch/local-engine/Join/BroadCastJoinBuilder.h	26
cpp-ch/local-engine/Join/StorageJoinFromReadBuffer.cpp	81
cpp-ch/local-engine/Join/StorageJoinFromReadBuffer.h	34
cpp-ch/local-engine/Operator/BlockCoalesceOperator.cpp	31
cpp-ch/local-engine/Operator/BlockCoalesceOperator.h	23
cpp-ch/local-engine/Operator/BlocksBufferPoolTransform.cpp	92
cpp-ch/local-engine/Operator/BlocksBufferPoolTransform.h	35
cpp-ch/local-engine/Operator/DefaultHashAggregateResult.cpp	152
cpp-ch/local-engine/Operator/DefaultHashAggregateResult.h	18
cpp-ch/local-engine/Operator/EmptyProjectStep.cpp	104
cpp-ch/local-engine/Operator/EmptyProjectStep.h	18
cpp-ch/local-engine/Operator/ExpandStep.cpp	69
cpp-ch/local-engine/Operator/ExpandStep.h	23
cpp-ch/local-engine/Operator/ExpandTransform.cpp	113
cpp-ch/local-engine/Operator/ExpandTransorm.h	27
cpp-ch/local-engine/Operator/GraceMergingAggregatedStep.cpp	497
cpp-ch/local-engine/Operator/GraceMergingAggregatedStep.h	93
cpp-ch/local-engine/Operator/PartitionColumnFillingTransform.cpp	112
cpp-ch/local-engine/Operator/PartitionColumnFillingTransform.h	19
cpp-ch/local-engine/Operator/StreamingAggregatingStep.cpp	270
cpp-ch/local-engine/Operator/StreamingAggregatingStep.h	75
cpp-ch/local-engine/Parser/AggregateFunctionParser.cpp	156
cpp-ch/local-engine/Parser/AggregateFunctionParser.h	137
cpp-ch/local-engine/Parser/AggregateRelParser.cpp	341
cpp-ch/local-engine/Parser/AggregateRelParser.h	44
cpp-ch/local-engine/Parser/CHColumnToSparkRow.cpp	829
cpp-ch/local-engine/Parser/CHColumnToSparkRow.h	114
cpp-ch/local-engine/Parser/ExpandField.h	35
cpp-ch/local-engine/Parser/ExpandRelParser.cpp	112
cpp-ch/local-engine/Parser/ExpandRelParser.h	15
cpp-ch/local-engine/Parser/FilterRelParser.cpp	52
cpp-ch/local-engine/Parser/FilterRelParser.h	17
cpp-ch/local-engine/Parser/FunctionExecutor.cpp	91
cpp-ch/local-engine/Parser/FunctionExecutor.h	55
cpp-ch/local-engine/Parser/FunctionParser.cpp	90
cpp-ch/local-engine/Parser/FunctionParser.h	86
cpp-ch/local-engine/Parser/JoinRelParser.cpp	351
cpp-ch/local-engine/Parser/JoinRelParser.h	36
cpp-ch/local-engine/Parser/MergeTreeRelParser.cpp	302
cpp-ch/local-engine/Parser/MergeTreeRelParser.h	69
cpp-ch/local-engine/Parser/ProjectRelParser.cpp	152
cpp-ch/local-engine/Parser/ProjectRelParser.h	36
cpp-ch/local-engine/Parser/RelMetric.cpp	126
cpp-ch/local-engine/Parser/RelMetric.h	36
cpp-ch/local-engine/Parser/RelParser.cpp	126
cpp-ch/local-engine/Parser/RelParser.h	75
cpp-ch/local-engine/Parser/SerializedPlanParser.cpp	1971
cpp-ch/local-engine/Parser/SerializedPlanParser.h	368
cpp-ch/local-engine/Parser/SortRelParser.cpp	83
cpp-ch/local-engine/Parser/SortRelParser.h	21
cpp-ch/local-engine/Parser/SparkRowToCHColumn.cpp	356
cpp-ch/local-engine/Parser/SparkRowToCHColumn.h	310
cpp-ch/local-engine/Parser/TypeParser.cpp	273
cpp-ch/local-engine/Parser/TypeParser.h	29
cpp-ch/local-engine/Parser/WindowRelParser.cpp	328
cpp-ch/local-engine/Parser/WindowRelParser.h	64
cpp-ch/local-engine/Parser/aggregate_function_parser/BloomFilterAggParser.cpp	54
cpp-ch/local-engine/Parser/aggregate_function_parser/BloomFilterAggParser.h	17
cpp-ch/local-engine/Parser/aggregate_function_parser/CollectListParser.cpp	8
cpp-ch/local-engine/Parser/aggregate_function_parser/CollectListParser.h	70
cpp-ch/local-engine/Parser/aggregate_function_parser/CommonAggregateFunctionParser.cpp	30
cpp-ch/local-engine/Parser/aggregate_function_parser/CommonAggregateFunctionParser.h	18
cpp-ch/local-engine/Parser/aggregate_function_parser/CountParser.cpp	64
cpp-ch/local-engine/Parser/aggregate_function_parser/CountParser.h	17
cpp-ch/local-engine/Parser/aggregate_function_parser/LeadLagParser.cpp	89
cpp-ch/local-engine/Parser/aggregate_function_parser/LeadLagParser.h	29
cpp-ch/local-engine/Parser/example_udf/customSum.cpp	8
cpp-ch/local-engine/Parser/example_udf/myAdd.cpp	14
cpp-ch/local-engine/Parser/example_udf/myMd5.cpp	32
cpp-ch/local-engine/Parser/scalar_function_parser/CommonScalarFunctionParser.cpp	29
cpp-ch/local-engine/Parser/scalar_function_parser/GetJSONObjectParser.cpp	70
cpp-ch/local-engine/Parser/scalar_function_parser/arrayContains.cpp	68
cpp-ch/local-engine/Parser/scalar_function_parser/arrayDistinct.cpp	32
cpp-ch/local-engine/Parser/scalar_function_parser/arrayElement.h	47
cpp-ch/local-engine/Parser/scalar_function_parser/arrayIntersect.cpp	32
cpp-ch/local-engine/Parser/scalar_function_parser/arrayMaxAndMin.cpp	51
cpp-ch/local-engine/Parser/scalar_function_parser/arrayPosition.cpp	57
cpp-ch/local-engine/Parser/scalar_function_parser/arrayUnion.cpp	35
cpp-ch/local-engine/Parser/scalar_function_parser/concatWs.cpp	62
cpp-ch/local-engine/Parser/scalar_function_parser/decode.cpp	35
cpp-ch/local-engine/Parser/scalar_function_parser/divide.cpp	43
cpp-ch/local-engine/Parser/scalar_function_parser/elementAt.cpp	25
cpp-ch/local-engine/Parser/scalar_function_parser/elt.cpp	52
cpp-ch/local-engine/Parser/scalar_function_parser/empty2null.cpp	35
cpp-ch/local-engine/Parser/scalar_function_parser/encode.cpp	35
cpp-ch/local-engine/Parser/scalar_function_parser/findInset.cpp	51
cpp-ch/local-engine/Parser/scalar_function_parser/getArrayItem.cpp	13
cpp-ch/local-engine/Parser/scalar_function_parser/ln.cpp	18
cpp-ch/local-engine/Parser/scalar_function_parser/log10.cpp	18
cpp-ch/local-engine/Parser/scalar_function_parser/log1p.cpp	18
cpp-ch/local-engine/Parser/scalar_function_parser/log2.cpp	18
cpp-ch/local-engine/Parser/scalar_function_parser/logarithm.h	42
cpp-ch/local-engine/Parser/scalar_function_parser/mapFromArraysUnaligned.cpp	59
cpp-ch/local-engine/Parser/scalar_function_parser/parseUrl.cpp	102
cpp-ch/local-engine/Parser/scalar_function_parser/parseUrl.h	26
cpp-ch/local-engine/Parser/scalar_function_parser/sequence.cpp	67
cpp-ch/local-engine/Parser/scalar_function_parser/shiftRightUnsigned.cpp	48
cpp-ch/local-engine/Parser/scalar_function_parser/slice.cpp	76
cpp-ch/local-engine/Parser/scalar_function_parser/sortArray.cpp	37
cpp-ch/local-engine/Parser/scalar_function_parser/substring.cpp	51
cpp-ch/local-engine/Parser/scalar_function_parser/trunc.cpp	52
cpp-ch/local-engine/Parser/scalar_function_parser/unixTimestamp.cpp	45
cpp-ch/local-engine/Rewriter/ExpressionRewriter.h	225
cpp-ch/local-engine/Rewriter/RelRewriter.h	26
cpp-ch/local-engine/Shuffle/CachedShuffleWriter.cpp	120
cpp-ch/local-engine/Shuffle/CachedShuffleWriter.h	34
cpp-ch/local-engine/Shuffle/NativeSplitter.cpp	217
cpp-ch/local-engine/Shuffle/NativeSplitter.h	84
cpp-ch/local-engine/Shuffle/NativeWriterInMemory.cpp	23
cpp-ch/local-engine/Shuffle/NativeWriterInMemory.h	16
cpp-ch/local-engine/Shuffle/PartitionWriter.cpp	344
cpp-ch/local-engine/Shuffle/PartitionWriter.h	89
cpp-ch/local-engine/Shuffle/SelectorBuilder.cpp	372
cpp-ch/local-engine/Shuffle/SelectorBuilder.h	93
cpp-ch/local-engine/Shuffle/ShuffleReader.cpp	82
cpp-ch/local-engine/Shuffle/ShuffleReader.h	53
cpp-ch/local-engine/Shuffle/ShuffleSplitter.cpp	368
cpp-ch/local-engine/Shuffle/ShuffleSplitter.h	159
cpp-ch/local-engine/Shuffle/ShuffleWriter.cpp	57
cpp-ch/local-engine/Shuffle/ShuffleWriter.h	20
cpp-ch/local-engine/Shuffle/ShuffleWriterBase.h	14
cpp-ch/local-engine/Shuffle/WriteBufferFromJavaOutputStream.cpp	44
cpp-ch/local-engine/Shuffle/WriteBufferFromJavaOutputStream.h	24
cpp-ch/local-engine/Storages/ArrowParquetBlockInputFormat.cpp	84
cpp-ch/local-engine/Storages/ArrowParquetBlockInputFormat.h	31
cpp-ch/local-engine/Storages/CustomMergeTreeSink.cpp	13
cpp-ch/local-engine/Storages/CustomMergeTreeSink.h	22
cpp-ch/local-engine/Storages/CustomStorageMergeTree.cpp	194
cpp-ch/local-engine/Storages/CustomStorageMergeTree.h	56
cpp-ch/local-engine/Storages/IO/AggregateSerializationUtils.cpp	111
cpp-ch/local-engine/Storages/IO/AggregateSerializationUtils.h	11
cpp-ch/local-engine/Storages/IO/CompressedWriteBuffer.cpp	60
cpp-ch/local-engine/Storages/IO/CompressedWriteBuffer.h	50
cpp-ch/local-engine/Storages/IO/NativeReader.cpp	193
cpp-ch/local-engine/Storages/IO/NativeReader.h	44
cpp-ch/local-engine/Storages/IO/NativeWriter.cpp	74
cpp-ch/local-engine/Storages/IO/NativeWriter.h	26
cpp-ch/local-engine/Storages/Mergetree/SparkMergeTreeWriter.cpp	198
cpp-ch/local-engine/Storages/Mergetree/SparkMergeTreeWriter.h	76
cpp-ch/local-engine/Storages/Output/BlockStripeSplitter.cpp	62
cpp-ch/local-engine/Storages/Output/BlockStripeSplitter.h	17
cpp-ch/local-engine/Storages/Output/FileWriterWrappers.cpp	39
cpp-ch/local-engine/Storages/Output/FileWriterWrappers.h	43
cpp-ch/local-engine/Storages/Output/ORCOutputFormatFile.cpp	26
cpp-ch/local-engine/Storages/Output/ORCOutputFormatFile.h	21
cpp-ch/local-engine/Storages/Output/OutputFormatFile.cpp	61
cpp-ch/local-engine/Storages/Output/OutputFormatFile.h	47
cpp-ch/local-engine/Storages/Output/ParquetOutputFormatFile.cpp	33
cpp-ch/local-engine/Storages/Output/ParquetOutputFormatFile.h	21
cpp-ch/local-engine/Storages/Output/WriteBufferBuilder.cpp	90
cpp-ch/local-engine/Storages/Output/WriteBufferBuilder.h	31
cpp-ch/local-engine/Storages/Serializations/ExcelBoolReader.cpp	152
cpp-ch/local-engine/Storages/Serializations/ExcelBoolReader.h	9
cpp-ch/local-engine/Storages/Serializations/ExcelDecimalReader.h	49
cpp-ch/local-engine/Storages/Serializations/ExcelDecimalSerialization.cpp	25
cpp-ch/local-engine/Storages/Serializations/ExcelDecimalSerialization.h	72
cpp-ch/local-engine/Storages/Serializations/ExcelNumberReader.h	416
cpp-ch/local-engine/Storages/Serializations/ExcelReadHelpers.cpp	211
cpp-ch/local-engine/Storages/Serializations/ExcelReadHelpers.h	133
cpp-ch/local-engine/Storages/Serializations/ExcelSerialization.cpp	123
cpp-ch/local-engine/Storages/Serializations/ExcelSerialization.h	88
cpp-ch/local-engine/Storages/Serializations/ExcelStringReader.cpp	210
cpp-ch/local-engine/Storages/Serializations/ExcelStringReader.h	35
cpp-ch/local-engine/Storages/SourceFromJavaIter.cpp	155
cpp-ch/local-engine/Storages/SourceFromJavaIter.h	27
cpp-ch/local-engine/Storages/StorageMergeTreeFactory.cpp	107
cpp-ch/local-engine/Storages/StorageMergeTreeFactory.h	33
cpp-ch/local-engine/Storages/SubstraitSource/ExcelTextFormatFile.cpp	319
cpp-ch/local-engine/Storages/SubstraitSource/ExcelTextFormatFile.h	58
cpp-ch/local-engine/Storages/SubstraitSource/FormatFile.cpp	82
cpp-ch/local-engine/Storages/SubstraitSource/FormatFile.h	60
cpp-ch/local-engine/Storages/SubstraitSource/JSONFormatFile.cpp	23
cpp-ch/local-engine/Storages/SubstraitSource/JSONFormatFile.h	14
cpp-ch/local-engine/Storages/SubstraitSource/ORCFormatFile.cpp	104
cpp-ch/local-engine/Storages/SubstraitSource/ORCFormatFile.h	37
cpp-ch/local-engine/Storages/SubstraitSource/OrcUtil.cpp	140
cpp-ch/local-engine/Storages/SubstraitSource/OrcUtil.h	36
cpp-ch/local-engine/Storages/SubstraitSource/ParquetFormatFile.cpp	148
cpp-ch/local-engine/Storages/SubstraitSource/ParquetFormatFile.h	43
cpp-ch/local-engine/Storages/SubstraitSource/ReadBufferBuilder.cpp	596
cpp-ch/local-engine/Storages/SubstraitSource/ReadBufferBuilder.h	45
cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp	326
cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h	85
cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSourceStep.cpp	43
cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSourceStep.h	20
cpp-ch/local-engine/Storages/SubstraitSource/TextFormatFile.cpp	47
cpp-ch/local-engine/Storages/SubstraitSource/TextFormatFile.h	22
cpp-ch/local-engine/Storages/ch_parquet/OptimizedArrowColumnToCHColumn.cpp	590
cpp-ch/local-engine/Storages/ch_parquet/OptimizedArrowColumnToCHColumn.h	33
cpp-ch/local-engine/Storages/ch_parquet/OptimizedParquetBlockInputFormat.cpp	150
cpp-ch/local-engine/Storages/ch_parquet/OptimizedParquetBlockInputFormat.h	50
cpp-ch/local-engine/Storages/ch_parquet/arrow/column_reader.cc	1672
cpp-ch/local-engine/Storages/ch_parquet/arrow/column_reader.h	212
cpp-ch/local-engine/Storages/ch_parquet/arrow/encoding.cc	2718
cpp-ch/local-engine/Storages/ch_parquet/arrow/encoding.h	274
cpp-ch/local-engine/Storages/ch_parquet/arrow/reader.cc	1121
cpp-ch/local-engine/Storages/ch_parquet/arrow/reader.h	146
cpp-ch/local-engine/Storages/ch_parquet/arrow/reader_internal.cc	712
cpp-ch/local-engine/Storages/ch_parquet/arrow/reader_internal.h	81
cpp-ch/local-engine/jni/CelebornClient.h	42
cpp-ch/local-engine/jni/ReservationListenerWrapper.cpp	37
cpp-ch/local-engine/jni/ReservationListenerWrapper.h	23
cpp-ch/local-engine/jni/SharedPointerWrapper.h	34
cpp-ch/local-engine/jni/jni_common.cpp	73
cpp-ch/local-engine/jni/jni_common.h	87
cpp-ch/local-engine/jni/jni_error.cpp	74
cpp-ch/local-engine/jni/jni_error.h	61
cpp-ch/local-engine/local_engine_jni.cpp	1135
cpp-ch/local-engine/proto/substrait/algebra.proto	1175
cpp-ch/local-engine/proto/substrait/capabilities.proto	23
cpp-ch/local-engine/proto/substrait/ddl.proto	19
cpp-ch/local-engine/proto/substrait/extended_expression.proto	41
cpp-ch/local-engine/proto/substrait/extensions/extensions.proto	64
cpp-ch/local-engine/proto/substrait/function.proto	115
cpp-ch/local-engine/proto/substrait/parameterized_types.proto	106
cpp-ch/local-engine/proto/substrait/plan.proto	68
cpp-ch/local-engine/proto/substrait/type.proto	202
cpp-ch/local-engine/proto/substrait/type_expressions.proto	134
cpp-ch/local-engine/tool/parquet_to_mergetree.py	81