Path Lines of Code common/src/main/java/org/apache/arrow/c/CometBufferImportTypeVisitor.java 316 common/src/main/java/org/apache/comet/parquet/BatchReader.java 445 common/src/main/java/org/apache/comet/parquet/MetadataColumnReader.java 56 common/src/main/java/org/apache/comet/parquet/Native.java 76 common/src/main/java/org/apache/comet/parquet/NativeBatchReader.java 419 common/src/main/java/org/apache/comet/parquet/NativeColumnReader.java 89 common/src/main/java/org/apache/comet/parquet/ReadOptions.java 137 common/src/main/java/org/apache/comet/parquet/TypeUtil.java 293 common/src/main/java/org/apache/comet/parquet/Utils.java 187 common/src/main/scala/org/apache/spark/sql/comet/execution/arrow/CometArrowConverters.scala 139 native/core/src/common/bit.rs 1249 native/core/src/execution/operators/copy.rs 226 native/core/src/execution/operators/scan.rs 382 native/core/src/execution/planner.rs 2783 native/core/src/execution/shuffle/list.rs 291 native/core/src/execution/shuffle/map.rs 2574 native/core/src/execution/shuffle/row.rs 3089 native/core/src/execution/sort.rs 154 native/core/src/parquet/mod.rs 687 native/core/src/parquet/mutable_vector.rs 151 native/core/src/parquet/parquet_support.rs 281 native/core/src/parquet/read/column.rs 806 native/core/src/parquet/read/levels.rs 170 native/core/src/parquet/read/values.rs 888 native/core/src/parquet/schema_adapter.rs 200 native/core/src/parquet/util/bit_packing.rs 3070 native/core/src/parquet/util/jni.rs 212 native/core/src/parquet/util/memory.rs 393 native/spark-expr/src/conversion_funcs/cast.rs 2312 native/spark-expr/src/json_funcs/to_json.rs 303 spark/src/main/java/org/apache/parquet/filter2/predicate/SparkFilterApi.java 23 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/SpillWriter.java 149 spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala 250 spark/src/main/scala/org/apache/comet/expressions/CometCast.scala 229 spark/src/main/scala/org/apache/comet/parquet/CometParquetPartitionReaderFactory.scala 178 spark/src/main/scala/org/apache/comet/parquet/ParquetFilters.scala 834 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/spark/sql/comet/CometBatchScanExec.scala 95 spark/src/main/scala/org/apache/spark/sql/comet/CometCollectLimitExec.scala 75 spark/src/main/scala/org/apache/spark/sql/comet/CometMetricNode.scala 100 spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala 425 spark/src/main/scala/org/apache/spark/sql/comet/CometTakeOrderedAndProjectExec.scala 96 spark/src/main/scala/org/apache/spark/sql/comet/DecimalPrecision.scala 68 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/CometShuffleExchangeExec.scala 296 spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffledRowRDD.scala 109 spark/src/main/scala/org/apache/spark/sql/comet/operators.scala 746 spark/src/main/spark-3.4/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala 44 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