Skip to content

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 👍

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