Apache Flink 漫谈系列(13) - Table API 概述

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

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

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

jinchengsunjcdeMacBook-Pro:FlinkTable APIDemo 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差异来举办响应的构建即可!

六、小结

本篇起首向各人先容了什么是Table API, Table API的焦点特点，然后以此先容Table API的焦点算子成果，并附带了详细的测试数据和测试措施，最后以一个End-to-End的示例展示了怎样编写Apache Flink Table API的Job收尾。但愿对各人进修Apache Flink Table API 进程中有所辅佐。

关于点赞和评述

本系列文章不免有许多缺陷和不敷，真诚但愿读者对有收成的篇章给以点赞勉励，对有不敷的篇章给以反馈和提议，先行感激各人!

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

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

戳这里，看该作者更多好文

【编辑保举】

1. Apache Flink 漫谈系列(08) - SQL概览
2. Apache Flink 漫谈系列(09) - JOIN 算子
3. Apache Flink 漫谈系列(10) - JOIN LATERAL
4. Apache Flink 漫谈系列(11) - Temporal Table JOIN
5. Apache Flink 漫谈系列(12) - Time Interval(Time-windowed) JOIN

（编辑：湖南网）

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