File tree 1 file changed +3
-1
lines changed
stream-processing/getting-started
1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ $ docker run -ti -v `pwd`/sp-samples-1k.log:/sp-samples-1k.log \
72
72
-i tail \
73
73
-p path=/sp-samples-1k.log \
74
74
-p parser=json \
75
- -p read_from_head=true \
75
+ -p read_from_head=true \
76
76
-T " SELECT word, num FROM STREAM:tail.0 WHERE country='Chile';" \
77
77
-o null -f 1
78
78
```
@@ -99,6 +99,7 @@ $ docker run -ti -v `pwd`/sp-samples-1k.log:/sp-samples-1k.log \
99
99
-i tail \
100
100
-p path=/sp-samples-1k.log \
101
101
-p parser=json \
102
+ -p read_from_head=true \
102
103
-T " SELECT AVG(num) FROM STREAM:tail.0 WHERE country='Chile';" \
103
104
-o null -f 1
104
105
```
@@ -127,6 +128,7 @@ $ docker run -ti -v `pwd`/sp-samples-1k.log:/sp-samples-1k.log \
127
128
-i tail \
128
129
-p path=/sp-samples-1k.log \
129
130
-p parser=json \
131
+ -p read_from_head=true \
130
132
-T " SELECT country, AVG(num) FROM STREAM:tail.0 \
131
133
WINDOW TUMBLING (1 SECOND) \
132
134
WHERE country='Chile' \
You can’t perform that action at this time.
0 commit comments