[ISSUE #82]Add doc and shell script

.gitignore

@@ -16,6 +16,7 @@ target/
 *.iml
 *.ipr
 *.gz
+*.zip
 
 
 ### NetBeans ###

README.md

@@ -1,13 +1,92 @@
-## Local Deploy
-* Install RocketMQ 5.0, [quick start](https://rocketmq.apache.org/zh/docs/quickStart/02quickstart);
-* Clone and install RocketMQ Streams 1.1.1-SNAPSHOT(develop branch in [RocketMQ Streams](https://github.com/apache/rocketmq-streams) repository)
-* Compile antlr4 to source code:
+## RSQLDB
+
+The database build for stream processing.
+
+
+## Overview
+
+RSQLDB is a database for stream processing build on the of RocketMQ. It is distributed, highly available，scalable. SQL can be used to define a stream processing task, and
+RSQLDB parse it into a stream-processing task. RSQLDB offers the fellow core features:
+
+- Restful API - create, query, stop, stream-processing tasks;
+- Standard SQL - describe the stream processing task with standard sql;
+- Materialized views - incremental calculation on the of stream;
+
+
+## Deploy
+
+### Run RocketMQ 5.0 locally
+
+Steps are as follows:
+- **Install Java**
+
+- **Download RocketMQ**
+
+- **Start NameServer**
+
+- **Start Broker**
+
+More details can be obtained at [quick start](https://rocketmq.apache.org/zh/docs/quickStart/02quickstart);
+
+
+### Run RSQLDB
+
+#### From source code:
+
+- Git clone and compile
 ```shell
+git clone git@github.com:alibaba/rsqldb.git
+
+#compile antlr4 file to source code:
 mvn clean compile -DskipTests
 ```
 * Run the entrance method:
 ```java
   com.alibaba.rsqldb.rest.Application
 ````
 
+#### From distribution package
+- Download distribution package
+- Unzip package
+```shell
+unzip rsqldb-distribution.zip
+```
+- Start rsqldb
+```shell
+cd rsqldb && sh bin/start.sh
+```
+
+## Use Cases and Examples
+
+### Filter
+
+```shell
+select *
+from sourceTable where age>20 and name like '%mack';
+```
+
+
+### Join
+
+```shell
+SELECT Websites.name as `count`, Websites.url as url, SUM(access_log.count) AS nums 
+FROM access_log 
+WHERE access_log.`count` > 100
+INNER JOIN Websites ON access_log.site_id=Websites.id and access_log.url=Websites.url
+```
+
+### Window
+
+```sql
+select 
+TUMBLE_START(ts, INTERVAL '5' SECOND)       AS window_start,
+TUMBLE_END(ts, INTERVAL '5' SECOND)         AS window_end,
+position                                    AS position,
+sum(num)                                    AS sumNum
+from  sourceTable
+where num > 5
+group by TUMBLE(ts, INTERVAL '5' SECOND), position
+having sum(num) < 20;
+```
 
+- More examples can be found [here](docs/sql_example.md).

distribution/bin/start.sh

@@ -0,0 +1,48 @@
+#!/bin/sh
+
+binDir=$(cd `dirname $0`;pwd)
+echo "binDir=$binDir"
+
+cd $binDir/..
+homeDir=$(pwd)
+echo "homeDir=$homeDir"
+cd $homeDir
+
+confPath=$homeDir/conf/rsqldb.conf
+if [ ! -z "$1" ]; then
+  confPath=$1
+fi
+echo "confPath=$confPath"
+
+if [ ! -d log ]; then
+  mkdir log
+fi
+
+[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
+[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
+[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"
+
+export JAVA_HOME
+export JAVA="$JAVA_HOME/bin/java"
+export BASE_DIR=$(dirname $0)/..
+export CLASSPATH=.:${BASE_DIR}/conf:${BASE_DIR}/server/*
+
+JVM_CONFIG="-Xms512m -Xmx512m -Xmn128m"
+
+JAVA_OPTIONS=${JAVA_OPTIONS:-}
+
+JVM_OPTS=()
+if [ ! -z "${JAVA_OPTIONS}" ]; then
+  JVM_OPTS+=("${JAVA_OPTIONS}")
+fi
+
+if [ ! -z "${JVM_CONFIG}" ]; then
+  JVM_OPTS+=("${JVM_CONFIG}")
+fi
+
+JVM_OPTS="${JVM_OPTS} -cp ${CLASSPATH}"
+
+nohup $JAVA ${JVM_OPTS} -jar $homeDir/server/rsqldb.jar $confPath > /dev/null 2>&1 &
+
+echo "start server success."
+

distribution/bin/stop.sh

@@ -0,0 +1,16 @@
+#!/bin/bash
+
+function_error_exit ()
+{
+    echo "ERROR: $1 !!"
+    exit 1
+}
+
+stop()
+{
+    STR=`ps -ef | grep java | grep -- "rsqldb.jar"`
+    [ -z "$STR" ] && return
+    kill `ps -ef | grep java | grep -- "rsqldb.jar" | awk '{print $2}'`
+}
+
+stop

distribution/distribution.xml

@@ -17,14 +17,20 @@ limitations under the License.
 <assembly>
     <id>distribution</id>
     <formats>
-        <format>tar.gz</format>
+        <format>zip</format>
     </formats>
     <fileSets>
         <fileSet>
             <fileMode>0775</fileMode>
             <directory>conf</directory>
             <outputDirectory>/conf</outputDirectory>
         </fileSet>
+
+        <fileSet>
+            <fileMode>0775</fileMode>
+            <directory>bin</directory>
+            <outputDirectory>/bin</outputDirectory>
+        </fileSet>
     </fileSets>
     <files>
         <file>

distribution/pom.xml

@@ -49,7 +49,7 @@
                         </goals>
                         <configuration>
                             <target>
-                                <copy file="${project.build.directory}/rsqldb-distribution.tar.gz" tofile="${project.basedir}/rsqldb-distribution.tar.gz" overwrite="true" />
+                                <copy file="${project.build.directory}/rsqldb-distribution.zip" tofile="${project.basedir}/rsqldb-distribution.zip" overwrite="true" />
                             </target>
                         </configuration>
                     </execution>

rsqldb-parser/src/main/java/com/alibaba/rsqldb/parser/model/statement/query/join/JointStatement.java

@@ -204,7 +204,8 @@ protected RStream<JsonNode> join(RStream<JsonNode> leftStream, RStream<JsonNode>
                     }
 
                     return result;
-                }).apply((value1, value2) -> {
+                }).window(WindowBuilder.tumblingWindow(Time.seconds(10)))
+                .apply((value1, value2) -> {
                     ObjectNode objectNode = JsonNodeFactory.instance.objectNode();
                     //新建临时表