Path Lines of Code cpp-ch/local-engine/AggregateFunctions/AggregateFunctionDVRoaringBitmap.cpp 26 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionDVRoaringBitmap.h 81 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionGroupBloomFilter.cpp 69 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionGroupBloomFilter.h 133 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionPartialMerge.cpp 84 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionPartialMerge.h 69 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionSparkAvg.cpp 139 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionUniqHyperLogLogPlusPlus.cpp 24 cpp-ch/local-engine/AggregateFunctions/AggregateFunctionUniqHyperLogLogPlusPlus.h 2937 cpp-ch/local-engine/AggregateFunctions/GroupLimitFunctions.cpp 237 cpp-ch/local-engine/Builder/SerializedPlanBuilder.cpp 330 cpp-ch/local-engine/Builder/SerializedPlanBuilder.h 72 cpp-ch/local-engine/Common/AggregateUtil.cpp 259 cpp-ch/local-engine/Common/AggregateUtil.h 55 cpp-ch/local-engine/Common/ArrayJoinHelper.cpp 127 cpp-ch/local-engine/Common/ArrayJoinHelper.h 16 cpp-ch/local-engine/Common/Base85Codec.cpp 101 cpp-ch/local-engine/Common/Base85Codec.h 29 cpp-ch/local-engine/Common/BlockIterator.cpp 39 cpp-ch/local-engine/Common/BlockIterator.h 18 cpp-ch/local-engine/Common/BlockTypeUtils.cpp 37 cpp-ch/local-engine/Common/BlockTypeUtils.h 165 cpp-ch/local-engine/Common/CHUtil.cpp 883 cpp-ch/local-engine/Common/CHUtil.h 172 cpp-ch/local-engine/Common/ChunkBuffer.cpp 32 cpp-ch/local-engine/Common/ChunkBuffer.h 14 cpp-ch/local-engine/Common/ConcurrentMap.h 49 cpp-ch/local-engine/Common/DebugUtils.cpp 347 cpp-ch/local-engine/Common/DebugUtils.h 28 cpp-ch/local-engine/Common/ExceptionUtils.cpp 10 cpp-ch/local-engine/Common/ExceptionUtils.h 11 cpp-ch/local-engine/Common/FileCacheConcurrentMap.h 53 cpp-ch/local-engine/Common/GlutenConfig.cpp 128 cpp-ch/local-engine/Common/GlutenConfig.h 142 cpp-ch/local-engine/Common/GlutenDecimalUtils.h 61 cpp-ch/local-engine/Common/GlutenSettings.cpp 37 cpp-ch/local-engine/Common/GlutenSettings.h 52 cpp-ch/local-engine/Common/GlutenSignalHandler.cpp 342 cpp-ch/local-engine/Common/GlutenSignalHandler.h 20 cpp-ch/local-engine/Common/GlutenStringUtils.cpp 8 cpp-ch/local-engine/Common/GlutenStringUtils.h 47 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/PlanUtil.cpp 95 cpp-ch/local-engine/Common/PlanUtil.h 26 cpp-ch/local-engine/Common/QueryContext.cpp 160 cpp-ch/local-engine/Common/QueryContext.h 38 cpp-ch/local-engine/Disks/ObjectStorages/CompactObjectStorageDiskTransaction.cpp 106 cpp-ch/local-engine/Disks/ObjectStorages/CompactObjectStorageDiskTransaction.h 148 cpp-ch/local-engine/Disks/ObjectStorages/GlutenDiskHDFS.cpp 70 cpp-ch/local-engine/Disks/ObjectStorages/GlutenDiskHDFS.h 73 cpp-ch/local-engine/Disks/ObjectStorages/GlutenDiskS3.cpp 38 cpp-ch/local-engine/Disks/ObjectStorages/GlutenDiskS3.h 28 cpp-ch/local-engine/Disks/ObjectStorages/GlutenHDFSObjectStorage.cpp 31 cpp-ch/local-engine/Disks/ObjectStorages/GlutenHDFSObjectStorage.h 28 cpp-ch/local-engine/Disks/ObjectStorages/MetadataStorageFromRocksDB.cpp 263 cpp-ch/local-engine/Disks/ObjectStorages/MetadataStorageFromRocksDB.h 76 cpp-ch/local-engine/Disks/ObjectStorages/MetadataStorageFromRocksDBTransactionOperations.cpp 147 cpp-ch/local-engine/Disks/ObjectStorages/MetadataStorageFromRocksDBTransactionOperations.h 91 cpp-ch/local-engine/Disks/ObjectStorages/registerGlutenDiskObjectStorage.cpp 86 cpp-ch/local-engine/Disks/registerGlutenDisks.cpp 112 cpp-ch/local-engine/Disks/registerGlutenDisks.h 5 cpp-ch/local-engine/Functions/FunctionGetDateData.h 144 cpp-ch/local-engine/Functions/FunctionsBloomFilter.cpp 9 cpp-ch/local-engine/Functions/FunctionsBloomFilter.h 177 cpp-ch/local-engine/Functions/SparkArrayFlatten.cpp 85 cpp-ch/local-engine/Functions/SparkCastComplexTypesToString.cpp 8 cpp-ch/local-engine/Functions/SparkCastComplexTypesToString.h 370 cpp-ch/local-engine/Functions/SparkFunctionArrayDistinct.cpp 244 cpp-ch/local-engine/Functions/SparkFunctionArrayJoin.cpp 129 cpp-ch/local-engine/Functions/SparkFunctionArraySort.cpp 277 cpp-ch/local-engine/Functions/SparkFunctionArraysOverlap.cpp 112 cpp-ch/local-engine/Functions/SparkFunctionBin.cpp 94 cpp-ch/local-engine/Functions/SparkFunctionBinaryArithmetic.cpp 165 cpp-ch/local-engine/Functions/SparkFunctionCastFloatToInt.cpp 24 cpp-ch/local-engine/Functions/SparkFunctionCastFloatToInt.h 144 cpp-ch/local-engine/Functions/SparkFunctionCastFloatToString.cpp 89 cpp-ch/local-engine/Functions/SparkFunctionCheckDecimalOverflow.cpp 282 cpp-ch/local-engine/Functions/SparkFunctionCheckDecimalOverflow.h 60 cpp-ch/local-engine/Functions/SparkFunctionConv.cpp 175 cpp-ch/local-engine/Functions/SparkFunctionConv.h 33 cpp-ch/local-engine/Functions/SparkFunctionDateToUnixTimestamp.cpp 8 cpp-ch/local-engine/Functions/SparkFunctionDateToUnixTimestamp.h 61 cpp-ch/local-engine/Functions/SparkFunctionDecimalBinaryArithmetic.h 603 cpp-ch/local-engine/Functions/SparkFunctionDecimalBinaryOperator.h 288 cpp-ch/local-engine/Functions/SparkFunctionDecimalDivide.cpp 20 cpp-ch/local-engine/Functions/SparkFunctionDecimalMinus.cpp 20 cpp-ch/local-engine/Functions/SparkFunctionDecimalModulo.cpp 20 cpp-ch/local-engine/Functions/SparkFunctionDecimalMultiply.cpp 20 cpp-ch/local-engine/Functions/SparkFunctionDecimalPlus.cpp 19 cpp-ch/local-engine/Functions/SparkFunctionDivide.cpp 8 cpp-ch/local-engine/Functions/SparkFunctionDivide.h 180 cpp-ch/local-engine/Functions/SparkFunctionExtractYear.cpp 24 cpp-ch/local-engine/Functions/SparkFunctionFloor.cpp 8 cpp-ch/local-engine/Functions/SparkFunctionFloor.h 226 cpp-ch/local-engine/Functions/SparkFunctionGetJsonObject.cpp 114 cpp-ch/local-engine/Functions/SparkFunctionGetJsonObject.h 692 cpp-ch/local-engine/Functions/SparkFunctionHashingExtended.cpp 10 cpp-ch/local-engine/Functions/SparkFunctionHashingExtended.h 517 cpp-ch/local-engine/Functions/SparkFunctionMakeDecimal.cpp 190 cpp-ch/local-engine/Functions/SparkFunctionMonotonicallyIncreasingID.cpp 64 cpp-ch/local-engine/Functions/SparkFunctionMonthsBetween.cpp 118 cpp-ch/local-engine/Functions/SparkFunctionMonthsBetween.h 27 cpp-ch/local-engine/Functions/SparkFunctionNextDay.cpp 259 cpp-ch/local-engine/Functions/SparkFunctionNextDay.h 35 cpp-ch/local-engine/Functions/SparkFunctionPositionUTF8.cpp 222 cpp-ch/local-engine/Functions/SparkFunctionRegexpExtractAll.cpp 309 cpp-ch/local-engine/Functions/SparkFunctionReinterpretAsString.cpp 71 cpp-ch/local-engine/Functions/SparkFunctionRint.cpp 40 cpp-ch/local-engine/Functions/SparkFunctionRint.h 31 cpp-ch/local-engine/Functions/SparkFunctionRoundHalfUp.cpp 17 cpp-ch/local-engine/Functions/SparkFunctionRoundHalfUp.h 299 cpp-ch/local-engine/Functions/SparkFunctionSortArray.cpp 51 cpp-ch/local-engine/Functions/SparkFunctionSortArray.h 52 cpp-ch/local-engine/Functions/SparkFunctionSplitByRegexp.cpp 175 cpp-ch/local-engine/Functions/SparkFunctionStrToMap.cpp 336 cpp-ch/local-engine/Functions/SparkFunctionToDate.cpp 28 cpp-ch/local-engine/Functions/SparkFunctionToDateTime.cpp 8 cpp-ch/local-engine/Functions/SparkFunctionToDateTime.h 165 cpp-ch/local-engine/Functions/SparkFunctionTrim.cpp 178 cpp-ch/local-engine/Functions/SparkFunctionTupleElement.cpp 186 cpp-ch/local-engine/Functions/SparkFunctionUnscaleValue.cpp 100 cpp-ch/local-engine/Functions/SparkParseURL.cpp 445 cpp-ch/local-engine/Functions/SparkPartitionEscape.cpp 80 cpp-ch/local-engine/Functions/SparkPartitionEscape.h 36 cpp-ch/local-engine/IO/SplittableBzip2ReadBuffer.cpp 880 cpp-ch/local-engine/IO/SplittableBzip2ReadBuffer.h 229 cpp-ch/local-engine/Join/BroadCastJoinBuilder.cpp 163 cpp-ch/local-engine/Join/BroadCastJoinBuilder.h 30 cpp-ch/local-engine/Join/StorageJoinFromReadBuffer.cpp 134 cpp-ch/local-engine/Join/StorageJoinFromReadBuffer.h 53 cpp-ch/local-engine/Operator/AdvancedExpandStep.cpp 216 cpp-ch/local-engine/Operator/AdvancedExpandStep.h 61 cpp-ch/local-engine/Operator/BlocksBufferPoolTransform.cpp 91 cpp-ch/local-engine/Operator/BlocksBufferPoolTransform.h 34 cpp-ch/local-engine/Operator/BranchStep.cpp 226 cpp-ch/local-engine/Operator/BranchStep.h 53 cpp-ch/local-engine/Operator/BranchTransform.cpp 125 cpp-ch/local-engine/Operator/BranchTransform.h 28 cpp-ch/local-engine/Operator/DefaultHashAggregateResult.cpp 145 cpp-ch/local-engine/Operator/DefaultHashAggregateResult.h 18 cpp-ch/local-engine/Operator/EarlyStopStep.cpp 71 cpp-ch/local-engine/Operator/EarlyStopStep.h 32 cpp-ch/local-engine/Operator/EmptyProjectStep.cpp 104 cpp-ch/local-engine/Operator/EmptyProjectStep.h 19 cpp-ch/local-engine/Operator/ExpandStep.cpp 62 cpp-ch/local-engine/Operator/ExpandStep.h 21 cpp-ch/local-engine/Operator/ExpandTransform.cpp 98 cpp-ch/local-engine/Operator/ExpandTransform.h 25 cpp-ch/local-engine/Operator/GraceAggregatingStep.cpp 73 cpp-ch/local-engine/Operator/GraceAggregatingStep.h 26 cpp-ch/local-engine/Operator/GraceAggregatingTransform.cpp 558 cpp-ch/local-engine/Operator/GraceAggregatingTransform.h 90 cpp-ch/local-engine/Operator/GraceMergingAggregatedStep.cpp 75 cpp-ch/local-engine/Operator/GraceMergingAggregatedStep.h 30 cpp-ch/local-engine/Operator/PartitionColumnFillingTransform.cpp 112 cpp-ch/local-engine/Operator/PartitionColumnFillingTransform.h 19 cpp-ch/local-engine/Operator/ReplicateRowsStep.cpp 72 cpp-ch/local-engine/Operator/ReplicateRowsStep.h 23 cpp-ch/local-engine/Operator/StreamingAggregatingStep.cpp 279 cpp-ch/local-engine/Operator/StreamingAggregatingStep.h 69 cpp-ch/local-engine/Operator/WindowGroupLimitStep.cpp 289 cpp-ch/local-engine/Operator/WindowGroupLimitStep.h 28 cpp-ch/local-engine/Parser/AdvancedParametersParseUtil.cpp 138 cpp-ch/local-engine/Parser/AdvancedParametersParseUtil.h 34 cpp-ch/local-engine/Parser/AggregateFunctionParser.cpp 201 cpp-ch/local-engine/Parser/AggregateFunctionParser.h 123 cpp-ch/local-engine/Parser/CHColumnToSparkRow.cpp 829 cpp-ch/local-engine/Parser/CHColumnToSparkRow.h 123 cpp-ch/local-engine/Parser/ExpandField.h 35 cpp-ch/local-engine/Parser/ExpressionParser.cpp 846 cpp-ch/local-engine/Parser/ExpressionParser.h 51 cpp-ch/local-engine/Parser/FunctionExecutor.cpp 88 cpp-ch/local-engine/Parser/FunctionExecutor.h 56 cpp-ch/local-engine/Parser/FunctionParser.cpp 156 cpp-ch/local-engine/Parser/FunctionParser.h 83 cpp-ch/local-engine/Parser/LocalExecutor.cpp 151 cpp-ch/local-engine/Parser/LocalExecutor.h 56 cpp-ch/local-engine/Parser/ParserContext.cpp 93 cpp-ch/local-engine/Parser/ParserContext.h 38 cpp-ch/local-engine/Parser/RelMetric.cpp 184 cpp-ch/local-engine/Parser/RelMetric.h 36 cpp-ch/local-engine/Parser/RelParsers/AggregateRelParser.cpp 437 cpp-ch/local-engine/Parser/RelParsers/AggregateRelParser.h 48 cpp-ch/local-engine/Parser/RelParsers/CrossRelParser.cpp 264 cpp-ch/local-engine/Parser/RelParsers/CrossRelParser.h 39 cpp-ch/local-engine/Parser/RelParsers/ExpandRelParser.cpp 177 cpp-ch/local-engine/Parser/RelParsers/ExpandRelParser.h 25 cpp-ch/local-engine/Parser/RelParsers/FetchRelParser.cpp 28 cpp-ch/local-engine/Parser/RelParsers/FilterRelParser.cpp 57 cpp-ch/local-engine/Parser/RelParsers/FilterRelParser.h 18 cpp-ch/local-engine/Parser/RelParsers/GroupLimitRelParser.cpp 420 cpp-ch/local-engine/Parser/RelParsers/GroupLimitRelParser.h 54 cpp-ch/local-engine/Parser/RelParsers/JoinRelParser.cpp 686 cpp-ch/local-engine/Parser/RelParsers/JoinRelParser.h 62 cpp-ch/local-engine/Parser/RelParsers/MergeTreeRelParser.cpp 451 cpp-ch/local-engine/Parser/RelParsers/MergeTreeRelParser.h 89 cpp-ch/local-engine/Parser/RelParsers/ProjectRelParser.cpp 127 cpp-ch/local-engine/Parser/RelParsers/ProjectRelParser.h 29 cpp-ch/local-engine/Parser/RelParsers/ReadRelParser.cpp 202 cpp-ch/local-engine/Parser/RelParsers/ReadRelParser.h 38 cpp-ch/local-engine/Parser/RelParsers/RelParser.cpp 144 cpp-ch/local-engine/Parser/RelParsers/RelParser.h 62 cpp-ch/local-engine/Parser/RelParsers/SortParsingUtils.cpp 82 cpp-ch/local-engine/Parser/RelParsers/SortParsingUtils.h 13 cpp-ch/local-engine/Parser/RelParsers/SortRelParser.cpp 54 cpp-ch/local-engine/Parser/RelParsers/SortRelParser.h 20 cpp-ch/local-engine/Parser/RelParsers/StreamKafkaRelParser.cpp 65 cpp-ch/local-engine/Parser/RelParsers/StreamKafkaRelParser.h 32 cpp-ch/local-engine/Parser/RelParsers/WindowRelParser.cpp 286 cpp-ch/local-engine/Parser/RelParsers/WindowRelParser.h 63 cpp-ch/local-engine/Parser/RelParsers/WriteRelParser.cpp 203 cpp-ch/local-engine/Parser/RelParsers/WriteRelParser.h 28 cpp-ch/local-engine/Parser/SerializedPlanParser.cpp 360 cpp-ch/local-engine/Parser/SerializedPlanParser.h 87 cpp-ch/local-engine/Parser/SparkRowToCHColumn.cpp 355 cpp-ch/local-engine/Parser/SparkRowToCHColumn.h 308 cpp-ch/local-engine/Parser/SubstraitParserUtils.cpp 23 cpp-ch/local-engine/Parser/SubstraitParserUtils.h 57 cpp-ch/local-engine/Parser/TypeParser.cpp 296 cpp-ch/local-engine/Parser/TypeParser.h 28 cpp-ch/local-engine/Parser/aggregate_function_parser/ApproxCountDistinctFunctionParser.cpp 107 cpp-ch/local-engine/Parser/aggregate_function_parser/ApproxPercentileParser.cpp 20 cpp-ch/local-engine/Parser/aggregate_function_parser/BloomFilterAggParser.cpp 53 cpp-ch/local-engine/Parser/aggregate_function_parser/BloomFilterAggParser.h 17 cpp-ch/local-engine/Parser/aggregate_function_parser/CollectListParser.cpp 6 cpp-ch/local-engine/Parser/aggregate_function_parser/CollectListParser.h 70 cpp-ch/local-engine/Parser/aggregate_function_parser/CommonAggregateFunctionParser.cpp 28 cpp-ch/local-engine/Parser/aggregate_function_parser/CommonAggregateFunctionParser.h 18 cpp-ch/local-engine/Parser/aggregate_function_parser/CountParser.cpp 65 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/aggregate_function_parser/NtileParser.cpp 24 cpp-ch/local-engine/Parser/aggregate_function_parser/NtileParser.h 17 cpp-ch/local-engine/Parser/aggregate_function_parser/PercentileParser.cpp 20 cpp-ch/local-engine/Parser/aggregate_function_parser/PercentileParserBase.cpp 119 cpp-ch/local-engine/Parser/aggregate_function_parser/PercentileParserBase.h 27 cpp-ch/local-engine/Parser/aggregate_function_parser/SimpleStatisticsFunctions.cpp 47 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 33 cpp-ch/local-engine/Parser/scalar_function_parser/CommonScalarFunctionParser.cpp 149 cpp-ch/local-engine/Parser/scalar_function_parser/alias.cpp 33 cpp-ch/local-engine/Parser/scalar_function_parser/arithmetic.cpp 302 cpp-ch/local-engine/Parser/scalar_function_parser/arrayContains.cpp 67 cpp-ch/local-engine/Parser/scalar_function_parser/arrayDistinct.cpp 31 cpp-ch/local-engine/Parser/scalar_function_parser/arrayExcept.cpp 76 cpp-ch/local-engine/Parser/scalar_function_parser/arrayHighOrderFunctions.cpp 183 cpp-ch/local-engine/Parser/scalar_function_parser/arrayIntersect.cpp 31 cpp-ch/local-engine/Parser/scalar_function_parser/arrayMaxAndMin.cpp 64 cpp-ch/local-engine/Parser/scalar_function_parser/arrayPosition.cpp 58 cpp-ch/local-engine/Parser/scalar_function_parser/arrayRemove.cpp 69 cpp-ch/local-engine/Parser/scalar_function_parser/arrayRepeat.cpp 66 cpp-ch/local-engine/Parser/scalar_function_parser/arrayUnion.cpp 34 cpp-ch/local-engine/Parser/scalar_function_parser/bitLength.cpp 41 cpp-ch/local-engine/Parser/scalar_function_parser/checkOverflow.cpp 47 cpp-ch/local-engine/Parser/scalar_function_parser/chr.cpp 44 cpp-ch/local-engine/Parser/scalar_function_parser/compareSubstrings.cpp 37 cpp-ch/local-engine/Parser/scalar_function_parser/concat.cpp 37 cpp-ch/local-engine/Parser/scalar_function_parser/concatWs.cpp 63 cpp-ch/local-engine/Parser/scalar_function_parser/cot.cpp 34 cpp-ch/local-engine/Parser/scalar_function_parser/csc.cpp 34 cpp-ch/local-engine/Parser/scalar_function_parser/dateFormat.cpp 30 cpp-ch/local-engine/Parser/scalar_function_parser/decode.cpp 35 cpp-ch/local-engine/Parser/scalar_function_parser/elementAt.cpp 62 cpp-ch/local-engine/Parser/scalar_function_parser/elt.cpp 53 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/equalNullSafe.cpp 41 cpp-ch/local-engine/Parser/scalar_function_parser/expm1.cpp 34 cpp-ch/local-engine/Parser/scalar_function_parser/extract.cpp 90 cpp-ch/local-engine/Parser/scalar_function_parser/factorial.cpp 41 cpp-ch/local-engine/Parser/scalar_function_parser/findInset.cpp 52 cpp-ch/local-engine/Parser/scalar_function_parser/fromJson.cpp 29 cpp-ch/local-engine/Parser/scalar_function_parser/fromUtcTimestamp.cpp 14 cpp-ch/local-engine/Parser/scalar_function_parser/getArrayItem.cpp 42 cpp-ch/local-engine/Parser/scalar_function_parser/getJSONObject.cpp 69 cpp-ch/local-engine/Parser/scalar_function_parser/getTimestamp.cpp 5 cpp-ch/local-engine/Parser/scalar_function_parser/getTimestamp.h 75 cpp-ch/local-engine/Parser/scalar_function_parser/isNaN.cpp 40 cpp-ch/local-engine/Parser/scalar_function_parser/lambdaFunction.cpp 161 cpp-ch/local-engine/Parser/scalar_function_parser/lambdaFunction.h 7 cpp-ch/local-engine/Parser/scalar_function_parser/length.cpp 47 cpp-ch/local-engine/Parser/scalar_function_parser/ln.cpp 18 cpp-ch/local-engine/Parser/scalar_function_parser/locate.cpp 40 cpp-ch/local-engine/Parser/scalar_function_parser/log.cpp 48 cpp-ch/local-engine/Parser/scalar_function_parser/log10.cpp 19 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/makeDecimal.cpp 46 cpp-ch/local-engine/Parser/scalar_function_parser/mapHighOrderFunctions.cpp 65 cpp-ch/local-engine/Parser/scalar_function_parser/md5.cpp 32 cpp-ch/local-engine/Parser/scalar_function_parser/monotonicallyIncreasingId.cpp 29 cpp-ch/local-engine/Parser/scalar_function_parser/nanvl.cpp 44 cpp-ch/local-engine/Parser/scalar_function_parser/octetLength.cpp 38 cpp-ch/local-engine/Parser/scalar_function_parser/parseUrl.cpp 101 cpp-ch/local-engine/Parser/scalar_function_parser/parseUrl.h 25 cpp-ch/local-engine/Parser/scalar_function_parser/regexp_extract.cpp 123 cpp-ch/local-engine/Parser/scalar_function_parser/repeat.cpp 31 cpp-ch/local-engine/Parser/scalar_function_parser/reverse.cpp 26 cpp-ch/local-engine/Parser/scalar_function_parser/sec.cpp 34 cpp-ch/local-engine/Parser/scalar_function_parser/sequence.cpp 66 cpp-ch/local-engine/Parser/scalar_function_parser/sha1.cpp 32 cpp-ch/local-engine/Parser/scalar_function_parser/sha2.cpp 57 cpp-ch/local-engine/Parser/scalar_function_parser/shift.cpp 70 cpp-ch/local-engine/Parser/scalar_function_parser/shiftRightUnsigned.cpp 52 cpp-ch/local-engine/Parser/scalar_function_parser/size.cpp 44 cpp-ch/local-engine/Parser/scalar_function_parser/slice.cpp 82 cpp-ch/local-engine/Parser/scalar_function_parser/sortArray.cpp 35 cpp-ch/local-engine/Parser/scalar_function_parser/space.cpp 27 cpp-ch/local-engine/Parser/scalar_function_parser/split.cpp 26 cpp-ch/local-engine/Parser/scalar_function_parser/substring.cpp 47 cpp-ch/local-engine/Parser/scalar_function_parser/timestampAdd.cpp 75 cpp-ch/local-engine/Parser/scalar_function_parser/timestampSeconds.cpp 32 cpp-ch/local-engine/Parser/scalar_function_parser/toUtcTimestamp.cpp 14 cpp-ch/local-engine/Parser/scalar_function_parser/trimFunctions.cpp 88 cpp-ch/local-engine/Parser/scalar_function_parser/trunc.cpp 52 cpp-ch/local-engine/Parser/scalar_function_parser/tuple.cpp 28 cpp-ch/local-engine/Parser/scalar_function_parser/tupleElement.cpp 41 cpp-ch/local-engine/Parser/scalar_function_parser/unixTimestamp.cpp 59 cpp-ch/local-engine/Parser/scalar_function_parser/utcTimestampTransform.h 37 cpp-ch/local-engine/Rewriter/ExpressionRewriter.h 231 cpp-ch/local-engine/Rewriter/RelRewriter.h 23 cpp-ch/local-engine/Shuffle/NativeSplitter.cpp 211 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 447 cpp-ch/local-engine/Shuffle/PartitionWriter.h 188 cpp-ch/local-engine/Shuffle/SelectorBuilder.cpp 394 cpp-ch/local-engine/Shuffle/SelectorBuilder.h 97 cpp-ch/local-engine/Shuffle/ShuffleCommon.cpp 90 cpp-ch/local-engine/Shuffle/ShuffleCommon.h 92 cpp-ch/local-engine/Shuffle/ShuffleReader.cpp 82 cpp-ch/local-engine/Shuffle/ShuffleReader.h 60 cpp-ch/local-engine/Shuffle/ShuffleWriter.cpp 51 cpp-ch/local-engine/Shuffle/ShuffleWriter.h 20 cpp-ch/local-engine/Shuffle/SparkExchangeSink.cpp 333 cpp-ch/local-engine/Shuffle/SparkExchangeSink.h 89 cpp-ch/local-engine/Shuffle/WriteBufferFromJavaOutputStream.cpp 44 cpp-ch/local-engine/Shuffle/WriteBufferFromJavaOutputStream.h 24 cpp-ch/local-engine/Storages/Cache/CacheManager.cpp 221 cpp-ch/local-engine/Storages/Cache/CacheManager.h 30 cpp-ch/local-engine/Storages/Cache/JobScheduler.cpp 133 cpp-ch/local-engine/Storages/Cache/JobScheduler.h 95 cpp-ch/local-engine/Storages/IO/AggregateSerializationUtils.cpp 116 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 244 cpp-ch/local-engine/Storages/IO/NativeReader.h 57 cpp-ch/local-engine/Storages/IO/NativeWriter.cpp 77 cpp-ch/local-engine/Storages/IO/NativeWriter.h 26 cpp-ch/local-engine/Storages/Kafka/GlutenKafkaSource.cpp 254 cpp-ch/local-engine/Storages/Kafka/GlutenKafkaSource.h 75 cpp-ch/local-engine/Storages/Kafka/GlutenKafkaUtils.cpp 207 cpp-ch/local-engine/Storages/Kafka/GlutenKafkaUtils.h 42 cpp-ch/local-engine/Storages/Kafka/ReadFromGlutenStorageKafka.cpp 61 cpp-ch/local-engine/Storages/Kafka/ReadFromGlutenStorageKafka.h 38 cpp-ch/local-engine/Storages/MergeTree/MergeSparkMergeTreeTask.cpp 149 cpp-ch/local-engine/Storages/MergeTree/MergeSparkMergeTreeTask.h 79 cpp-ch/local-engine/Storages/MergeTree/MetaDataHelper.cpp 228 cpp-ch/local-engine/Storages/MergeTree/MetaDataHelper.h 16 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.cpp 277 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.h 63 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeSink.cpp 313 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeSink.h 270 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeWriteSettings.cpp 21 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeWriteSettings.h 26 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeWriter.cpp 134 cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeWriter.h 53 cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.cpp 433 cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h 118 cpp-ch/local-engine/Storages/MergeTree/StorageMergeTreeFactory.cpp 95 cpp-ch/local-engine/Storages/MergeTree/StorageMergeTreeFactory.h 81 cpp-ch/local-engine/Storages/NativeOutputWriter.h 17 cpp-ch/local-engine/Storages/Output/BlockStripeSplitter.cpp 62 cpp-ch/local-engine/Storages/Output/BlockStripeSplitter.h 17 cpp-ch/local-engine/Storages/Output/NormalFileWriter.cpp 179 cpp-ch/local-engine/Storages/Output/NormalFileWriter.h 459 cpp-ch/local-engine/Storages/Output/ORCOutputFormatFile.cpp 35 cpp-ch/local-engine/Storages/Output/ORCOutputFormatFile.h 18 cpp-ch/local-engine/Storages/Output/OutputFormatFile.cpp 60 cpp-ch/local-engine/Storages/Output/OutputFormatFile.h 56 cpp-ch/local-engine/Storages/Output/ParquetOutputFormatFile.cpp 31 cpp-ch/local-engine/Storages/Output/ParquetOutputFormatFile.h 19 cpp-ch/local-engine/Storages/Output/WriteBufferBuilder.cpp 92 cpp-ch/local-engine/Storages/Output/WriteBufferBuilder.h 31 cpp-ch/local-engine/Storages/Parquet/ArrowUtils.cpp 20 cpp-ch/local-engine/Storages/Parquet/ArrowUtils.h 43 cpp-ch/local-engine/Storages/Parquet/ColumnIndexFilter.cpp 864 cpp-ch/local-engine/Storages/Parquet/ColumnIndexFilter.h 128 cpp-ch/local-engine/Storages/Parquet/ParquetConverter.h 297 cpp-ch/local-engine/Storages/Parquet/ParquetMeta.cpp 194 cpp-ch/local-engine/Storages/Parquet/ParquetMeta.h 131 cpp-ch/local-engine/Storages/Parquet/RowRanges.h 167 cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.cpp 379 cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.h 172 cpp-ch/local-engine/Storages/Parquet/VirtualColumnRowIndexReader.h 106 cpp-ch/local-engine/Storages/Serializations/ExcelBoolReader.cpp 152 cpp-ch/local-engine/Storages/Serializations/ExcelBoolReader.h 11 cpp-ch/local-engine/Storages/Serializations/ExcelDecimalReader.h 50 cpp-ch/local-engine/Storages/Serializations/ExcelDecimalSerialization.cpp 26 cpp-ch/local-engine/Storages/Serializations/ExcelDecimalSerialization.h 77 cpp-ch/local-engine/Storages/Serializations/ExcelNumberReader.h 417 cpp-ch/local-engine/Storages/Serializations/ExcelReadHelpers.cpp 228 cpp-ch/local-engine/Storages/Serializations/ExcelReadHelpers.h 132 cpp-ch/local-engine/Storages/Serializations/ExcelSerialization.cpp 124 cpp-ch/local-engine/Storages/Serializations/ExcelSerialization.h 88 cpp-ch/local-engine/Storages/Serializations/ExcelStringReader.cpp 211 cpp-ch/local-engine/Storages/Serializations/ExcelStringReader.h 34 cpp-ch/local-engine/Storages/SourceFromJavaIter.cpp 132 cpp-ch/local-engine/Storages/SourceFromJavaIter.h 27 cpp-ch/local-engine/Storages/SourceFromRange.cpp 96 cpp-ch/local-engine/Storages/SourceFromRange.h 38 cpp-ch/local-engine/Storages/SubstraitSource/Delta/Bitmap/DeltaDVRoaringBitmapArray.cpp 169 cpp-ch/local-engine/Storages/SubstraitSource/Delta/Bitmap/DeltaDVRoaringBitmapArray.h 36 cpp-ch/local-engine/Storages/SubstraitSource/Delta/DeltaParquetMeta.h 25 cpp-ch/local-engine/Storages/SubstraitSource/Delta/DeltaReader.cpp 111 cpp-ch/local-engine/Storages/SubstraitSource/Delta/DeltaReader.h 41 cpp-ch/local-engine/Storages/SubstraitSource/Delta/DeltaWriter.cpp 206 cpp-ch/local-engine/Storages/SubstraitSource/Delta/DeltaWriter.h 42 cpp-ch/local-engine/Storages/SubstraitSource/ExcelTextFormatFile.cpp 319 cpp-ch/local-engine/Storages/SubstraitSource/ExcelTextFormatFile.h 70 cpp-ch/local-engine/Storages/SubstraitSource/FileReader.cpp 280 cpp-ch/local-engine/Storages/SubstraitSource/FileReader.h 74 cpp-ch/local-engine/Storages/SubstraitSource/FormatFile.cpp 124 cpp-ch/local-engine/Storages/SubstraitSource/FormatFile.h 109 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/EqualityDeleteFileReader.cpp 144 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/EqualityDeleteFileReader.h 48 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/IcebergMetadataColumn.h 36 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/IcebergReader.cpp 186 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/IcebergReader.h 36 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/PositionalDeleteFileReader.cpp 64 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/PositionalDeleteFileReader.h 17 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/SimpleParquetReader.cpp 64 cpp-ch/local-engine/Storages/SubstraitSource/Iceberg/SimpleParquetReader.h 39 cpp-ch/local-engine/Storages/SubstraitSource/JSONFormatFile.cpp 24 cpp-ch/local-engine/Storages/SubstraitSource/JSONFormatFile.h 14 cpp-ch/local-engine/Storages/SubstraitSource/ORCFormatFile.cpp 105 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 199 cpp-ch/local-engine/Storages/SubstraitSource/ParquetFormatFile.h 31 cpp-ch/local-engine/Storages/SubstraitSource/ReadBufferBuilder.cpp 772 cpp-ch/local-engine/Storages/SubstraitSource/ReadBufferBuilder.h 57 cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp 86 cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h 32 cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSourceStep.cpp 46 cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSourceStep.h 19 cpp-ch/local-engine/Storages/SubstraitSource/TextFormatFile.cpp 50 cpp-ch/local-engine/Storages/SubstraitSource/TextFormatFile.h 25 cpp-ch/local-engine/Storages/SubstraitSource/substrait_fwd.h 9 cpp-ch/local-engine/jni/CelebornClient.h 42 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 191 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 1213 cpp-ch/local-engine/proto/config.proto 8 cpp-ch/local-engine/proto/substrait/algebra.proto 1290 cpp-ch/local-engine/proto/substrait/capabilities.proto 23 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 204 cpp-ch/local-engine/proto/substrait/type_expressions.proto 134 cpp-ch/local-engine/proto/write_optimization.proto 36 cpp-ch/local-engine/tool/parquet_to_mergetree.py 81