-
Notifications
You must be signed in to change notification settings - Fork 1.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[HZ-561] Implement EXISTS and NOT EXISTS expressions #19729
[HZ-561] Implement EXISTS and NOT EXISTS expressions #19729
Conversation
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/HazelcastSqlToRelConverter.java
Outdated
Show resolved
Hide resolved
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/CreateDagVisitor.java
Outdated
Show resolved
Hide resolved
This comment has been minimized.
This comment has been minimized.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/ObjectArrayKey.java
Show resolved
Hide resolved
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/CreateDagVisitor.java
Outdated
Show resolved
Hide resolved
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/JoinConverterRule.java
Outdated
Show resolved
Hide resolved
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/QueryConverter.java
Outdated
Show resolved
Hide resolved
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/HashJoinProcessor.java
Outdated
Show resolved
Hide resolved
...in/java/com/hazelcast/jet/sql/impl/validate/operators/predicate/HazelcastExistsOperator.java
Outdated
Show resolved
Hide resolved
@@ -93,6 +93,11 @@ public void consume(Inbox inbox) { | |||
offset--; | |||
} | |||
|
|||
if (limit <= 0) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why is it needed? All tests pass without it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It was needed for the previous implementation because it was breaking LIMIT 0 queries in other SQL tests.
Interestingly, it works now. I am planning to keep it because if limit == 0
, then the logic in the consume is wrong.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
* Remove assertions * Use kind equality directly * Improve operator operand count and type checks
This comment has been minimized.
This comment has been minimized.
run-lab-run |
Implementation of
EXISTS(...)
andNOT EXISTS(...)
expressions for SQLNOTE:
This implementation has different visibility semantics for the rows originated from right input.