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 2016/03/03 08:42:21 UTC
kafka git commit: HOTFIX: Fix checkstyle failure in KStreams by
providing fully qualified class names.
Repository: kafka
Updated Branches:
refs/heads/trunk 00a58f8e1 -> b9eda22d7
HOTFIX: Fix checkstyle failure in KStreams by providing fully qualified class names.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #1000 from ewencp/hotfix-kstreams-checkstyle-javadocs
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b9eda22d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b9eda22d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b9eda22d
Branch: refs/heads/trunk
Commit: b9eda22d71aa9896cac90798c7e888a04f14549d
Parents: 00a58f8
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Authored: Wed Mar 2 23:42:17 2016 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Mar 2 23:42:17 2016 -0800
----------------------------------------------------------------------
.../main/java/org/apache/kafka/streams/kstream/Windowed.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/b9eda22d/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java
index 22d52aa..eed5fe1 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java
@@ -17,12 +17,11 @@
package org.apache.kafka.streams.kstream;
-import org.apache.kafka.common.serialization.Deserializer;
-import org.apache.kafka.common.serialization.Serializer;
-
/**
* The windowed key interface used in {@link KTable}, used for representing a windowed table result from windowed stream aggregations,
- * i.e. {@link KStream#aggregateByKey(Initializer, Aggregator, Windows, Serializer, Serializer, Deserializer, Deserializer)}
+ * i.e. {@link KStream#aggregateByKey(Initializer, Aggregator, Windows, org.apache.kafka.common.serialization.Serializer,
+ * org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Deserializer,
+ * org.apache.kafka.common.serialization.Deserializer)}
*
* @param <T> Type of the key
*/