Spill for Window and OrderBy operators#228
Conversation
|
Thank you for your pull request and welcome to our community. We could not parse the GitHub identity of the following contributors: Atri Sharma.
|
|
@findepi new commits that require review: New spill are enabled by default (when spilling is enabled). |
e0359db to
e0ef8d3
Compare
|
Thank you for your pull request and welcome to our community. We could not parse the GitHub identity of the following contributors: Atri Sharma.
|
presto-hive/src/test/java/io/prestosql/plugin/hive/TestHiveDistributedOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
findepi
left a comment
There was a problem hiding this comment.
"Convert revocable memory to user memory on fully buffered group"
presto-hive/src/test/java/io/prestosql/plugin/hive/TestHiveDistributedOrderByQueries.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/operator/WindowOperator.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/operator/WindowOperator.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/operator/WindowOperator.java
Outdated
Show resolved
Hide resolved
presto-main/src/test/java/io/prestosql/operator/TestWindowOperator.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
remove revocablePagesIndex parameter from updateMemoryUsage
There was a problem hiding this comment.
How would we know if pages index is revocable then?
findepi
left a comment
There was a problem hiding this comment.
"Use OrderingCompiler in WindowOperator spilling"
presto-main/src/main/java/io/prestosql/operator/WindowOperator.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
i'd add this param after int preSortedChannelPrefix,, or after PagesIndex.Factory pagesIndexFactory,
findepi
left a comment
There was a problem hiding this comment.
"Convert revocable memory to user memory on OrderBy finish"
presto-main/src/main/java/io/prestosql/operator/OrderByOperator.java
Outdated
Show resolved
Hide resolved
presto-main/src/test/java/io/prestosql/operator/TestOrderByOperator.java
Outdated
Show resolved
Hide resolved
findepi
left a comment
There was a problem hiding this comment.
"Use OrderingCompiler in OrderBy spilling"
There was a problem hiding this comment.
move this param after List<SortOrder> sortOrder,
There was a problem hiding this comment.
move this field after private final List<SortOrder> sortOrder;
(and move private boolean closed; to be last, separated by a blank line)
There was a problem hiding this comment.
I think that orderingCompiler is tightly coupled with spillerFactory, so they can as well be paired as parameters (similar in window operator)
Moved closed
|
@sopel39 i reviewed the new commits listed in #228 (comment) Also, please update |
|
Thank you for your pull request and welcome to our community. We could not parse the GitHub identity of the following contributors: Atri Sharma.
|
presto-tests/src/main/java/io/prestosql/tests/AbstractTestOrderByQueries.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
How would we know if pages index is revocable then?
There was a problem hiding this comment.
Fix error message commit
Please squash this with the first commit which broadens the use of OrderingCompiler. Otherwise you lose the context of the "fix".
ORDER BY currently will error out if the data being processed exceeds query memory limit. This commit introduces paging from disk and ensures that ORDER BY is limited only by the amount of disk present.
e2e3d24 to
37006b0
Compare
|
Thank you for your pull request and welcome to our community. We could not parse the GitHub identity of the following contributors: Atri Sharma.
|
This avoids calling `Page.getRegion` on the input page and separates input management from index building.
37006b0 to
f30d3c6
Compare
|
Thank you for your pull request and welcome to our community. We could not parse the GitHub identity of the following contributors: Atri Sharma.
|
No description provided.