more renaming

apache · Jan 30, 2025 · 7d39853 · 7d39853
1 parent 77ec779
commit 7d39853
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java
@@ -27,18 +27,18 @@
 import java.util.Optional;
 import java.util.Set;
 
-class KStreamKTableJoin<KStream, VStream, VTable, VOut> implements ProcessorSupplier<KStream, VStream, KStream, VOut> {
+class KStreamKTableJoin<StreamKey, StreamValue, TableValue, VOut> implements ProcessorSupplier<StreamKey, StreamValue, StreamKey, VOut> {
 
-    private final KeyValueMapper<KStream, VStream, KStream> keyValueMapper = (key, value) -> key;
-    private final KTableValueGetterSupplier<KStream, VTable> valueGetterSupplier;
-    private final ValueJoinerWithKey<? super KStream, ? super VStream, ? super VTable, VOut> joiner;
+    private final KeyValueMapper<StreamKey, StreamValue, StreamKey> keyValueMapper = (key, value) -> key;
+    private final KTableValueGetterSupplier<StreamKey, TableValue> valueGetterSupplier;
+    private final ValueJoinerWithKey<? super StreamKey, ? super StreamValue, ? super TableValue, VOut> joiner;
     private final boolean leftJoin;
     private final Optional<Duration> gracePeriod;
     private final Optional<String> storeName;
     private final Set<StoreBuilder<?>> stores;
 
-    KStreamKTableJoin(final KTableValueGetterSupplier<KStream, VTable> valueGetterSupplier,
-                      final ValueJoinerWithKey<? super KStream, ? super VStream, ? super VTable, VOut> joiner,
+    KStreamKTableJoin(final KTableValueGetterSupplier<StreamKey, TableValue> valueGetterSupplier,
+                      final ValueJoinerWithKey<? super StreamKey, ? super StreamValue, ? super TableValue, VOut> joiner,
                       final boolean leftJoin,
                       final Optional<Duration> gracePeriod,
                       final Optional<StoreBuilder<?>> bufferStoreBuilder) {
@@ -57,7 +57,7 @@ public Set<StoreBuilder<?>> stores() {
     }
 
     @Override
-    public Processor<KStream, VStream, KStream, VOut> get() {
+    public Processor<StreamKey, StreamValue, StreamKey, VOut> get() {
         return new KStreamKTableJoinProcessor<>(valueGetterSupplier.get(), keyValueMapper, joiner, leftJoin, gracePeriod, storeName);
     }