腾讯云产品

查看流湖引擎 Setats 信息，可登录 流计算 Oceanus 控制台，在计算资源中，选择计算集群，在集群的流湖引擎 Setats 标签页中 新建Setats服务，具体可参考 创建流湖引擎 Setats 服务。创建 Setats 集群后可在计算资源中计算集群的流湖引擎 Setats 标签页中查看集群信息。

集合函数包括数组（Array）和键值对映射（Map）的操作，函数名和功能描述如下。

这篇说说腾讯云流计算 Oceanus 的 FileSystem connector，支持将数据写入 HDFS 和 COS，并详细说明了不同 Flink 版本支持情况、DDL 定义、WITH 参数配置、HDFS 与 COS 的配置方法及 Kerberos 认证授权。 版本与支持：Flink 1.13 支持 lzo/snappy 压缩，1.14 及以上版本不支持；支持 CSV、JSON、Avro 等格式写入。 HDFS 。

功能描述：GENERATE_SERIES 用于生成一个连续的整数序列，并将序列展开为多行。该函数常用于构造测试数据、根据起止值展开连续编号、补齐序列，或将区间字段展开为多行。

流计算 Oceanus 采用符合 ANSI SQL 规范的定义，支持丰富的数据类型。用户在使用 CREATE TABLE 语句定义一个数据表时，可以用这些数据类型来定义每个字段的类型。

当需要检验作业是否可以正常运行、逻辑是否正确时，为了减少外部系统的部署开销，以及避免干扰因素，我们可以使用一些调试专用的 Connector。

Kafka 连接器既可以作为 Source（type: kafka）从 Kafka 主题读取变更事件，也可以作为 Sink（type: kafka）把变更事件写入 Kafka 主题。

JDBC Connector 提供了对 MySQL、PostgreSQL、Oracle 等常目前 Oceanus 提供的 flink-connector-jdbc Connector 组件已经内置了 MySQL 和 PostgreSQL 的驱动程序。若需要连接 Oracle 等其它的数据库，可通过附加自定义程序包的方式，上传相应的 JDBC Driver 的 JAR 包。

Setats 支持通过 Flink 持续写入实时数据，使用 setats connector 将 Upsert 数据写入 Setats 主键表。数据写入后会触发 Eager 合并并生成 Changelog，因此能够同时满足秒级。

功能描述：DATEDIFF 用于计算两个日期/时间表达式之间相差的天数，返回 t1 – t2 的差值（以”日历日”为单位）。示例测试语句：SELECT DATEDIFF(t1, t2) AS res。