Flink Table API & SQL概念和通用API Flink

Flink Table API & SQL概念和通用API

Apache Flink具有两个关系API-Table API和SQL-用于统一流和批处理。Table API是用于Scala和Java的语言集成查询API,它允许以非常直观的方式组合来自关系运算符(例如选择,过滤和联接)的查询。Flink的SQL支持基于实现SQL标准的Apache Calcite。无论输入是批处理输入DataSet还是流输入DataStream,在两个接口中指定的查询都具有相同
阅读全文
本文目录
    Loading...