Apache Flink 漫谈系列 - SQL概览

执行主措施后我们会在节制台获得Sink的文件路径，如下：

Sink path : /var/folders/88/8n406qmx2z73qvrzc_rbtv_r0000gn/T/csv_sink_8025014910735142911tem 

Cat 方法查察计较功效，如下：

jinchengsunjcdeMacBook-Pro:FlinkTableApiDemo jincheng.sunjc$ cat /var/folders/88/8n406qmx2z73qvrzc_rbtv_r0000gn/T/csv_sink_8025014910735142911tem 
ShangHai,2017-11-11 02:00:00.0,2017-11-11 02:02:00.0,1 
BeiJing,2017-11-11 02:00:00.0,2017-11-11 02:02:00.0,1 
BeiJing,2017-11-11 02:10:00.0,2017-11-11 02:12:00.0,2 
ShangHai,2017-11-11 04:10:00.0,2017-11-11 04:12:00.0,1 

表格化如上功效：

上面这个端到端的完备示例也可以应用到本篇前面先容的其他算子示例中，只是各人按照Source和Sink的Schema差异来举办响应的构建即可!

十四、总结

本篇提纲的向各人先容了SQL的由来，Apache Flink SQL 大部门焦点成果，并附带了详细的测试数据和测试措施，最后以一个End-to-End的示例展示了怎样编写Apache Flink SQL的Job收尾。本篇着重向各人先容Apache Flink SQL的行使，后续我们再继承探讨每个算子的实现道理。

作者：孙金城，混名 金竹，今朝就职于阿里巴巴，自2015年以来一向投入于基于Apache Flink的阿里巴巴计较平台Blink的计划研发事变。

【本文为51CTO专栏作者“金竹”原创稿件，转载请接洽原作者】

【编辑保举】

1. Apache Flink靠什么征服阿里工程师?
2. Apache Flink 漫谈系列 - 流表对偶(duality)性
3. MySQL：缓存算什么对象？！
4. Redis：MySQL算老几？
5. Apache Flink 漫谈系列 - 一连查询(Continuous Queries)

（编辑：湖南网）

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