kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Add missing `@Override` to `KStreamImpl.through`
Date Tue, 12 Apr 2016 18:34:49 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 40fd45664 -> 319c6e719


MINOR: Add missing `@Override` to `KStreamImpl.through`

Author: Ismael Juma <ismael@juma.me.uk>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #1216 from ijuma/add-missing-override-to-through


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/319c6e71
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/319c6e71
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/319c6e71

Branch: refs/heads/trunk
Commit: 319c6e7195143c1fa4a1e5b34ad923c2b73f373d
Parents: 40fd456
Author: Ismael Juma <ismael@juma.me.uk>
Authored: Tue Apr 12 11:34:46 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Apr 12 11:34:46 2016 -0700

----------------------------------------------------------------------
 .../org/apache/kafka/streams/kstream/internals/KStreamImpl.java    | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/319c6e71/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
----------------------------------------------------------------------
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 a02cfb4..97a7aac 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
@@ -243,6 +243,8 @@ public class KStreamImpl<K, V> extends AbstractStream<K> implements
KStream<K, V
 
         topology.addProcessor(name, new KStreamForeach<>(action), this.name);
     }
+
+    @Override
     public KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde,
String topic) {
         return through(keySerde, valSerde, null, topic);
     }


Mime
View raw message