[kafka] branch trunk updated: MINOR: code cleanup for `VOut` inconsistent naming (#8907)

[boyang]

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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new a4b923f  MINOR: code cleanup for `VOut` inconsistent naming (#8907)
a4b923f is described below

commit a4b923f76f8d4557f353c8ceb98d2366cfcd86ae
Author: Vito Jeng <v...@purple.tw>
AuthorDate: Sat Jul 25 23:54:35 2020 +0800

    MINOR: code cleanup for `VOut` inconsistent naming (#8907)
    
    Consistently using VOut instead of Vout for Streams group API.
    
    Reviewers: Boyang Chen <boy...@confluent.io>
---
 .../main/java/org/apache/kafka/streams/kstream/KGroupedStream.java    | 4 ++--
 .../apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java 
b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java
index a17d88b..56faea0 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java
@@ -549,9 +549,9 @@ public interface KGroupedStream<K, V> {
      * is passed into {@link CogroupedKStream#aggregate(Initializer)}) and the 
record's value.
      *
      * @param aggregator an {@link Aggregator} that computes a new aggregate 
result
-     * @param <Vout> the type of the output values
+     * @param <VOut> the type of the output values
      * @return a {@link CogroupedKStream}
      */
-    <Vout> CogroupedKStream<K, Vout> cogroup(final Aggregator<? super K, ? 
super V, Vout> aggregator);
+    <VOut> CogroupedKStream<K, VOut> cogroup(final Aggregator<? super K, ? 
super V, VOut> aggregator);
 
 }
diff --git 
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java
 
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java
index c0ad172..f8061ca 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java
@@ -230,9 +230,9 @@ class KGroupedStreamImpl<K, V> extends AbstractStream<K, V> 
implements KGroupedS
     }
 
     @Override
-    public <Vout> CogroupedKStream<K, Vout> cogroup(final Aggregator<? super 
K, ? super V, Vout> aggregator) {
+    public <VOut> CogroupedKStream<K, VOut> cogroup(final Aggregator<? super 
K, ? super V, VOut> aggregator) {
         Objects.requireNonNull(aggregator, "aggregator can't be null");
-        return new CogroupedKStreamImpl<K, Vout>(name, subTopologySourceNodes, 
streamsGraphNode, builder)
+        return new CogroupedKStreamImpl<K, VOut>(name, subTopologySourceNodes, 
streamsGraphNode, builder)
             .cogroup(this, aggregator);
     }
 }