腾讯云产品

  • 流计算 Oceanus CREATE FUNCTION

    对于 SQL 作业,用户可以上传 自定义程序包,然后在作业分析开发页的参数设置中,引用该程序包。目前支持从本地上传,也可以引用账户下现有 COS 存储中的资源(仅限相同地域)。这里的程序包既可以用来扩展 Connector 的功能,也可以创建自定义函数(UDF)。

    腾讯云产品 6天前
  • 流计算 Oceanus 版本管理

    使用版本管理可以对作业回滚历史版本,增加操作的容错率。
    在开发调试页的左上角单击版本管理可以在侧边弹窗中查看当前作业发布过的所有历史版本,单击某个版本,可以查看该版本的作业信息,但不可编辑。在版本管理弹窗中可以删除不需要的历史版本或对比不同版本的代码和配置差异。

    腾讯云产品 6天前
  • 流计算 Oceanus Postgres 连接器

    Postgres 连接器支持从 PostgreSQL 数据库读取快照数据与增量 WAL 数据,并提供整库同步能力。通过 YAML 作业定义即可完成一条数据同步链路。

    腾讯云产品 6天前
  • 流计算 Oceanus 数据分析引擎 Elasticsearch Service

    Elasticsearch Connector 提供了对 Elasticsearch 的写入、读取和维表关联支持。目前 Oceanus 支持 Elasticsearch 6.x、7.x 和 8.x 版本。

    腾讯云产品 6天前
  • 流计算 Oceanus Flink CDC流式读取

    Setats 支持通过 Flink 以 CDC 方式流式读取表的 Changelog 数据。数据写入 Setats 后,系统会基于主键合并结果生成变更日志,下游可通过 setats-cdc connector 持续消费新增、更新和删除事件。

    腾讯云产品 6天前
  • 流计算 Oceanus 条件函数

    腾讯云文档列出了条件函数(CASE、NULLIF、COALESCE、IF等)及其功能描述,用于在SQL查询中实现条件判断和值处理。 CASE函数:支持值匹配与条件判断两种语法,返回对应结果或默认值。 IF与NULLIF:IF根据条件返回两个值之一,NULLIF比较两值相同则返回NULL。 COALESCE与IF_NULL_STR:提供NULL值替代,分别返回首个非NULL值或默认值。

    腾讯云产品 6天前
  • 流计算 Oceanus 作业最大并行度

    每个 Flink 作业都有一个名为最大并行度(Maximum Parallelism,简称 MaxParallelism)的属性,它决定了 Flink 作业无损扩容的上限。

    腾讯云产品 6天前
  • 流计算 Oceanus SQL Gateway

    登录 流计算 Oceanus 控制台,在计算资源的集群列表中选择单个集群,在集群服务中找到 SQL Gateway。SQL Gateway 在 Oceanus 中构建起一条统一的 SQL 访问通道。

    腾讯云产品 6天前
  • 流计算 Oceanus 查询语句

    SELECT 不能单独使用,必须配合CREATE VIEW … AS或 INSERT INTO 使用,否则系统会提示没有合适的 Operator。

    腾讯云产品 6天前
  • 流计算 Oceanus 作业类型

    登录 流计算 Oceanus 控制台,目前 Oceanus 在新建作业中支持3种作业类型:SQL 作业、JAR 作业、Python 作业。开发人员可根据业务需求与使用场景,选择合适的作业类型进行开发。

    腾讯云产品 6天前