Browse Source

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.
pull/4622/merge
Blake Miller 7 years ago committed by Guozhang Wang
parent
commit
7c5d0c459f
  1. 2
      streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java
  2. 2
      streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java
  3. 12
      streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java

2
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java

@ -86,6 +86,6 @@ class GroupedStreamAggregateBuilder<K, V> { @@ -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);
}
}

2
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 @@ -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);
}
}

12
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 @@ -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;

Loading…
Cancel
Save