-
Notifications
You must be signed in to change notification settings - Fork 236
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
Spillable host buffer #9070
Spillable host buffer #9070
Conversation
Signed-off-by: Alessandro Bellina <[email protected]>
Markdown failing on:
|
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.
Looks good. Need to start using it to really see what we need to change, but generally it looks a lot smaller than I expected.
@@ -294,29 +295,42 @@ class RapidsBufferCatalog( | |||
} | |||
|
|||
/** | |||
* Adds a buffer to the device storage. This does NOT take ownership of the | |||
* buffer, so it is the responsibility of the caller to close it. | |||
* Adds a buffer to the either device or host storage. This does NOT take |
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.
nit Adds a buffer to either the device or host storage.
sql-plugin/src/main/scala/com/nvidia/spark/rapids/RapidsBufferCatalog.scala
Show resolved
Hide resolved
build |
@jlowe you looked at the first spillable code changes for device buffers. Could you take a look at this one too, just to have another pair of eyes so to find things I might have missed? |
…already warned before
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.
Got confused by the setSpillable/doSetSpillable distinction, but that already existed and can be addressed separately, tracked in #9076.
build |
This contributes towards #8882 but it doesn't close it since we need to handle
HostColumnVectors
(it will end up being aSpillableHostBatch
for now).I can add more tests around host spillability but I do have a couple of TODOs in the code that I need some clarification on (possibly just put it in as is and add follow on as we add more support for host spillable).
Posting for some 👀 to make sure I didn't miss something major.