-
Notifications
You must be signed in to change notification settings - Fork 3.1k
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
Simplify creation of join operator #13783
Simplify creation of join operator #13783
Conversation
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
0dcd9d6
to
842304b
Compare
Made the changes you proposed. Indeed it is much more readable now |
Additionally, more lines are removed than added. |
core/trino-main/src/main/java/io/trino/operator/TrinoOperatorFactories.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/TrinoOperatorFactories.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/test/java/io/trino/operator/join/unspilled/JoinTestUtils.java
Outdated
Show resolved
Hide resolved
...-main/src/test/java/io/trino/operator/join/unspilled/BenchmarkHashBuildAndJoinOperators.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Show resolved
Hide resolved
842304b
to
335b0a5
Compare
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
77ae5bf
to
8285a1f
Compare
core/trino-main/src/main/java/io/trino/operator/OperatorFactories.java
Outdated
Show resolved
Hide resolved
8285a1f
to
8068553
Compare
This makes further refactorings easier to read.
Since the split into spilling and non-spilling, creation of join operators had some unnecessary casting. This commit cleans it and makes clear spilling/non-spilling code paths in LocalExecutionPlanner. Changes in this class are strictly mechanical. No logical changes are made.
8068553
to
1c8f7c2
Compare
OptionalInt totalOperatorsCount, | ||
PartitioningSpillerFactory partitioningSpillerFactory, | ||
BlockTypeOperators blockTypeOperators); | ||
public static class JoinOperatorType |
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.
Modifier 'public' is redundant for interface members
Modifier 'static' is redundant for inner classes of interfaces
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.
Thanks. I wonder why InteliJ did not notice this.
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.
I've InteliJ Ultimate - and it's not that I'm an eagle.
Description
refactoring
core query engine
nothing worth mentioning
Related issues, pull requests, and links
Documentation
(x) No documentation is needed.
( ) Sufficient documentation is included in this PR.
( ) Documentation PR is available with #prnumber.
( ) Documentation issue #issuenumber is filed, and can be handled later.
Release notes
(x) No release notes entries required.
( ) Release notes entries required with the following suggested text: