Path Lines of Code native/Cargo.toml 54 native/core/Cargo.toml 111 native/core/benches/bit_util.rs 162 native/core/benches/bloom_filter_agg.rs 129 native/core/benches/common.rs 60 native/core/benches/filter.rs 81 native/core/benches/parquet_decode.rs 35 native/core/benches/parquet_read.rs 125 native/core/benches/perf.rs 34 native/core/benches/row_columnar.rs 80 native/core/benches/shuffle_writer.rs 128 native/core/src/common/bit.rs 1249 native/core/src/common/buffer.rs 254 native/core/src/common/mod.rs 4 native/core/src/errors.rs 663 native/core/src/execution/expressions/bloom_filter_agg.rs 133 native/core/src/execution/expressions/bloom_filter_might_contain.rs 109 native/core/src/execution/expressions/mod.rs 4 native/core/src/execution/expressions/subquery.rs 162 native/core/src/execution/jni_api.rs 543 native/core/src/execution/memory_pools/config.rs 79 native/core/src/execution/memory_pools/fair_pool.rs 27 native/core/src/execution/memory_pools/mod.rs 89 native/core/src/execution/memory_pools/task_shared.rs 31 native/core/src/execution/memory_pools/unified_pool.rs 22 native/core/src/execution/metrics/mod.rs 1 native/core/src/execution/metrics/utils.rs 55 native/core/src/execution/mod.rs 21 native/core/src/execution/operators/copy.rs 226 native/core/src/execution/operators/expand.rs 150 native/core/src/execution/operators/filter.rs 470 native/core/src/execution/operators/mod.rs 29 native/core/src/execution/operators/scan.rs 382 native/core/src/execution/planner.rs 2783 native/core/src/execution/serde.rs 157 native/core/src/execution/shuffle/codec.rs 186 native/core/src/execution/shuffle/list.rs 291 native/core/src/execution/shuffle/map.rs 2574 native/core/src/execution/shuffle/mod.rs 7 native/core/src/execution/shuffle/row.rs 3089 native/core/src/execution/shuffle/shuffle_writer.rs 1053 native/core/src/execution/sort.rs 154 native/core/src/execution/spark_plan.rs 63 native/core/src/execution/util/mod.rs 2 native/core/src/execution/util/spark_bit_array.rs 163 native/core/src/execution/util/spark_bloom_filter.rs 126 native/core/src/execution/utils.rs 80 native/core/src/jvm_bridge/batch_iterator.rs 18 native/core/src/jvm_bridge/comet_exec.rs 34 native/core/src/jvm_bridge/comet_metric_node.rs 19 native/core/src/jvm_bridge/comet_task_memory_manager.rs 18 native/core/src/jvm_bridge/mod.rs 290 native/core/src/lib.rs 73 native/core/src/parquet/data_type.rs 2 native/core/src/parquet/mod.rs 687 native/core/src/parquet/mutable_vector.rs 151 native/core/src/parquet/parquet_exec.rs 107 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/mod.rs 52 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/buffer.rs 88 native/core/src/parquet/util/jni.rs 212 native/core/src/parquet/util/memory.rs 393 native/core/src/parquet/util/mod.rs 6 native/hdfs/Cargo.toml 47 native/hdfs/src/lib.rs 1 native/hdfs/src/object_store/hdfs.rs 536 native/hdfs/src/object_store/mod.rs 1 native/proto/Cargo.toml 30 native/proto/build.rs 18 native/proto/src/lib.rs 17 native/proto/src/proto/expr.proto 410 native/proto/src/proto/metric.proto 23 native/proto/src/proto/operator.proto 198 native/proto/src/proto/partitioning.proto 33 native/rustfmt.toml 18 native/spark-expr/Cargo.toml 63 native/spark-expr/benches/aggregate.rs 164 native/spark-expr/benches/cast_from_string.rs 52 native/spark-expr/benches/cast_numeric.rs 46 native/spark-expr/benches/conditional.rs 108 native/spark-expr/benches/decimal_div.rs 41 native/spark-expr/src/agg_funcs/avg.rs 257 native/spark-expr/src/agg_funcs/avg_decimal.rs 409 native/spark-expr/src/agg_funcs/correlation.rs 195 native/spark-expr/src/agg_funcs/covariance.rs 257 native/spark-expr/src/agg_funcs/mod.rs 14 native/spark-expr/src/agg_funcs/stddev.rs 131 native/spark-expr/src/agg_funcs/sum_decimal.rs 429 native/spark-expr/src/agg_funcs/variance.rs 188 native/spark-expr/src/array_funcs/array_insert.rs 252 native/spark-expr/src/array_funcs/array_repeat.rs 147 native/spark-expr/src/array_funcs/get_array_struct_fields.rs 133 native/spark-expr/src/array_funcs/list_extract.rs 262 native/spark-expr/src/array_funcs/mod.rs 8 native/spark-expr/src/bitwise_funcs/bitwise_not.rs 90 native/spark-expr/src/bitwise_funcs/mod.rs 2 native/spark-expr/src/comet_scalar_funcs.rs 142 native/spark-expr/src/conditional_funcs/if_expr.rs 116 native/spark-expr/src/conditional_funcs/mod.rs 2 native/spark-expr/src/conversion_funcs/cast.rs 2312 native/spark-expr/src/conversion_funcs/mod.rs 1 native/spark-expr/src/datetime_funcs/date_arithmetic.rs 79 native/spark-expr/src/datetime_funcs/date_trunc.rs 86 native/spark-expr/src/datetime_funcs/hour.rs 96 native/spark-expr/src/datetime_funcs/minute.rs 96 native/spark-expr/src/datetime_funcs/mod.rs 12 native/spark-expr/src/datetime_funcs/second.rs 96 native/spark-expr/src/datetime_funcs/timestamp_trunc.rs 119 native/spark-expr/src/error.rs 45 native/spark-expr/src/hash_funcs/mod.rs 7 native/spark-expr/src/hash_funcs/murmur3.rs 225 native/spark-expr/src/hash_funcs/sha2.rs 54 native/spark-expr/src/hash_funcs/utils.rs 431 native/spark-expr/src/hash_funcs/xxhash64.rs 218 native/spark-expr/src/json_funcs/mod.rs 2 native/spark-expr/src/json_funcs/to_json.rs 303 native/spark-expr/src/kernels/mod.rs 2 native/spark-expr/src/kernels/strings.rs 90 native/spark-expr/src/kernels/temporal.rs 1010 native/spark-expr/src/lib.rs 56 native/spark-expr/src/math_funcs/ceil.rs 63 native/spark-expr/src/math_funcs/div.rs 88 native/spark-expr/src/math_funcs/floor.rs 63 native/spark-expr/src/math_funcs/hex.rs 229 native/spark-expr/src/math_funcs/internal/checkoverflow.rs 127 native/spark-expr/src/math_funcs/internal/make_decimal.rs 43 native/spark-expr/src/math_funcs/internal/mod.rs 8 native/spark-expr/src/math_funcs/internal/normalize_nan.rs 132 native/spark-expr/src/math_funcs/internal/unscaled_value.rs 25 native/spark-expr/src/math_funcs/mod.rs 18 native/spark-expr/src/math_funcs/negative.rs 208 native/spark-expr/src/math_funcs/round.rs 182 native/spark-expr/src/math_funcs/unhex.rs 191 native/spark-expr/src/math_funcs/utils.rs 53 native/spark-expr/src/predicate_funcs/is_nan.rs 51 native/spark-expr/src/predicate_funcs/mod.rs 4 native/spark-expr/src/predicate_funcs/rlike.rs 130 native/spark-expr/src/static_invoke/char_varchar_utils/mod.rs 2 native/spark-expr/src/static_invoke/char_varchar_utils/read_side_padding.rs 83 native/spark-expr/src/static_invoke/mod.rs 2 native/spark-expr/src/string_funcs/chr.rs 91 native/spark-expr/src/string_funcs/mod.rs 8 native/spark-expr/src/string_funcs/prediction.rs 102 native/spark-expr/src/string_funcs/string_space.rs 77 native/spark-expr/src/string_funcs/substring.rs 84 native/spark-expr/src/struct_funcs/create_named_struct.rs 126 native/spark-expr/src/struct_funcs/get_struct_field.rs 98 native/spark-expr/src/struct_funcs/mod.rs 4 native/spark-expr/src/timezone.rs 51 native/spark-expr/src/unbound.rs 33 native/spark-expr/src/utils.rs 170