You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2019/05/30 18:42:37 UTC
[samza] branch master updated: [TYPO] Fix typos in async
documentation
This is an automated email from the ASF dual-hosted git repository.
pmaheshwari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new bd647bb [TYPO] Fix typos in async documentation
bd647bb is described below
commit bd647bb152f981f3fe32a1ee3914ae8852cdb1ab
Author: mynameborat <bh...@gmail.com>
AuthorDate: Thu May 30 11:42:31 2019 -0700
[TYPO] Fix typos in async documentation
Author: mynameborat <bh...@gmail.com>
Reviewers: Prateek Maheshwari <pm...@apache.org>
Closes #1056 from mynameborat/async-doc-typo-fix
---
docs/learn/documentation/versioned/api/high-level-api.md | 2 +-
docs/learn/tutorials/versioned/samza-async-user-guide.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/learn/documentation/versioned/api/high-level-api.md b/docs/learn/documentation/versioned/api/high-level-api.md
index 53cac8c..18ed44a 100644
--- a/docs/learn/documentation/versioned/api/high-level-api.md
+++ b/docs/learn/documentation/versioned/api/high-level-api.md
@@ -151,7 +151,7 @@ Applies the provided 1:n [AsyncFlatMapFunction](javadocs/org/apache/samza/operat
RestClient restClient = ...
MessageStream<String> words = ...
// Transform each incoming word into its meaning using a dictionary look up service
- MessageStream<String> meanings = words.asynFlatMap(word -> {
+ MessageStream<String> meanings = words.asyncFlatMap(word -> {
// Builds a look up request to the dictionary service
Request<String> dictionaryRequest = buildDictionaryRequest(word);
CompletableFuture<DictionaryResponse> dictionaryResponseFuture = restClient.sendRequest(dictionaryRequest);
diff --git a/docs/learn/tutorials/versioned/samza-async-user-guide.md b/docs/learn/tutorials/versioned/samza-async-user-guide.md
index 70c9204..5c0149c 100644
--- a/docs/learn/tutorials/versioned/samza-async-user-guide.md
+++ b/docs/learn/tutorials/versioned/samza-async-user-guide.md
@@ -175,7 +175,7 @@ If IO library accepts callbacks instead of returning a Future, the callback can
CompletableFuture<Collection<StandardizedWikipediaFeedEvent>> standardizedFuture = new CompletableFuture<>();
client.async().get(standardizationRequest, new InvocationCallback<Response>() {
@Override
- public void completed(ResStandardizerResponseponse response) {
+ public void completed(StandardizerResponse response) {
standardizedFuture.complete(extractStandardizedWikipediaFeedEvent(response));
}