Mingliang Zhu
Mingliang Zhu
### What changes were proposed in this pull request? In ad hoc queries we often need to limit the number of rows returned, if query is limit outside of window...
### What changes were proposed in this pull request? Push down throwable predicate through aggregates and add ut for "can't push down nondeterministic filter through aggregate". ### Why are the...
### What changes were proposed in this pull request? Be consistent with closing code-gen, update code-gen for full outer sort merge join output row by row. For example: ``` val...
# What changes were proposed in this pull request? Set activeSession before each script execution. Because spark `functions.expr` use SQLConf of activeSession. Refer to [SPARK-44206](https://issues.apache.org/jira/browse/SPARK-44206), all SparkSession dataset methods already...
#### Which Delta project/connector is this regarding? - [x] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ##...
## Bug #### Which Delta project/connector is this regarding? - [x] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in...
### What changes were proposed in this pull request? Remove unexpected exception thrown in `EquivalentExpressions.updateExprInMap()`. Equivalent expressions may contain different children, it should happen expression not in map and `useCount`...
### What changes were proposed in this pull request? Avoid push down predicate if non-cheap expression exceed reused limit. Push down predicate through project/aggregate need replace expression, if the expression...
### What changes were proposed in this pull request? Expression definitions should apply to the entire `With` child contains internally nested `WITH`, so refactor `RewriteWithExpression` logic. Rewrite `With` consists of...
## What changes were proposed in this pull request? (Fixes: \#7685) In production, we encountered a situation where the consumption of r2c large table was far greater than the performance...