Skip to content
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

[MINOR]: Some code changes and a new empty batch guard for SHJ #8557

Merged
merged 2 commits into from
Dec 15, 2023
Merged

[MINOR]: Some code changes and a new empty batch guard for SHJ #8557

merged 2 commits into from
Dec 15, 2023

Conversation

metesynnada
Copy link
Contributor

Which issue does this PR close?

Closes #.

Rationale for this change

StreamJoinMetrics can be replaced under the stream_join_utils.rs.

What changes are included in this PR?

Code replacement for utils. Also, I added an empty RecordBatch guard for the edge cases in SHJ.

Are these changes tested?

With existing tests.

Are there any user-facing changes?

No

Copy link
Contributor

@mustafasrepo mustafasrepo left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It is LGTM!

Copy link
Contributor

@ozankabak ozankabak left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM, the moved code is common to all stream joins 👍

@mustafasrepo mustafasrepo merged commit bf0073c into apache:main Dec 15, 2023
22 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants