-
Notifications
You must be signed in to change notification settings - Fork 1k
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
fix: changes required for compatibility with KIP-479 #3466
fix: changes required for compatibility with KIP-479 #3466
Conversation
final String name, | ||
final String storeName) { | ||
return StreamJoined.with(keySerde, leftSerde, rightSerde) | ||
.withName(name).withStoreName(storeName); |
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.
The withStoreName
is the key change/addition. If we want to stick with generated store names, we can omit the withStoreName
call and update the expected topologies for the QueryTranslationTest
.
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.
LGTM! Thanks @bbejeck
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.
The code changes to ksql-streams
look good. You won't need the changes to SchemaKStream after you rebase.
530ae49
to
689fc83
Compare
rebased and updated this PR |
689fc83
to
1a87af9
Compare
rebased this |
@@ -251,6 +254,7 @@ public void shouldDoInnerJoin() { | |||
} | |||
|
|||
@Test | |||
@SuppressFBWarnings |
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.
Spotbugs doesn't like line 266, adding this suppression for now
Return value of StreamJoinedFactory.create(Serde, Serde, Serde, String, String) ignored, but method has no side effect [io.confluent.ksql.execution.streams.StreamStreamJoinBuilderTest] At StreamStreamJoinBuilderTest.java:[line 264] RV_RETURN_VALUE_IGNORED_NO_SIDE_EFFECT
Merged #3466 into master. |
Description
This PR introduces the
StreamJoined
object from KIP-479. Specifically this PRKStream#join(KStream,....Joined)
methods in favor ofKStream#join(KStream,....StreamJoined)
Testing done
I updated existing tests. Since this PR does not introduce new behavior, I felt that updating the current tests is sufficient.
EDIT: I ran the
QueryTranslationTest
,ksql-engine
, andksql-streams
tests locally and all passed.Reviewer checklist