[CALCITE-2348] Handling non-deterministic operator in rules

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.17.0
• Component/s: core
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: godfrey he
• Created: 01/Jun/18 06:43
• Updated: 19/Feb/20 18:18

Description

Currently,  rules do not handle non-deterministic operator,

e.g. FilterAggregateTransposeRule can't push down a non-deterministic filter through an aggregate.

// rand_substr is a non-deterministic udf
@Test public void testPushFilterPastAggWithNondeterministicFilter() {
  final String sql = "select ename, empno, c from\n"
      + " (select ename, empno, count(*) as c from emp group by ename, empno) t\n"
      + " where rand_substr(ename, 1, 3) = 'Tom' and empno = 10";
  checkPlanning(FilterAggregateTransposeRule.INSTANCE, sql);
}

 

Issue Links

• relates to: CALCITE-3760 Rewriting non-deterministic function can break query semantics
• links to: PR717