You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@ignite.apache.org by "Ignite TC Bot (Jira)" <ji...@apache.org> on 2025/03/04 05:32:00 UTC

[jira] [Commented] (IGNITE-24688) Add FILTER_CORRELATE rule to HEP push down list

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

Ignite TC Bot commented on IGNITE-24688:
----------------------------------------

{panel:title=Branch: [pull/11905/head] Base: [master] : No blockers found!|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1}{panel}
{panel:title=Branch: [pull/11905/head] Base: [master] : No new tests found!|borderStyle=dashed|borderColor=#ccc|titleBGColor=#F7D6C1}{panel}
[TeamCity *--&gt; Run :: All* Results|https://ci2.ignite.apache.org/viewLog.html?buildId=8336065&amp;buildTypeId=IgniteTests24Java8_RunAll]

> Add FILTER_CORRELATE rule to HEP push down list
> -----------------------------------------------
>
>                 Key: IGNITE-24688
>                 URL: https://issues.apache.org/jira/browse/IGNITE-24688
>             Project: Ignite
>          Issue Type: Improvement
>            Reporter: Maksim Timonin
>            Assignee: Maksim Timonin
>            Priority: Major
>              Labels: ise
>             Fix For: 2.18
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
>  
> In the plan below Filter rule is under IgniteTableScan. This leads to memory overhead. Let's fix it by adding new filter push down rule - Calcite's FILTER_CORRELATE rule
>  
> {code:java}
> IgniteColocatedSortAggregate(group=[{0}], ORDER_COUNT=[COUNT()], collation=[[0 ASC-nulls-first]]): 
>   IgniteProject(O_ORDERPRIORITY=[$7])
>     IgniteFilter(condition=[AND(>=($6, 1998-01-01), <($6, +(1998-01-01, 3:INTERVAL MONTH)))])
>       IgniteCorrelatedNestedLoopJoin(condition=[true], joinType=[inner], variablesSet=[[$cor0]], variablesSet=[[0]], correlationVariables=[[$cor0]])
>         IgniteExchange(distribution=[single])
>           IgniteSort(sort0=[$7], dir0=[ASC-nulls-first])
>             IgniteTableScan(table=[[PUBLIC, ORDERS]])
>         IgniteColocatedHashAggregate(group=[{0}])
>           IgniteProject(i=[true])
>             IgniteHashIndexSpool(readType=[LAZY], writeType=[EAGER], searchRow=[[$cor0.O_ORDERKEY, null, null]], condition=[AND(=($0, $cor0.O_ORDERKEY), <($1, $2))], allowNulls=[false])
>               IgniteExchange(distribution=[single])
>                 IgniteTableScan(table=[[PUBLIC, LINEITEM]], requiredColumns=[{2, 13, 14}])
>  {code}
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)