You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/02/26 20:26:01 UTC
[kafka] branch trunk updated: MINOR:Fix typo in the impl source
(#4587)
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 <bl...@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.