大数据
flink执行sparksql 标签描述

一、TableAPI&SQL 注意:TableAPI和SQL现在还处于活跃开发阶段,还没有完全实现Flink中所有的特性。不是所有的[TableAPI,SQL]和[流,批]的组合都是支持的。 TableAPI和SQL的由来:Flink针对标准的流处理和批处理提供了两种关系型API,TableAPI和SQL。TableAPI允许用户以一种很直观的方式进行select、filter和join操作。FlinkSQL基于ApacheCalcite实现标准SQL。针对批处理和流处理可以提供相同的处理语义和结果。FlinkTableAPI、SQL和Flink的DataStreamAPI、Da...