add error performance fql

Author: camilesing

docs/performance/error/complexed_1.fql

@@ -0,0 +1,72 @@
+CREATE TEMPORARY VIEW temp_view AS
+select
+  e.application_id as id,
+  e.main_id as main_id,
+  (
+    case
+      when r.province = 'Hongkong' then '22.27747'
+      WHEN r.province = 'Macao' then '22.16252'
+      WHEN r.province = 'Taiwan' then '25.04573'
+      ELSE -- expect error
+    END
+  ) as lat,
+  (
+    case
+      when r.province = 'Hongkong' then '114.1712'
+      WHEN r.province = 'Macao' then '113.5838'
+      WHEN r.province = 'Taiwan' then '121.5117'
+      ELSE m.lng
+    END
+  ) as lng,
+  (
+    case
+      when r.province = 'Hongkong' then 'HK'
+      WHEN r.province = 'Macao' then 'MO'
+      WHEN r.province = 'Taiwan' then 'TW'
+      ELSE r.areacode
+    END
+  ) as region,
+  count(distinct e.s_id) filter (
+    where
+      TIMESTAMPDIFF(MINUTE, e.rowtime, LOCALTIMESTAMP) <= 10
+  ) as uv,
+  count(e.s_id) filter (
+    where
+      TIMESTAMPDIFF(MINUTE, e.rowtime, LOCALTIMESTAMP) <= 10
+  ) as pv,
+  HOP_END(e.proctime, INTERVAL '10' SECOND, INTERVAL '10' MINUTE) as dt
+from
+  filter_uv e
+  left join lookup_ip_info FOR SYSTEM_TIME AS OF e.proctime as r on e.ip = r.ip
+  left join lookup_international_location FOR SYSTEM_TIME AS OF e.proctime as m on m.code = r.areacode
+where
+  TIMESTAMPDIFF(MINUTE, e.rowtime, LOCALTIMESTAMP) <= 10
+group by
+  e.application_id,
+  e.main_id,
+  (
+    case
+      when r.province = 'Hongkong' then '22.27747'
+      WHEN r.province = 'Macao' then '22.16252'
+      WHEN r.province = 'Taiwan' then '25.04573'
+      ELSE m.lat
+    END
+  ),
+  (
+    case
+      when r.province = 'Hongkong' then '114.1712'
+      WHEN r.province = 'Macao' then '113.5838'
+      WHEN r.province = 'Taiwan' then '121.5117'
+      ELSE m.lng
+    END
+  ),
+  r.areacode,
+  (
+    case
+      when r.province = 'Hongkong' then 'HK'
+      WHEN r.province = 'Macao' then 'MO'
+      WHEN r.province = 'Taiwan' then 'TW'
+      ELSE r.areacode
+    END
+  ),
+  HOP(e.proctime, INTERVAL '10' SECOND, INTERVAL '10' MINUTE);

docs/performance/error/create_database.fql

@@ -0,0 +1,3 @@
+CREATE DATABASE my_dwv;
+
+use my_dwv --expect error

docs/performance/error/create_tmp_view.fql

@@ -0,0 +1,27 @@
+CREATE TEMPORARY VIEW tmp_view AS
+SELECT
+  *
+FROM
+  (
+    SELECT
+      *,
+      ROW_NUMBER() OVER (
+        PARTITION  FLOOR( --miss 'BY' 
+          TO_TIMESTAMP(
+            FROM_UNIXTIME(event_time / 1000, 'yyyy-MM-dd HH:mm:ss')
+          ) TO HOUR
+        ),
+        event_time,
+        order_seq,
+        sku_id,
+        is_offline
+        ORDER
+          BY proctime DESC
+      ) AS rownum
+    FROM
+      source_trade_order_fht
+    WHERE
+      is_offline = 0
+  )
+WHERE
+  rownum = 1;

docs/performance/error/select.fql

@@ -0,0 +1,58 @@
+CREATE TEMPORARY VIEW tmp_view AS
+select
+  name as row_key,
+  cast(id as BIGINT) as id,
+  count(1) filter (
+    where
+      (
+        event_no not in (
+          '54126212',
+          '54126213',
+          '54126214',
+          '54126215',
+          '54126216',
+          '54126217'
+        )
+        AND event_no = '101'
+      )
+  ) as f1,
+  count(1) filter (
+    where
+      (
+        event_no <> '60079992'
+        or event_name <> '138'
+      )
+  ) as f2,
+  count(1) filter (
+    where
+     event_name = 'trigger'
+  ) as f3,
+  sum(1) filter (
+    where
+      visit_type = 'look'
+      and (
+        event_no <> '54126210'
+        or event_name = 'trigger2'
+      )
+  ) as f4,
+  count(distinct name) filter (
+    where
+      TIMESTAMPDIFF(MINUTE, rowtime, LOCALTIMESTAMP) <= 10
+      and  event_no <> '54126211'
+  ) as f5,
+  (
+    case
+      when country = 'China' then 8
+      when country = 'US' then 20
+      ELSE 0
+    END
+  ) as timezone,
+  FLOOR(rowtime TO MINUTE as dt, -- miss )
+  PROCTIME() as proctime
+from
+  source_table
+where
+  create_timestamp is not null
+group by
+  id,
+  name;

docs/performance/error/select_array.fql

@@ -0,0 +1,12 @@
+insert into
+  table1
+select
+  ARRAY [ ROW(
+    f1,
+    f2,
+    f3,
+    f4,
+    f5, -- expect error
+  )]  as message
+from
+  source_table;