THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
After the proposal is finished, the above user cases will work smoothly. Assume users' local time zone is UTC+8, the wall-clock is 2020-12-29 07:52:52.
- user case 1 :
| Code Block | ||
|---|---|---|
| ||
Flink SQL> SELECT NOW(), PROCTIME(), CURRENT_TIMESTAMP, CURRENT_DATE, CURRENT_TIME; -- output: +-------------------------+-------------------------+-------------------------+--------------+--------------+ | NOW() | PROCTIME() | CURRENT_TIMESTAMP | CURRENT_DATE | CURRENT_TIME | +-------------------------+-------------------------+-------------------------+--------------+--------------+ | 2020-12-29T07:52:52 | 2020-12-29T07:52:52 | 2020-12-29T07:52:52 | 2020-12-29 | 07:52:52.236 | +-------------------------+-------------------------+-------------------------+--------------+--------------+ |
- user case 2
SELECT
- :
| Code Block | ||
|---|---|---|
| ||
Flink SQL> SELECT TUMBLE |
...
_START(proctime, INTERVAL ‘1’ DAY), |
...
> TUMBLE_END(proctime, INTERVAL ‘1’ |
...
count(userId) as cnt
FROM userLog
...
DAY), > count(userId) as cnt > FROM userLog > GROUP BY TUMBLE_WINDOW(proctime, INTERVAL ‘1’ DAY) |
...
;
-- output:
+-------------------------+-------------------------+-------------------------+
| TUMBLE_START | TUMBLE_END | count(userId) |
+-------------------------+-------------------------+-------------------------+
| 2020-12-29T00:00:00 | 2020-12-30T00:00:00 | 100 |
+-------------------------+-------------------------+-------------------------+
|
- user case 3:
| Code Block | ||
|---|---|---|
| ||
Flink SQL> SELECT *
> FROM userLog
> WHERE date >= CURRENT_DATE;
-- in the query, records earlier than 2020-12-29 will not be output.
+-------------------------+-------------------------+-------------------------+
| date | log_ts | user |
+-------------------------+-------------------------+-------------------------+
| 2020-12-29 | 2020-12-29T00:00:00 | Alice |
+-------------------------+-------------------------+-------------------------+
| 2020-12-29 | 2020-12-29T00:00:01 | Bob |
+-------------------------+-------------------------+-------------------------+
| 2020-12-29 | 2020-12-29T00:00:02 | Tom |
+-------------------------+-------------------------+-------------------------+
|
will output:
| 2020-12-29 00:00:00 | 2020-12-30 00:00:00 | 100|
- user case 3: int the query
SELECT * FROM userLog where date >= CURRENT_DATE |
...