Andy Grove
Andy Grove
### What is the problem the feature request solves? Spark supports casting a struct to a different struct type. We should add support in Comet. ```scala private[this] def castStruct(from: StructType,...
### What is the problem the feature request solves? I am benchmarking with this query (based on TPC-DS q39): ```sql select w_warehouse_name,w_warehouse_sk,i_item_sk,d_moy ,stddev_samp(inv_quantity_on_hand) stdev from inventory ,item ,warehouse ,date_dim where...
### What is the problem the feature request solves? Comet currently performances poorly with the following query when broadcast hash joins are disabled and when Comet native shuffle is disabled....
### What is the problem the feature request solves? In `ScanExec` there can be a difference between the Parquet data type and the Spark data type being requested. In this...
### Describe the bug We do not need to have a native version of `AQEShuffleRead`, so we should not show warnings like this: ``` WARN CometSparkSessionExtensions$CometExecRule: Comet cannot execute some...
## Which issue does this PR close? Closes #. ## Rationale for this change ## What changes are included in this PR? ## How are these changes tested?
## Which issue does this PR close? N/A ## Rationale for this change Many tests use the following pattern to cover testing with dictionary-encoded data. ```scala Seq("true", "false").foreach { dictionary...
### Describe the bug Many tests use the following pattern to cover testing with dictionary-encoded data. ```scala Seq("true", "false").foreach { dictionary => withParquetTable( (-5 until 5).map(i => (i.toDouble + 0.3,...
### What is the problem the feature request solves? We should move the following expressions to the new crate. - [ ] NegativeExpr - [ ] UnboundColumn - [x] HourExec/MinuteExec/SecondExec/DateTruncExec/TimestampTruncExec...
### Describe the bug We have a user report that they are unable to get Comet to run certain aggregate queries that work fine in Spark. This issue is to...