You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2023/04/19 23:59:21 UTC
[kafka] branch 3.5 updated (34f037c1394 -> 6cf1010a6bf)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 34f037c1394 KAFKA-14881: Rework UserScramCredentialRecord (#13513)
add 6cf1010a6bf KAFKA-14834: [11/N] Update table joins to identify out-of-order records with `isLatest` (#13609)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/InternalStreamsBuilder.java | 10 +-
.../streams/kstream/internals/KTableImpl.java | 22 +-
.../internals/KTableKTableAbstractJoin.java | 20 +-
.../kstream/internals/KTableKTableInnerJoin.java | 30 +-
.../kstream/internals/KTableKTableLeftJoin.java | 30 +-
.../kstream/internals/KTableKTableOuterJoin.java | 30 +-
.../kstream/internals/KTableKTableRightJoin.java | 30 +-
.../ForeignTableJoinProcessorSupplier.java | 40 +--
.../SubscriptionJoinProcessorSupplier.java | 2 +-
.../SubscriptionReceiveProcessorSupplier.java | 2 +-
.../SubscriptionSendProcessorSupplier.java | 46 +--
.../internals/graph/BaseJoinProcessorNode.java | 6 +-
...e.java => ForeignJoinSubscriptionSendNode.java} | 25 +-
...leFilterNode.java => ForeignTableJoinNode.java} | 28 +-
.../internals/graph/KTableKTableJoinNode.java | 37 ++-
.../kstream/internals/graph/TableFilterNode.java | 2 +-
.../internals/graph/TableRepartitionMapNode.java | 2 +-
.../graph/VersionedSemanticsGraphNode.java | 2 +-
.../integration/AbstractJoinIntegrationTest.java | 53 ++-
...ableForeignKeyVersionedJoinIntegrationTest.java | 72 ++--
.../StreamStreamJoinIntegrationTest.java | 334 +------------------
.../StreamTableJoinIntegrationTest.java | 46 ++-
.../integration/TableTableJoinIntegrationTest.java | 363 +++++++++------------
.../internals/InternalStreamsBuilderTest.java | 201 ++++++++++++
.../streams/kstream/internals/KStreamImplTest.java | 8 +-
25 files changed, 671 insertions(+), 770 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/{TableFilterNode.java => ForeignJoinSubscriptionSendNode.java} (56%)
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/{TableFilterNode.java => ForeignTableJoinNode.java} (50%)