腾讯云产品
-
流计算 Oceanus 开发 Python 作业
这篇说说腾讯云流计算Oceanus Python作业的创建与开发流程,需先有独享集群,上传程序包后配置主程序包、入口类及作业参数,支持Flink 1.13⁄1.16及Python 3.7,可设置内置Connector、日志采集、高级参数、规格与并行度,并支持从快照恢复作业。 【前提与创建】:需先创建独享集群,在控制台新建作业并选择类型和集群。 【开发流程】:上传Python或Zip包,配置主程序包、入口类及参数,保存。
-
腾讯云数据仓库 TCHouse-P SQL 关键字
腾讯云数据仓库 TCHouse-P 的 SQL 关键字可以通过函数pg_get_keywords查询获得。SELECT * FROM pg_get_keywords()。
-
流计算 Oceanus 消息队列 Pulsar
Pulsar SQL connector 允许你使用简单的 SQL 查询或 Flink Table API 从 Pulsar topic 查询数据或将数据写入 Pulsar。
-
腾讯云数据仓库 TCHouse-P 数据类型
腾讯云数据仓库 TCHouse-P 提供丰富的内置数据类型。用户可以使用CREATE TYPE命令新增数据类型。下表展示了常用的内置数据类型。
-
流计算 Oceanus TaskManager Pod 异常退出事件
Flink 作业的 TaskManager 运行在 Kubernetes Pod 中,当 Pod 终止时,我们可以监测到该事件,并根据返回码、状态信息等维度,判断 Pod 是否发生了异常。
-
腾讯云数据仓库 TCHouse-P insert 语句
postgres=# insert into tbase(id, nickname) values(1, ‘hello TBase’)。
-
腾讯云数据仓库 TCHouse-P 系统信息函数
这篇列出了腾讯云数据库提供的系统信息函数,包括获取当前数据库、schema、用户、客户端地址、服务器端口、启动时间及PostgreSQL版本等信息的函数及其返回值说明。 会话与用户信息函数:current_database()、current_schema()、current_user、session_user等用于获取当前会话的数据库、schema及用户名称。 网络与状态函数:inet_client_addr()、。
-
流计算 Oceanus Python 开发指南
流计算 Oceanus 支持使用 Python 开发 Flink 作业,可以以在 Python 环境中使用 Flink 的所有功能,在降低开发门槛的同时,发挥 Python 在数据处理、机器学习领域的生态优势。
本章节主要提供在独享集群上开发 Python 作业的指南。通过阅读本章节,你将学习到以下内容。 -
腾讯云数据仓库 TCHouse-P SQL 命令
腾讯云数据仓库TCHouse-P支持丰富的SQL命令,涵盖数据定义、数据操纵、事务控制、权限管理及系统维护等类别,包括CREATE、ALTER、DROP、SELECT、INSERT、UPDATE、DELETE、BEGIN、COMMIT、GRANT等,适用于数据库对象的全生命周期管理。 数据定义命令:包括CREATE、ALTER、DROP系列,用于定义和修改数据库、表、索引、视图、函数等对象。 数据操纵命令:包括SEL。
-
流计算 Oceanus 数据库 SQLServer CDC
SQLServer 的 CDC 源表(即 SQLServer 的流式源表),SQLServer CDC Connector 允许从 SQLServer 数据库读取全量数据和增量数据。这篇档介绍如何设置 SQLServer CDC Connector。目前 SQLServer connector 标识分为 sqlserver-cdc 和 sqlserver-cdc-2.4,前者是 cdc 1.0版本,存量读取阶段不支持。