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 2018/10/23 17:31:24 UTC
samza git commit: Minor instruction changes
Repository: samza
Updated Branches:
refs/heads/master 91e54568b -> 18b940134
Minor instruction changes
Author: rmatharu@linkedin.com <rm...@linkedin.com>
Reviewers: Prateek Maheshwari <pm...@apache.org>
Closes #758 from rmatharu/doc
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/18b94013
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/18b94013
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/18b94013
Branch: refs/heads/master
Commit: 18b94013428a8efb7642b3fa4dfee2b2f317e913
Parents: 91e5456
Author: rmatharu@linkedin.com <rm...@linkedin.com>
Authored: Tue Oct 23 10:31:20 2018 -0700
Committer: Prateek Maheshwari <pm...@apache.org>
Committed: Tue Oct 23 10:31:20 2018 -0700
----------------------------------------------------------------------
docs/learn/documentation/versioned/api/samza-sql.md | 2 +-
docs/learn/tutorials/versioned/samza-sql.md | 2 +-
docs/learn/tutorials/versioned/samza-tools.md | 6 +-----
3 files changed, 3 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/18b94013/docs/learn/documentation/versioned/api/samza-sql.md
----------------------------------------------------------------------
diff --git a/docs/learn/documentation/versioned/api/samza-sql.md b/docs/learn/documentation/versioned/api/samza-sql.md
index 769b7ec..13b059f 100644
--- a/docs/learn/documentation/versioned/api/samza-sql.md
+++ b/docs/learn/documentation/versioned/api/samza-sql.md
@@ -47,7 +47,7 @@ Please follow the instructions from the [Kafka quickstart](http://kafka.apache.o
The below sql statements require a topic named ProfileChangeStream to be created on the Kafka broker. You can follow the instructions in the Kafka quick start guide to create a topic named “ProfileChangeStream”.
```bash
->./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ProfileChangeStream
+>./deploy/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ProfileChangeStream
```
## Generate events into ProfileChangeStream topic
http://git-wip-us.apache.org/repos/asf/samza/blob/18b94013/docs/learn/tutorials/versioned/samza-sql.md
----------------------------------------------------------------------
diff --git a/docs/learn/tutorials/versioned/samza-sql.md b/docs/learn/tutorials/versioned/samza-sql.md
index fa79a1b..f64aa06 100644
--- a/docs/learn/tutorials/versioned/samza-sql.md
+++ b/docs/learn/tutorials/versioned/samza-sql.md
@@ -38,7 +38,7 @@ Please follow the instructions from the [Kafka quickstart](http://kafka.apache.o
The below sql statements requires a topic named ProfileChangeStream to be created on the Kafka broker. You can follow the instructions in the [Kafka quick start guide](http://kafka.apache.org/quickstart) to create a topic named "ProfileChangeStream".
{% highlight bash %}
-./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ProfileChangeStream
+./deploy/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ProfileChangeStream
{% endhighlight %}
## Generate events into ProfileChangeStream topic
http://git-wip-us.apache.org/repos/asf/samza/blob/18b94013/docs/learn/tutorials/versioned/samza-tools.md
----------------------------------------------------------------------
diff --git a/docs/learn/tutorials/versioned/samza-tools.md b/docs/learn/tutorials/versioned/samza-tools.md
index 6e4ee71..a249b03 100644
--- a/docs/learn/tutorials/versioned/samza-tools.md
+++ b/docs/learn/tutorials/versioned/samza-tools.md
@@ -94,16 +94,12 @@ usage: Error: One of the (f or s) options needs to be set
samza-sql-console.sh
-f,--file <SQL_FILE> Path to the SQL file to execute.
-s,--sql <SQL_STMT> SQL statement to execute.
-
-# Example command to filter out all the users who have moved to LinkedIn
-
-./scripts/samza-sql-console.sh --sql "Insert into log.consoleOutput select Name, OldCompany from kafka.ProfileChangeStream where NewCompany = 'LinkedIn'"
-
{% endhighlight %}
You can run below sql commands using Samza sql console. Please make sure you are running generate-kafka-events tool to generate events into ProfileChangeStream before running the below command.
{% highlight bash %}
+# Example command to filter out all the users who have moved to LinkedIn
./scripts/samza-sql-console.sh --sql "Insert into log.consoleOutput select Name, OldCompany from kafka.ProfileChangeStream where NewCompany = 'LinkedIn'"
{% endhighlight %}