Path Lines of Code spark/src/main/java/org/apache/comet/CometBatchIterator.java 33 spark/src/main/java/org/apache/parquet/filter2/predicate/SparkFilterApi.java 23 spark/src/main/java/org/apache/spark/CometTaskMemoryManager.java 34 spark/src/main/java/org/apache/spark/shuffle/comet/CometBoundedShuffleMemoryAllocator.java 121 spark/src/main/java/org/apache/spark/shuffle/comet/CometShuffleChecksumSupport.java 24 spark/src/main/java/org/apache/spark/shuffle/comet/CometShuffleMemoryAllocator.java 19 spark/src/main/java/org/apache/spark/shuffle/comet/CometShuffleMemoryAllocatorTrait.java 15 spark/src/main/java/org/apache/spark/shuffle/comet/CometUnifiedShuffleMemoryAllocator.java 35 spark/src/main/java/org/apache/spark/shuffle/comet/TooLargePageException.java 6 spark/src/main/java/org/apache/spark/shuffle/sort/CometShuffleExternalSorter.java 410 spark/src/main/java/org/apache/spark/sql/comet/CometScalarSubquery.java 62 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/CometBypassMergeSortShuffleWriter.java 276 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/CometDiskBlockWriter.java 304 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/CometUnsafeShuffleWriter.java 425 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/ExposedByteArrayOutputStream.java 10 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/ShuffleThreadPool.java 37 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/SpillInfo.java 13 spark/src/main/java/org/apache/spark/sql/comet/execution/shuffle/SpillWriter.java 149 spark/src/main/scala/org/apache/comet/CometExecIterator.scala 142 spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala 250 spark/src/main/scala/org/apache/comet/DataTypeSupport.scala 62 spark/src/main/scala/org/apache/comet/ExtendedExplainInfo.scala 126 spark/src/main/scala/org/apache/comet/GenerateDocs.scala 80 spark/src/main/scala/org/apache/comet/MetricsSupport.scala 31 spark/src/main/scala/org/apache/comet/Native.scala 49 spark/src/main/scala/org/apache/comet/expressions/CometCast.scala 229 spark/src/main/scala/org/apache/comet/expressions/CometEvalMode.scala 10 spark/src/main/scala/org/apache/comet/expressions/RegExp.scala 6 spark/src/main/scala/org/apache/comet/parquet/CometParquetFileFormat.scala 223 spark/src/main/scala/org/apache/comet/parquet/CometParquetPartitionReaderFactory.scala 178 spark/src/main/scala/org/apache/comet/parquet/CometParquetScan.scala 57 spark/src/main/scala/org/apache/comet/parquet/ParquetFilters.scala 834 spark/src/main/scala/org/apache/comet/parquet/SourceFilterSerde.scala 135 spark/src/main/scala/org/apache/comet/rules/CometExecRule.scala 536 spark/src/main/scala/org/apache/comet/rules/CometScanRule.scala 141 spark/src/main/scala/org/apache/comet/rules/EliminateRedundantTransitions.scala 53 spark/src/main/scala/org/apache/comet/rules/RewriteJoin.scala 69 spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala 2504 spark/src/main/scala/org/apache/comet/serde/aggregates.scala 644 spark/src/main/scala/org/apache/comet/serde/arrays.scala 264 spark/src/main/scala/org/apache/comet/serde/hash.scala 57 spark/src/main/scala/org/apache/comet/testing/ParquetGenerator.scala 194 spark/src/main/scala/org/apache/spark/Plugins.scala 68 spark/src/main/scala/org/apache/spark/shuffle/sort/RowPartition.scala 29 spark/src/main/scala/org/apache/spark/sql/comet/CometBatchScanExec.scala 95 spark/src/main/scala/org/apache/spark/sql/comet/CometBroadcastExchangeExec.scala 208 spark/src/main/scala/org/apache/spark/sql/comet/CometCoalesceExec.scala 38 spark/src/main/scala/org/apache/spark/sql/comet/CometCollectLimitExec.scala 75 spark/src/main/scala/org/apache/spark/sql/comet/CometColumnarToRowExec.scala 233 spark/src/main/scala/org/apache/spark/sql/comet/CometExecRDD.scala 29 spark/src/main/scala/org/apache/spark/sql/comet/CometExecUtils.scala 105 spark/src/main/scala/org/apache/spark/sql/comet/CometMetricNode.scala 100 spark/src/main/scala/org/apache/spark/sql/comet/CometNativeScanExec.scala 199 spark/src/main/scala/org/apache/spark/sql/comet/CometPlan.scala 3 spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala 425 spark/src/main/scala/org/apache/spark/sql/comet/CometScanUtils.scala 7 spark/src/main/scala/org/apache/spark/sql/comet/CometSparkToColumnarExec.scala 108 spark/src/main/scala/org/apache/spark/sql/comet/CometTakeOrderedAndProjectExec.scala 96 spark/src/main/scala/org/apache/spark/sql/comet/CometWindowExec.scala 41 spark/src/main/scala/org/apache/spark/sql/comet/DataSourceHelpers.scala 10 spark/src/main/scala/org/apache/spark/sql/comet/DecimalPrecision.scala 68 spark/src/main/scala/org/apache/spark/sql/comet/ZippedPartitionsRDD.scala 33 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometBlockStoreShuffleReader.scala 119 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometNativeShuffleWriter.scala 160 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleDependency.scala 36 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala 296 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleManager.scala 231 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffledRowRDD.scala 109 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/NativeBatchDecoderIterator.scala 131 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/ShuffleUtils.scala 30 spark/src/main/scala/org/apache/spark/sql/comet/operators.scala 746 spark/src/main/scala/org/apache/spark/sql/comet/plans/AliasAwareOutputExpression.scala 48 spark/src/main/spark-3.4/org/apache/comet/shims/CometExprShim.scala 17 spark/src/main/spark-3.4/org/apache/comet/shims/ShimSQLConf.scala 6 spark/src/main/spark-3.4/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala 44 spark/src/main/spark-3.5/org/apache/comet/shims/CometExprShim.scala 17 spark/src/main/spark-3.5/org/apache/comet/shims/ShimSQLConf.scala 6 spark/src/main/spark-3.5/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala 101 spark/src/main/spark-3.x/org/apache/comet/shims/ShimCometShuffleExchangeExec.scala 24 spark/src/main/spark-3.x/org/apache/comet/shims/ShimCometSparkSessionExtensions.scala 16 spark/src/main/spark-3.x/org/apache/spark/comet/shims/ShimCometDriverPlugin.scala 8 spark/src/main/spark-3.x/org/apache/spark/sql/ExtendedExplainGenerator.scala 6 spark/src/main/spark-3.x/org/apache/spark/sql/comet/shims/ShimCometShuffleWriteProcessor.scala 22 spark/src/main/spark-4.0/org/apache/comet/shims/CometExprShim.scala 17 spark/src/main/spark-4.0/org/apache/comet/shims/ShimCometShuffleExchangeExec.scala 20 spark/src/main/spark-4.0/org/apache/comet/shims/ShimCometSparkSessionExtensions.scala 10 spark/src/main/spark-4.0/org/apache/comet/shims/ShimSQLConf.scala 6 spark/src/main/spark-4.0/org/apache/spark/comet/shims/ShimCometDriverPlugin.scala 7 spark/src/main/spark-4.0/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala 55 spark/src/main/spark-4.0/org/apache/spark/sql/comet/shims/ShimCometShuffleWriteProcessor.scala 4