kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR:Fix typo in the impl source (#4587)
Date Mon, 26 Feb 2018 20:26:01 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang 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 7c5d0c4  MINOR:Fix typo in the impl source (#4587)
7c5d0c4 is described below

commit 7c5d0c459f1d4a8796e3b5af925f40fd4f8a69fa
Author: Blake Miller <blak3mill3r@gmail.com>
AuthorDate: Mon Feb 26 20:25:53 2018 +0000

    MINOR:Fix typo in the impl source (#4587)
    
    The static method KStreamImpl.createReparitionedSource() is missing a t.
    
    This PR globally fixes the typo and keeps the code indentation consistent.
---
 .../kstream/internals/GroupedStreamAggregateBuilder.java     |  2 +-
 .../kafka/streams/kstream/internals/KGroupedStreamImpl.java  |  2 +-
 .../apache/kafka/streams/kstream/internals/KStreamImpl.java  | 12 ++++++------
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java
index e4429cc..24ed8a0 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java
@@ -86,6 +86,6 @@ class GroupedStreamAggregateBuilder<K, V> {
         if (!repartitionRequired) {
             return this.name;
         }
-        return KStreamImpl.createReparitionedSource(builder, keySerde, valueSerde, queryableStoreName,
name);
+        return KStreamImpl.createRepartitionedSource(builder, keySerde, valueSerde, queryableStoreName,
name);
     }
 }
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 45ae7da..82e2823 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
@@ -519,6 +519,6 @@ class KGroupedStreamImpl<K, V> extends AbstractStream<K> implements
KGroupedStre
         if (!repartitionRequired) {
             return this.name;
         }
-        return KStreamImpl.createReparitionedSource(builder, keySerde, valSerde, queryableStoreName,
name);
+        return KStreamImpl.createRepartitionedSource(builder, keySerde, valSerde, queryableStoreName,
name);
     }
 }
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
index 8aaab49..141bbbb 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
@@ -653,16 +653,16 @@ public class KStreamImpl<K, V> extends AbstractStream<K>
implements KStream<K, V
      */
     private KStreamImpl<K, V> repartitionForJoin(final Serde<K> keySerde,
                                                  final Serde<V> valSerde) {
-        String repartitionedSourceName = createReparitionedSource(builder, keySerde, valSerde,
null, name);
+        String repartitionedSourceName = createRepartitionedSource(builder, keySerde, valSerde,
null, name);
         return new KStreamImpl<>(builder, repartitionedSourceName, Collections
             .singleton(repartitionedSourceName), false);
     }
 
-    static <K1, V1> String createReparitionedSource(final InternalStreamsBuilder builder,
-                                                    final Serde<K1> keySerde,
-                                                    final Serde<V1> valSerde,
-                                                    final String topicNamePrefix,
-                                                    final String name) {
+    static <K1, V1> String createRepartitionedSource(final InternalStreamsBuilder builder,
+                                                     final Serde<K1> keySerde,
+                                                     final Serde<V1> valSerde,
+                                                     final String topicNamePrefix,
+                                                     final String name) {
         Serializer<K1> keySerializer = keySerde != null ? keySerde.serializer() : null;
         Serializer<V1> valSerializer = valSerde != null ? valSerde.serializer() : null;
         Deserializer<K1> keyDeserializer = keySerde != null ? keySerde.deserializer()
: null;

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.

Mime
View raw message