From 6b9c58a5bea57148f992b2a481189fac9bcd4db6 Mon Sep 17 00:00:00 2001 From: Hojjat Jafarpour Date: Mon, 18 Dec 2017 15:00:54 -0800 Subject: [PATCH 1/4] Fixed minor style issues in the docs. --- docs/quickstart/README.md | 13 ++++++------- docs/quickstart/docker-compose.yml | 8 ++++---- 2 files changed, 10 insertions(+), 11 deletions(-) diff --git a/docs/quickstart/README.md b/docs/quickstart/README.md index c6e483867070..e24abacc82d1 100644 --- a/docs/quickstart/README.md +++ b/docs/quickstart/README.md @@ -80,8 +80,7 @@ Before proceeding, please check: 2. Create a TABLE `users_original` from the Kafka topic `users`, specifying the `value_format` of `JSON`. Describe the new TABLE. ```bash - ksql> CREATE TABLE users_original (registertime bigint, gender varchar, regionid varchar, - userid varchar) WITH (kafka_topic='users', value_format='JSON', key = 'userid'); + ksql> CREATE TABLE users_original (registertime bigint, gender varchar, regionid varchar, userid varchar) WITH (kafka_topic='users', value_format='JSON', key = 'userid'); ksql> DESCRIBE users_original; @@ -196,11 +195,11 @@ Before proceeding, please check: ```bash ksql> SHOW QUERIES; - Query ID | Kafka Topic | Query String + Query ID | Kafka Topic | Query String ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- - 1 | PAGEVIEWS_FEMALE | CREATE STREAM pageviews_female AS SELECT users_original.userid AS userid, pageid, regionid, gender FROM pageviews_original LEFT JOIN users_original ON pageviews_original.userid = users_original.userid WHERE gender = 'FEMALE'; - 2 | pageviews_enriched_r8_r9 | CREATE STREAM pageviews_female_like_89 WITH (kafka_topic='pageviews_enriched_r8_r9', value_format='DELIMITED') AS SELECT * FROM pageviews_female WHERE regionid LIKE '%_8' OR regionid LIKE '%_9'; - 3 | PAGEVIEWS_REGIONS | CREATE TABLE pageviews_regions AS SELECT gender, regionid , COUNT(*) AS numusers FROM pageviews_female WINDOW TUMBLING (size 30 second) GROUP BY gender, regionid HAVING COUNT(*) > 1; + CTAS_PAGEVIEWS_REGIONS | PAGEVIEWS_FEMALE | CREATE STREAM pageviews_female AS SELECT users_original.userid AS userid, pageid, regionid, gender FROM pageviews_original LEFT JOIN users_original ON pageviews_original.userid = users_original.userid WHERE gender = 'FEMALE'; + CSAS_PAGEVIEWS_FEMALE | pageviews_enriched_r8_r9 | CREATE STREAM pageviews_female_like_89 WITH (kafka_topic='pageviews_enriched_r8_r9', value_format='DELIMITED') AS SELECT * FROM pageviews_female WHERE regionid LIKE '%_8' OR regionid LIKE '%_9'; + CSAS_PAGEVIEWS_FEMALE_LIKE_89 | PAGEVIEWS_REGIONS | CREATE TABLE pageviews_regions AS SELECT gender, regionid , COUNT(*) AS numusers FROM pageviews_female WINDOW TUMBLING (size 30 second) GROUP BY gender, regionid HAVING COUNT(*) > 1; ``` @@ -213,7 +212,7 @@ Before proceeding, please check: 1. From the output of `SHOW QUERIES;` identify a query ID you would like to terminate. For example, if you wish to terminate query ID `2`: ```bash - ksql> TERMINATE 2; + ksql> TERMINATE CTAS_PAGEVIEWS_REGIONS; ``` 2. To exit from KSQL, type 'exit'. diff --git a/docs/quickstart/docker-compose.yml b/docs/quickstart/docker-compose.yml index edddb280cd9f..9d6cf4f8db31 100644 --- a/docs/quickstart/docker-compose.yml +++ b/docs/quickstart/docker-compose.yml @@ -38,7 +38,7 @@ services: - "moby:127.0.0.1" schema-registry: - image: "confluentinc/cp-schema-registry:latest" + image: "confluentinc/cp-schema-registry:4.0.0" hostname: schema-registry depends_on: - zookeeper @@ -53,7 +53,7 @@ services: # Runs the Kafka KSQL data generator for topic called "pageviews" ksql-datagen-pageviews: - image: "confluentinc/ksql-examples:0.2" + image: "confluentinc/ksql-examples:0.3-rc1" hostname: ksql-datagen-pageviews depends_on: - kafka @@ -83,7 +83,7 @@ services: # Runs the Kafka KSQL data generator for topic called "users" ksql-datagen-users: - image: "confluentinc/ksql-examples:0.2" + image: "confluentinc/ksql-examples:0.3-rc1" hostname: ksql-datagen-users depends_on: - kafka @@ -113,7 +113,7 @@ services: # Runs the Kafka KSQL application ksql-cli: - image: "confluentinc/ksql-cli:0.2" + image: "confluentinc/ksql-cli:0.3-rc1" hostname: ksql-cli depends_on: - kafka From 693382892d74827b43e49dcb3156c7f7b17d85f6 Mon Sep 17 00:00:00 2001 From: Hojjat Jafarpour Date: Mon, 18 Dec 2017 15:15:08 -0800 Subject: [PATCH 2/4] Removed the docker changes. --- docs/quickstart/docker-compose.yml | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/quickstart/docker-compose.yml b/docs/quickstart/docker-compose.yml index 9d6cf4f8db31..edddb280cd9f 100644 --- a/docs/quickstart/docker-compose.yml +++ b/docs/quickstart/docker-compose.yml @@ -38,7 +38,7 @@ services: - "moby:127.0.0.1" schema-registry: - image: "confluentinc/cp-schema-registry:4.0.0" + image: "confluentinc/cp-schema-registry:latest" hostname: schema-registry depends_on: - zookeeper @@ -53,7 +53,7 @@ services: # Runs the Kafka KSQL data generator for topic called "pageviews" ksql-datagen-pageviews: - image: "confluentinc/ksql-examples:0.3-rc1" + image: "confluentinc/ksql-examples:0.2" hostname: ksql-datagen-pageviews depends_on: - kafka @@ -83,7 +83,7 @@ services: # Runs the Kafka KSQL data generator for topic called "users" ksql-datagen-users: - image: "confluentinc/ksql-examples:0.3-rc1" + image: "confluentinc/ksql-examples:0.2" hostname: ksql-datagen-users depends_on: - kafka @@ -113,7 +113,7 @@ services: # Runs the Kafka KSQL application ksql-cli: - image: "confluentinc/ksql-cli:0.3-rc1" + image: "confluentinc/ksql-cli:0.2" hostname: ksql-cli depends_on: - kafka From 4394960de5c475e1be116b712a25b2c1a4df77a2 Mon Sep 17 00:00:00 2001 From: Hojjat Jafarpour Date: Mon, 18 Dec 2017 15:24:49 -0800 Subject: [PATCH 3/4] Updated datagen version. --- docs/quickstart/quickstart-non-docker.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/quickstart/quickstart-non-docker.md b/docs/quickstart/quickstart-non-docker.md index 850a88cded54..3fc4cf343469 100644 --- a/docs/quickstart/quickstart-non-docker.md +++ b/docs/quickstart/quickstart-non-docker.md @@ -77,14 +77,14 @@ Minimally, to use the [quick start exercises](/docs/quickstart#quick-start), you 1. Produce Kafka data to the `pageviews` topic using the data generator. The following example continuously generates data with a value in DELIMITED format. ```bash - $ java -jar ksql-examples/target/ksql-examples-4.0.0-SNAPSHOT-standalone.jar \ + $ java -jar ksql-examples/target/ksql-examples-4.1.0-SNAPSHOT-standalone.jar \ quickstart=pageviews format=delimited topic=pageviews maxInterval=10000 ``` 1. Produce Kafka data to the `users` topic using the data generator. The following example continuously generates data with a value in JSON format. ```bash - $ java -jar ksql-examples/target/ksql-examples-4.0.0-SNAPSHOT-standalone.jar \ + $ java -jar ksql-examples/target/ksql-examples-4.1.0-SNAPSHOT-standalone.jar \ quickstart=users format=json topic=users maxInterval=10000 ``` From d259a4254eeda3197332aec9cb299781a524570d Mon Sep 17 00:00:00 2001 From: Hojjat Jafarpour Date: Mon, 18 Dec 2017 16:42:35 -0800 Subject: [PATCH 4/4] To triger the jenkins build. Seems that'retest this please` doesn't respond. --- docs/quickstart/README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/quickstart/README.md b/docs/quickstart/README.md index e24abacc82d1..568e04e4249f 100644 --- a/docs/quickstart/README.md +++ b/docs/quickstart/README.md @@ -153,7 +153,7 @@ Before proceeding, please check: ^CQuery terminated ksql> ``` - + 4. Create a new persistent query where another condition is met, using `LIKE`. Results from this query are written to a Kafka topic called `pageviews_enriched_r8_r9`. ```bash