Mailing-List: contact issues-help@spark.apache.org; run by ezmlm
Precedence: bulk
Date: Tue, 23 Dec 2014 13:29:13 +0000 (UTC)
From: "Apache Spark (JIRA)" <jira@apache.org>
To: issues@spark.apache.org
Message-ID: <JIRA.12763461.1419341151000.91197.1419341353203@Atlassian.JIRA>
In-Reply-To: <JIRA.12763461.1419341151000@Atlassian.JIRA>
References: <JIRA.12763461.1419341151000@Atlassian.JIRA>
 <JIRA.12763461.1419341151517@arcas>
Subject: [jira] [Commented] (SPARK-4938) Adding optimization to simplify the
 filter condition
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/SPARK-4938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14256964#comment-14256964 ] 

Apache Spark commented on SPARK-4938:
-------------------------------------

User 'scwf' has created a pull request for this issue:
https://github.com/apache/spark/pull/3778

> Adding optimization to simplify the filter condition
> ----------------------------------------------------
>
>                 Key: SPARK-4938
>                 URL: https://issues.apache.org/jira/browse/SPARK-4938
>             Project: Spark
>          Issue Type: Improvement
>          Components: SQL
>    Affects Versions: 1.1.0
>            Reporter: wangfei
>             Fix For: 1.3.0
>
>
> Adding optimization to simplify the filter condition:
> 1  condition that can get the boolean result such as:
> a < 3 && a > 5     ----  False
> a < 1 || a > 0        ---- True
> 2 Simplify And, Or condition, such as the sql (one of hive-testbench
> ):
> select
>     sum(l_extendedprice* (1 - l_discount)) as revenue
> from
>     lineitem,
>     part
> where
>     (
>         p_partkey = l_partkey
>         and p_brand = 'Brand#32'
>         and p_container in ('SM CASE', 'SM BOX', 'SM PACK', 'SM PKG')
>         and l_quantity >= 7 and l_quantity <= 7 + 10
>         and p_size between 1 and 5
>         and l_shipmode in ('AIR', 'AIR REG')
>         and l_shipinstruct = 'DELIVER IN PERSON'
>     )
>     or
>     (
>         p_partkey = l_partkey
>         and p_brand = 'Brand#35'
>         and p_container in ('MED BAG', 'MED BOX', 'MED PKG', 'MED PACK')
>         and l_quantity >= 15 and l_quantity <= 15 + 10
>         and p_size between 1 and 10
>         and l_shipmode in ('AIR', 'AIR REG')
>         and l_shipinstruct = 'DELIVER IN PERSON'
>     )
>     or
>     (
>         p_partkey = l_partkey
>         and p_brand = 'Brand#24'
>         and p_container in ('LG CASE', 'LG BOX', 'LG PACK', 'LG PKG')
>         and l_quantity >= 26 and l_quantity <= 26 + 10
>         and p_size between 1 and 15
>         and l_shipmode in ('AIR', 'AIR REG')
>         and l_shipinstruct = 'DELIVER IN PERSON'
>     );
>  Before optimized it is a CartesianProduct, in my locally test this sql hang and can not get result, after optimization the CartesianProduct replaced by ShuffledHashJoin, which only need 20+ seconds to run this sql.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org