Skip to content

Conversation

@kunwp1
Copy link
Contributor

@kunwp1 kunwp1 commented Jan 22, 2026

What changes were proposed in this PR?

This PR adds multi-port support to R UDF operators by aligning R UDF descriptors with the Python UDF operator descriptor. Users can now add additional input ports and customize the port configuration.

Any related issues, documentation, discussions?

Closes #4173

How was this PR tested?

Test with this workflow R UDF Multi Port.json
Dataset: Iris.csv

The first port will run first and the second port will run next.
Screenshot 2026-01-22 at 1 13 23 PM

Was this PR authored or co-authored using generative AI tooling?

No.

@kunwp1 kunwp1 self-assigned this Jan 22, 2026
@kunwp1 kunwp1 changed the title feat: Enable Multiple Ports on R UDF operators feat: Enable Multiple Input Ports on R UDF operators Jan 22, 2026
@kunwp1 kunwp1 requested a review from chenlica January 22, 2026 21:53
@kunwp1
Copy link
Contributor Author

kunwp1 commented Jan 22, 2026

I initially assigned this PR to @chenlica because @Ma77Ball isn’t a contributor and can’t be assigned as a reviewer.

@kunwp1 kunwp1 requested review from Yicong-Huang and removed request for chenlica January 22, 2026 22:13
@Yicong-Huang
Copy link
Contributor

I initially assigned this PR to @chenlica because @Ma77Ball isn’t a contributor and can’t be assigned as a reviewer.

For those cases, just @ him in comment.

@Yicong-Huang
Copy link
Contributor

There must be some change on the Rudf template. Can we also add the changes in this PR?

@kunwp1
Copy link
Contributor Author

kunwp1 commented Jan 22, 2026

There must be some change on the Rudf template. Can we also add the changes in this PR?

What should we change in the template? It already includes port as a parameter.

@Yicong-Huang
Copy link
Contributor

What should we change in the template? It already includes port as a parameter.

Oh I didn't realize we already did that. Then I don't think we need other changes.

@Ma77Ball
Copy link
Contributor

@kunwp1 I ran the code locally, and it worked as expected. I think we can add more human-readable error logs in a future PR. Overall, though the code, LGTM!

@Yicong-Huang Yicong-Huang merged commit ece433c into apache:main Jan 23, 2026
10 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Support multiple ports on R UDF operators

4 participants