-
Notifications
You must be signed in to change notification settings - Fork 912
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
Remove cudf._lib.transform in favor of inlining pylibcudf #17505
Remove cudf._lib.transform in favor of inlining pylibcudf #17505
Conversation
… into cudf/_lib/transform
@@ -7883,6 +7881,16 @@ def interleave_columns(self): | |||
) | |||
return self._constructor_sliced._from_column(result_col) | |||
|
|||
@acquire_spill_lock() | |||
def _compute_columns(self, expr: str) -> ColumnBase: |
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.
Suggesting because it returns one column
def _compute_columns(self, expr: str) -> ColumnBase: | |
def _compute_column(self, expr: str) -> ColumnBase: |
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.
Sure, that makes sense. I'll incorporate this in another PR just to save a CI run
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 incorporated it in #17456
[*self._columns], self._column_names, statements[0] | ||
) | ||
) | ||
return Series._from_column(self._compute_columns(statements[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.
return Series._from_column(self._compute_columns(statements[0])) | |
return Series._from_column(self._compute_column(statements[0])) |
for name, col in zip(targets, cols): | ||
ret._data[name] = col | ||
for name, expr in zip(targets, exprs): | ||
ret._data[name] = self._compute_columns(expr) |
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.
ret._data[name] = self._compute_columns(expr) | |
ret._data[name] = self._compute_column(expr) |
/merge |
9df95d1
into
rapidsai:branch-25.02
Description
Contributes to #17317
Checklist