标签： Flink Table API&SQL

Connector 描述了存储表数据的外部系统。存储系统例如 Apache Kafka 或者常规的文件系统都可… 继续阅读 Flink从入门到实战九[Table API&SQL]-8-基于FileSystem 创建 TABLE 通过 connector SQL DDL

Connector 描述了存储表数据的外部系统。存储系统例如 Apache Kafka 或者常规的文件系统都可… 继续阅读 Flink从入门到实战九[Table API&SQL]-7-基于FileSystem 创建 TABLE 通过 connector 声明

我们要建表，就要定义内部和外部表的结构，此时就是在定义Catalog。Catalog 提供了元数据信息，例如数… 继续阅读 Flink从入门到实战九[Table API&SQL]-6-什么是Catalogs

将 DataStream 或 DataSet 转换成表//前面章节已经完整演示了代码Table table1 … 继续阅读 Flink从入门到实战九[Table API&SQL]-5-DataStream和DataSet与Table相互转换

创建 TableEnvironment的第二种方法，可以通过StreamExecutionEnvironmen… 继续阅读 Flink从入门到实战九[Table API&SQL]-4-使用StreamExecutionEnvironment创建 TableEnvironment

上一节知道了TableEnvironment的作用，并且也知道了创建TableEnvironment有两种方法… 继续阅读 Flink从入门到实战九[Table API&SQL]-3-使用EnvironmentSettings创建 TableEnvironment

TableEnvironment 是 Table API 和 SQL 的核心概念。它负责: • 在内部的 ca… 继续阅读 Flink从入门到实战九[Table API&SQL]-2-什么是 TableEnvironment

Flink本身是批流统一的处理框架，所以Table API和SQL，就是批流统一的上层处理API。目前功能尚未… 继续阅读 Flink从入门到实战九[Table API&SQL]-1-什么是 Table API&SQL?