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%)
