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