Apache Flink 漫谈系列 - 持续查询(Continuous Queries)

接下来我们把上面隐式存在的时间属性timestamp作为表flink_tab_ts(timestamp，user，clicks三列，无主键)的一列，再写一个 触发器(Trigger) 示例观察一下：

// INSERT 的时候查询一下数据flink_tab_ts，将结果写到trigger.sql中 
DELIMITER ;; 
create trigger flink_tab_ts_trigger_insert after insert 
on flink_tab_ts for each row 
begin 
select ts, user, clicks from flink_tab_ts into OUTFILE '/Users/jincheng.sunjc/testdir/atas/trigger.sql'; 
end ;; 
DELIMITER ; 

上面的trigger要将查询结果写入本地文件，默认MySQL是不允许写入的，我们查看一下：

MySQL> show variables like '%secure%'; 
+--------------------------+-------+ 
| Variable_name | Value | 
+--------------------------+-------+ 
| require_secure_transport | OFF | 
| secure_file_priv | NULL | 
+--------------------------+-------+ 
2 rows in set (0.00 sec) 

上面secure_file_priv属性为NULL，说明MySQL不允许写入file，我需要修改my.cnf在添加secure_file_priv=''打开写文件限制;

MySQL> show variables like '%secure%'; 
+--------------------------+-------+ 
| Variable_name | Value | 
+--------------------------+-------+ 
| require_secure_transport | OFF | 
| secure_file_priv | | 
+--------------------------+-------+ 
2 rows in set (0.00 sec) 

（编辑：西安站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!