Skip to content

Conversation

@baishuo
Copy link
Contributor

@baishuo baishuo commented Mar 27, 2014

use more faster way to construct an Array

use more faster way to construct an Array
@AmplabJenkins
Copy link

Can one of the admins verify this patch?

1 similar comment
@AmplabJenkins
Copy link

Can one of the admins verify this patch?

@mengxr
Copy link
Contributor

mengxr commented Apr 29, 2014

Jenkins, test this please.

@AmplabJenkins
Copy link

Build triggered.

@AmplabJenkins
Copy link

Build started.

@mengxr
Copy link
Contributor

mengxr commented Apr 29, 2014

@baishuo This is no longer mergeable. Could you try to merge the latest master?

@AmplabJenkins
Copy link

Build finished. All automated tests passed.

@AmplabJenkins
Copy link

All automated tests passed.
Refer to this link for build results: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/14559/

@baishuo
Copy link
Contributor Author

baishuo commented Apr 29, 2014

no problem @mengxr

@baishuo
Copy link
Contributor Author

baishuo commented Apr 29, 2014

Hi @mengxr the new PR is #588 please go to see if it can merge, thank you .
close this PR

@baishuo baishuo closed this Apr 29, 2014
lins05 added a commit to lins05/spark that referenced this pull request May 18, 2017
* Exit properly when the k8s cluster is not available.

* add jetty to k8s module dependency so we can use only rebuild the k8s module.

* CR

* Fixed single thread scheduler.

* Fixed scalastyle check.

* CR
erikerlandson pushed a commit to erikerlandson/spark that referenced this pull request Jul 28, 2017
* Exit properly when the k8s cluster is not available.

* add jetty to k8s module dependency so we can use only rebuild the k8s module.

* CR

* Fixed single thread scheduler.

* Fixed scalastyle check.

* CR
Igosuki pushed a commit to Adikteev/spark that referenced this pull request Jul 31, 2018
* smoke test

* use nobody in tests

* update docs a little
bzhaoopenstack pushed a commit to bzhaoopenstack/spark that referenced this pull request Sep 11, 2019
Config OCTAVIA_MGMT_SUBNET to avoid IP conflicting
turboFei pushed a commit to turboFei/spark that referenced this pull request Nov 6, 2025
…apache#256)

### What changes were proposed in this pull request?

This PR enhances ConstantPropagation to support more cases.

Propagated through other binary comparisons.
Propagated across equality comparisons. This can be further optimized to false.

### Why are the changes needed?

Improve query performance. [Denodo](https://community.denodo.com/docs/html/browse/latest/en/vdp/administration/optimizing_queries/automatic_simplification_of_queries/removing_redundant_branches_of_queries_partitioned_unions) also has a similar optimization. For example:
```
CREATE TABLE t1(a int, b int) using parquet;
CREATE TABLE t2(x int, y int) using parquet;

CREATE TEMP VIEW v1 AS
SELECT * FROM t1 JOIN t2 WHERE a = x AND a = 0
UNION ALL
SELECT * FROM t1 JOIN t2 WHERE a = x AND (a IS NULL OR a <> 0);

SELECT * FROM v1 WHERE x > 1;
```
Before this PR:
```
== Optimized Logical Plan ==
Union false, false
:- Project [a#0 AS a#12, b#1 AS b#13, x#2 AS x#14, y#3 AS y#15]
:  +- Join Inner
:     :- Filter (isnotnull(a#0) AND (a#0 = 0))
:     :  +- Relation spark_catalog.default.t1[a#0,b#1] parquet
:     +- Filter (isnotnull(x#2) AND ((0 = x#2) AND (x#2 > 1)))
:        +- Relation spark_catalog.default.t2[x#2,y#3] parquet
+- Join Inner, (a#16 = x#18)
   :- Filter ((isnull(a#16) OR NOT (a#16 = 0)) AND ((a#16 > 1) AND isnotnull(a#16)))
   :  +- Relation spark_catalog.default.t1[a#16,b#17] parquet
   +- Filter ((isnotnull(x#18) AND (x#18 > 1)) AND (isnull(x#18) OR NOT (x#18 = 0)))
      +- Relation spark_catalog.default.t2[x#18,y#19] parquet
```
After this PR:
```
== Optimized Logical Plan ==
Join Inner, (a#16 = x#18)
:- Filter ((isnull(a#16) OR NOT (a#16 = 0)) AND ((a#16 > 1) AND isnotnull(a#16)))
:  +- Relation spark_catalog.default.t1[a#16,b#17] parquet
+- Filter ((isnotnull(x#18) AND (x#18 > 1)) AND (isnull(x#18) OR NOT (x#18 = 0)))
   +- Relation spark_catalog.default.t2[x#18,y#19] parquet
```
### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Unit test.

Closes apache#42038 from TongWei1105/SPARK-42500.

Authored-by: TongWei1105 <[email protected]>
Signed-off-by: Yuming Wang <[email protected]>
(cherry picked from commit 74ae1e3)

Co-authored-by: TongWei1105 <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants