You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by bo...@apache.org on 2020/07/25 15:55:05 UTC
[kafka] branch trunk updated: MINOR: code cleanup for `VOut`
inconsistent naming (#8907)
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 <vi...@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 <bo...@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);
}
}