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: KStream JavaDoc fix
Date Wed, 21 Dec 2016 17:38:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk fc88bac66 -> baab43f0d


MINOR: KStream JavaDoc fix

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #2284 from mjsax/javaDoc


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

Branch: refs/heads/trunk
Commit: baab43f0d218e743693a933c0d6c44c428ebfc93
Parents: fc88bac
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Wed Dec 21 09:38:52 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Dec 21 09:38:52 2016 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/streams/kstream/KStream.java    | 15 ++++++---------
 1 file changed, 6 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/baab43f0/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
index f5ad24c..0686be2 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
@@ -559,12 +559,11 @@ public interface KStream<K, V> {
      * In order to assign a state, the state must be created and registered beforehand:
      * <pre>{@code
      * // create store
-     * StateStore myStore = Stores.create("myTransformState")
+     * StateStoreSupplier myStore = Stores.create("myTransformState")
      *     .withKeys(...)
      *     .withValues(...)
      *     .persistent() // optional
-     *     .build()
-     *     .get();
+     *     .build();
      *
      * // register store
      * builder.addStore(myStore);
@@ -639,12 +638,11 @@ public interface KStream<K, V> {
      * In order to assign a state, the state must be created and registered beforehand:
      * <pre>{@code
      * // create store
-     * StateStore myStore = Stores.create("myValueTransformState")
+     * StateStoreSupplier myStore = Stores.create("myValueTransformState")
      *     .withKeys(...)
      *     .withValues(...)
      *     .persistent() // optional
-     *     .build()
-     *     .get();
+     *     .build();
      *
      * // register store
      * builder.addStore(myStore);
@@ -714,12 +712,11 @@ public interface KStream<K, V> {
      * In order to assign a state, the state must be created and registered beforehand:
      * <pre>{@code
      * // create store
-     * StateStore myStore = Stores.create("myProcessorState")
+     * StateStoreSupplier myStore = Stores.create("myProcessorState")
      *     .withKeys(...)
      *     .withValues(...)
      *     .persistent() // optional
-     *     .build()
-     *     .get();
+     *     .build();
      *
      * // register store
      * builder.addStore(myStore);


Mime
View raw message