You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/01/20 18:20:31 UTC
storm git commit: fix broken links & package name in storm-sql docs
Repository: storm
Updated Branches:
refs/heads/asf-site 3590e2ee2 -> 9c20804c4
fix broken links & package name in storm-sql docs
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9c20804c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9c20804c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9c20804c
Branch: refs/heads/asf-site
Commit: 9c20804c410b18ed0ff59fbe56a68332bc73098e
Parents: 3590e2e
Author: Xin Wang <be...@163.com>
Authored: Sat Jan 16 17:55:32 2016 +0800
Committer: vesense <be...@163.com>
Committed: Wed Jan 20 09:53:47 2016 +0800
----------------------------------------------------------------------
documentation/storm-sql-internal.md | 2 +-
documentation/storm-sql.md | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9c20804c/documentation/storm-sql-internal.md
----------------------------------------------------------------------
diff --git a/documentation/storm-sql-internal.md b/documentation/storm-sql-internal.md
index 05ca1a9..08969c6 100644
--- a/documentation/storm-sql-internal.md
+++ b/documentation/storm-sql-internal.md
@@ -48,7 +48,7 @@ There are several constraints when querying tables that represent a real-time da
* The `ORDER BY` clause cannot be applied to a stream.
* There is at least one monotonic field in the `GROUP BY` clauses to allow StormSQL bounds the size of the buffer.
-For more information please refer to https://calcite.incubator.apache.org/docs/stream.html.
+For more information please refer to http://calcite.apache.org/docs/stream.html.
## Dependency
http://git-wip-us.apache.org/repos/asf/storm/blob/9c20804c/documentation/storm-sql.md
----------------------------------------------------------------------
diff --git a/documentation/storm-sql.md b/documentation/storm-sql.md
index 72dc776..fd28cb2 100644
--- a/documentation/storm-sql.md
+++ b/documentation/storm-sql.md
@@ -45,7 +45,7 @@ CREATE EXTERNAL TABLE table_name field_list
You can find detailed explanations of the properties in [Hive Data Definition Language](https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL). For example, the following statement specifies a Kafka spouts and sink:
```
-CREATE EXTERNAL TABLE FOO (ID INT PRIMARY KEY) LOCATION 'kafka://localhost:2181/brokers?topic=test' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"storm.kafka.IntSerializer","value.serializer":"storm.kafka.ByteBufferSerializer"}}'
+CREATE EXTERNAL TABLE FOO (ID INT PRIMARY KEY) LOCATION 'kafka://localhost:2181/brokers?topic=test' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"org.apache.storm.kafka.IntSerializer","value.serializer":"org.apache.storm.kafka.ByteBufferSerializer"}}'
```
## Plugging in External Data Sources
@@ -59,12 +59,12 @@ Let's say there is a Kafka stream that represents the transactions of orders. Ea
The user can specify the following SQL statements in the SQL file:
```
-CREATE EXTERNAL TABLE ORDERS (ID INT PRIMARY KEY, UNIT_PRICE INT, QUANTITY INT) LOCATION 'kafka://localhost:2181/brokers?topic=orders' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"storm.kafka.IntSerializer","value.serializer":"storm.kafka.ByteBufferSerializer"}}'
-CREATE EXTERNAL TABLE LARGE_ORDERS (ID INT PRIMARY KEY, TOTAL INT) LOCATION 'kafka://localhost:2181/brokers?topic=large_orders' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"storm.kafka.IntSerializer","value.serializer":"storm.kafka.ByteBufferSerializer"}}'
+CREATE EXTERNAL TABLE ORDERS (ID INT PRIMARY KEY, UNIT_PRICE INT, QUANTITY INT) LOCATION 'kafka://localhost:2181/brokers?topic=orders' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"org.apache.storm.kafka.IntSerializer","value.serializer":"org.apache.storm.kafka.ByteBufferSerializer"}}'
+CREATE EXTERNAL TABLE LARGE_ORDERS (ID INT PRIMARY KEY, TOTAL INT) LOCATION 'kafka://localhost:2181/brokers?topic=large_orders' TBLPROPERTIES '{"producer":{"bootstrap.servers":"localhost:9092","acks":"1","key.serializer":"org.apache.storm.kafka.IntSerializer","value.serializer":"org.apache.storm.kafka.ByteBufferSerializer"}}'
INSERT INTO LARGE_ORDERS SELECT ID, UNIT_PRICE * QUANTITY AS TOTAL FROM ORDERS WHERE UNIT_PRICE * QUANTITY > 50
```
-The first statement defines the table `ORDER` which represents the input stream. The `LOCATION` clause specifies the ZkHost (`localhost:2181`), the path of the brokers in ZooKeeper (`/brokers`) and the topic (`orders`). The `TBLPROPERTIES` clause specifies the configuration of [KafkaProducer](http://kafka.apache.org/documentation.html#newproducerconfigs).
+The first statement defines the table `ORDER` which represents the input stream. The `LOCATION` clause specifies the ZkHost (`localhost:2181`), the path of the brokers in ZooKeeper (`/brokers`) and the topic (`orders`). The `TBLPROPERTIES` clause specifies the configuration of [KafkaProducer](http://kafka.apache.org/documentation.html#producerconfigs).
Current implementation of `storm-sql-kafka` requires specifying both `LOCATION` and `TBLPROPERTIES` clauses even though the table is read-only or write-only.
Similarly, the second statement specifies the table `LARGE_ORDERS` which represents the output stream. The third statement is a `SELECT` statement which defines the topology: it instructs StormSQL to filter all orders in the external table `ORDERS`, calculates the total price and inserts matching records into the Kafka stream specified by `LARGE_ORDER`.