Repository: samza Updated Branches: refs/heads/1.0.0 cebf93c70 -> 55b3e9665
Minor instruction changes Author: [email protected] <[email protected]> Reviewers: Prateek Maheshwari <[email protected]> Closes #758 from rmatharu/doc (cherry picked from commit 18b94013428a8efb7642b3fa4dfee2b2f317e913) Signed-off-by: Prateek Maheshwari <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/55b3e966 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/55b3e966 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/55b3e966 Branch: refs/heads/1.0.0 Commit: 55b3e9665ade8e2b1b5ef8f5a237b828dee6d1e4 Parents: cebf93c 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:28 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/55b3e966/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/55b3e966/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/55b3e966/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 %}
