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/18 18:32:55 UTC
[kafka] branch trunk updated (abca86511ec -> 3388adf1b52)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from abca86511ec KAFKA-14881: Rework UserScramCredentialRecord (#13513)
     add 3388adf1b52 MINOR: rename internal FK-join processor classes (#13589)

No new revisions were added by this update.

Summary of changes:
 .../streams/kstream/internals/KTableImpl.java      | 57 +++++++++++-----------
 ...java => ForeignTableJoinProcessorSupplier.java} |  6 +--
 ...ier.java => ResponseJoinProcessorSupplier.java} | 12 ++---
 ...java => SubscriptionJoinProcessorSupplier.java} |  4 +-
 ...a => SubscriptionReceiveProcessorSupplier.java} |  6 +--
 ...java => SubscriptionSendProcessorSupplier.java} | 18 +++----
 .../streams/integration/ForeignKeyJoinSuite.java   |  4 +-
 ... => ForeignTableJoinProcessorSupplierTest.java} |  6 +--
 ...java => ResponseJoinProcessorSupplierTest.java} | 26 +++++-----
 ... SubscriptionReceiveProcessorSupplierTest.java} | 22 ++++-----
 10 files changed, 80 insertions(+), 81 deletions(-)
 rename streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{ForeignJoinSubscriptionProcessorSupplier.java => ForeignTableJoinProcessorSupplier.java} (97%)
 rename streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{SubscriptionResolverJoinProcessorSupplier.java => ResponseJoinProcessorSupplier.java} (89%)
 rename streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{SubscriptionJoinForeignProcessorSupplier.java => SubscriptionJoinProcessorSupplier.java} (97%)
 rename streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{SubscriptionStoreReceiveProcessorSupplier.java => SubscriptionReceiveProcessorSupplier.java} (97%)
 rename streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{ForeignJoinSubscriptionSendProcessorSupplier.java => SubscriptionSendProcessorSupplier.java} (92%)
 rename streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{ForeignJoinSubscriptionProcessorSupplierTest.java => ForeignTableJoinProcessorSupplierTest.java} (98%)
 rename streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{SubscriptionResolverJoinProcessorSupplierTest.java => ResponseJoinProcessorSupplierTest.java} (90%)
 rename streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/{SubscriptionStoreReceiveProcessorSupplierTest.java => SubscriptionReceiveProcessorSupplierTest.java} (95%)