Repository: samza Updated Branches: refs/heads/master 91e54568b -> 18b940134
Minor instruction changes Author: [email protected] <[email protected]> Reviewers: Prateek Maheshwari <[email protected]> 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: [email protected] <[email protected]> Authored: Tue Oct 23 10:31:20 2018 -0700 Committer: Prateek Maheshwari <[email protected]> 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 %}
