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/12/21 17:38:56 UTC
kafka git commit: MINOR: KStream JavaDoc fix
Repository: kafka
Updated Branches:
refs/heads/trunk fc88bac66 -> baab43f0d
MINOR: KStream JavaDoc fix
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Guozhang Wang <wa...@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 <ma...@confluent.io>
Authored: Wed Dec 21 09:38:52 2016 -0800
Committer: Guozhang Wang <wa...@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);