[CALCITE-3667] EnumerableMergeJoin should not use take-while enumerator

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Labels: pull-request-available
• Assignee: Jin Xing
• Reporter: Jin Xing
• Created: 02/Jan/20 14:48
• Updated: 19/Mar/20 17:12

Description

Currently EnumerableMergeJoin use take-while enumerator [1] to emit values satisfy predicate. However take-while enumerator stops the enumeration at once when predicate is failed, which is not correct and we should finish the enumeration and extract all the qualified values.

[1] https://github.com/apache/calcite/blob/master/linq4j/src/main/java/org/apache/calcite/linq4j/EnumerableDefaults.java#L3896

Issue Links

• is related to: CALCITE-3285 EnumerableMergeJoin should support non-equi join conditions
• links to: GitHub Pull Request #1717