流计算 Oceanus

{"list":[{"id":92650,"title":"动态与公告","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_92650_cn.pdf","children":[{"id":92651,"title":"产品公告","type":"directory","docType":"default","pdfUrl":"","children":[{"id":54183,"title":"共享版下线公告","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54183"}],"link":"/document/product/849/92651"},{"id":58738,"title":"产品动态","type":"page","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_58738_cn.pdf","link":"/document/product/849/58738"}],"link":"/document/product/849/92650"},{"id":16782,"title":"产品简介","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_16782_cn.pdf","children":[{"id":16784,"title":"产品概述","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/16784"},{"id":16783,"title":"产品优势","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/16783"},{"id":16785,"title":"应用场景","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/16785"}],"link":"/document/product/849/16782"},{"id":50775,"title":"购买指南","type":"directory","docType":"price","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_50775_cn.pdf","children":[{"id":50779,"title":"计费概述","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/50779"},{"id":82419,"title":"计费模式","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/82419"},{"id":50420,"title":"退费说明","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/50420"},{"id":50419,"title":"调整配置费用说明","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/50419"}],"link":"/document/product/849/50775"},{"id":48296,"title":"快速入门","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_48296_cn.pdf","children":[{"id":59880,"title":"从零开始上手","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59880"},{"id":48298,"title":"创建独享集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48298"},{"id":48301,"title":"创建 SQL 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48301"},{"id":48300,"title":"创建 JAR 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48300"},{"id":57853,"title":"创建 ETL 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/57853"},{"id":81987,"title":"创建 Python 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/81987"},{"id":103977,"title":"Flink 动态 CEP 快速入门","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/103977"}],"link":"/document/product/849/48296"},{"id":38376,"title":"操作指南","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_38376_cn.pdf","children":[{"id":48264,"title":"上下游数据一览","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48264"},{"id":48267,"title":"作业管理","type":"directory","docType":"default","pdfUrl":"","children":[{"id":89215,"title":"作业概览","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/89215"},{"id":59421,"title":"作业类型","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59421"},{"id":48286,"title":"作业信息","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48286"},{"id":48289,"title":"作业操作","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48289"}],"link":"/document/product/849/48267"},{"id":59419,"title":"作业开发","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48287,"title":"开发 SQL 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48287"},{"id":49805,"title":"开发 JAR 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/49805"},{"id":70714,"title":"开发 Python 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/70714"},{"id":57854,"title":"开发 ETL 作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/57854"},{"id":73436,"title":"开发批作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/73436"},{"id":53391,"title":"作业高级参数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/53391"},{"id":54516,"title":"作业最大并行度","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54516"},{"id":57772,"title":"作业资源配置","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/57772"},{"id":59420,"title":"版本管理","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59420"}],"link":"/document/product/849/59419"},{"id":59426,"title":"作业监控","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48294,"title":"查看作业监控信息","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48294"},{"id":48293,"title":"配置作业监控告警（数值指标）","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48293"},{"id":68291,"title":"配置作业事件告警（异常事件）","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/68291"},{"id":59425,"title":"监控指标一览","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59425"},{"id":55239,"title":"接入 Prometheus 自定义监控","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/55239"},{"id":48292,"title":"查看作业 Flink UI","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48292"}],"link":"/document/product/849/59426"},{"id":59444,"title":"作业日志","type":"directory","docType":"default","pdfUrl":"","children":[{"id":67031,"title":"配置采集作业运行日志","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/67031"},{"id":48288,"title":"查看作业日志信息","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48288"}],"link":"/document/product/849/59444"},{"id":59445,"title":"事件与诊断","type":"directory","docType":"default","pdfUrl":"","children":[{"id":53959,"title":"日志诊断指南","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/53959"},{"id":64469,"title":"查看关键事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64469"},{"id":64489,"title":"各类事件说明","type":"directory","docType":"default","pdfUrl":"","children":[{"id":64491,"title":"快照失败事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64491"},{"id":64499,"title":"作业失败事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64499"},{"id":64500,"title":"TaskManager Pod 异常退出事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64500"},{"id":68290,"title":"JobManager Pod 异常退出事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/68290"},{"id":64501,"title":"TaskManager Full GC 过久事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64501"},{"id":64502,"title":"TaskManager CPU 负载过高事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64502"},{"id":65095,"title":"TaskManager 背压较高/严重事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/65095"},{"id":94230,"title":"JobManager CPU 负载过高事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/94230"},{"id":94231,"title":"JobManager Full GC 过久事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/94231"}],"link":"/document/product/849/64489"}],"link":"/document/product/849/59445"},{"id":59446,"title":"现场采集","type":"directory","docType":"default","pdfUrl":"","children":[{"id":58709,"title":"Pod 崩溃现场采集","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/58709"}],"link":"/document/product/849/59446"},{"id":68572,"title":"元数据管理","type":"directory","docType":"default","pdfUrl":"","children":[{"id":58538,"title":"库表管理","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/58538"},{"id":68573,"title":"变量管理","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/68573"},{"id":71854,"title":"使用 Hive Catalog","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/71854"}],"link":"/document/product/849/68572"},{"id":66222,"title":"快照管理","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/66222"},{"id":86978,"title":"作业调优","type":"directory","docType":"default","pdfUrl":"","children":[{"id":76985,"title":"作业自动调优","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76985"},{"id":86979,"title":"作业自定义调优","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/86979"}],"link":"/document/product/849/86978"},{"id":48295,"title":"依赖管理","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48295"},{"id":49806,"title":"集群管理","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48265,"title":"查看集群信息","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48265"},{"id":49807,"title":"扩容集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/49807"},{"id":49808,"title":"销毁集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/49808"},{"id":55862,"title":"缩容集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/55862"},{"id":61851,"title":"迁移集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/61851"},{"id":65626,"title":"自定义DNS","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/65626"},{"id":79961,"title":"网络连通性检查","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/79961"}],"link":"/document/product/849/49806"},{"id":38621,"title":"权限管理","type":"directory","docType":"default","pdfUrl":"","children":[{"id":70605,"title":"权限概述","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/70605"},{"id":70606,"title":"基础权限配置指引","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/70606"},{"id":61002,"title":"空间角色权限","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/61002"}],"link":"/document/product/849/38621"}],"link":"/document/product/849/38376"},{"id":18030,"title":"SQL 开发指南","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_18030_cn.pdf","children":[{"id":48242,"title":"开发指南概述","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48242"},{"id":18148,"title":"术语和数据类型","type":"directory","docType":"default","pdfUrl":"","children":[{"id":18149,"title":"术语表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18149"},{"id":18119,"title":"数据类型","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18119"}],"link":"/document/product/849/18148"},{"id":18033,"title":"DDL 数据定义语句","type":"directory","docType":"default","pdfUrl":"","children":[{"id":18034,"title":"CREATE TABLE","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18034"},{"id":18035,"title":"CREATE VIEW","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18035"},{"id":48243,"title":"CREATE FUNCTION","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48243"}],"link":"/document/product/849/18033"},{"id":48246,"title":"DML 数据操作语句","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48247,"title":"查询语句","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48247"},{"id":48248,"title":"INSERT 语句","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48248"}],"link":"/document/product/849/48246"},{"id":76650,"title":"MySQL CDC 多 Source 复用","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76650"},{"id":76651,"title":"整库同步（SQL）能力","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76651"},{"id":48263,"title":"上下游开发指南","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48310,"title":"消息队列 Kafka","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48310"},{"id":62880,"title":"消息队列 Upsert Kafka","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/62880"},{"id":58213,"title":"消息队列 CMQ","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/58213"},{"id":71447,"title":"消息队列 TDMQ RabbitMQ","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/71447"},{"id":52698,"title":"数据库 MySQL CDC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52698"},{"id":85885,"title":"消息队列 Pulsar","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/85885"},{"id":71448,"title":"数据库 TDSQL-MySQL","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/71448"},{"id":54634,"title":"数据库 Redis","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54634"},{"id":60410,"title":"数据库 MongoDB CDC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60410"},{"id":68072,"title":"数据库 MongoDB","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/68072"},{"id":60315,"title":"数据库 PostgreSQL CDC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60315"},{"id":60717,"title":"数据库 HBase","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60717"},{"id":60953,"title":"数据库 Doris","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60953"},{"id":55238,"title":"数据仓库 Hive","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/55238"},{"id":53389,"title":"数据仓库 ClickHouse","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/53389"},{"id":85884,"title":"数据湖计算 DLC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/85884"},{"id":57609,"title":"数据仓库 Kudu","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/57609"},{"id":68460,"title":"云数据仓库 TCHouse-P","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/68460"},{"id":48313,"title":"数据分析引擎 Elasticsearch Service","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48313"},{"id":61690,"title":"日志消费 CLS","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/61690"},{"id":48312,"title":"数据库连接 JDBC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48312"},{"id":53852,"title":"文件系统 FileSystem","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/53852"},{"id":58713,"title":"模拟上下游 Datagen Logger Blackhole","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/58713"},{"id":48330,"title":"自定义 Connector","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48330"},{"id":79934,"title":"数据湖 Hudi","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/79934"},{"id":79945,"title":"数据湖 Iceberg ","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/79945"},{"id":86830,"title":"数据库 SQLServer CDC","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/86830"},{"id":89544,"title":"数据库 StarRocks","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/89544"}],"link":"/document/product/849/48263"},{"id":58734,"title":"SET 控制语句","type":"directory","docType":"default","pdfUrl":"","children":[{"id":48245,"title":"Flink 配置项","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/48245"}],"link":"/document/product/849/58734"},{"id":18037,"title":"运算符和内置函数","type":"directory","docType":"default","pdfUrl":"","children":[{"id":18083,"title":"概览","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18083"},{"id":71606,"title":"内置函数差异对比","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/71606"},{"id":18078,"title":"比较函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18078"},{"id":18082,"title":"逻辑和位运算函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18082"},{"id":18080,"title":"算术函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18080"},{"id":18076,"title":"条件函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18076"},{"id":18073,"title":"字符串操作函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18073"},{"id":18079,"title":"类型转换函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18079"},{"id":18075,"title":"时间相关函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18075"},{"id":18081,"title":"聚合函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18081"},{"id":18077,"title":"时间窗口函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18077"},{"id":18074,"title":"其他函数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18074"}],"link":"/document/product/849/18037"},{"id":18116,"title":"标识符与保留字","type":"directory","docType":"default","pdfUrl":"","children":[{"id":18117,"title":"命名规则","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18117"},{"id":18118,"title":"保留字","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/18118"}],"link":"/document/product/849/18116"}],"link":"/document/product/849/18030"},{"id":70715,"title":"Python 开发指南","type":"page","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_70715_cn.pdf","link":"/document/product/849/70715"},{"id":59838,"title":"ETL 开发指南","type":"directory","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_59838_cn.pdf","children":[{"id":59839,"title":"概述","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59839"},{"id":59840,"title":"ETL 作业术语表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59840"},{"id":59841,"title":"上下游开发指南","type":"directory","docType":"default","pdfUrl":"","children":[{"id":59842,"title":"数据源表 MySQL","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59842"},{"id":59843,"title":"数据目的表 MySQL","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59843"},{"id":60722,"title":"数据目的表 PostgreSQL","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60722"},{"id":59844,"title":"数据目的表 ClickHouse","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/59844"},{"id":60723,"title":"数据目的表 Elasticsearch","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60723"}],"link":"/document/product/849/59841"}],"link":"/document/product/849/59838"},{"id":51992,"title":"API 文档","type":"directory","docType":"api","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_51992_cn.pdf","children":[{"id":52020,"title":"更新历史","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52020"},{"id":52018,"title":"简介","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52018"},{"id":52019,"title":"API 概览","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52019"},{"id":52011,"title":"调用方式","type":"directory","docType":"default","pdfUrl":"","children":[{"id":52012,"title":"请求结构","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52012"},{"id":52013,"title":"公共参数","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52013"},{"id":52014,"title":"签名方法 v3","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52014"},{"id":52015,"title":"签名方法","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52015"},{"id":52016,"title":"返回结果","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52016"},{"id":78537,"title":"参数类型","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/78537"}],"link":"/document/product/849/52011"},{"id":95068,"title":"日志相关接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":95069,"title":"查询作业实例启动日志","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/95069"}],"link":"/document/product/849/95068"},{"id":51998,"title":"资源相关接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":52000,"title":"创建资源接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52000"},{"id":54670,"title":"删除资源接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54670"},{"id":54669,"title":"获取资源关联作业信息","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54669"},{"id":54668,"title":"描述资源接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54668"},{"id":51999,"title":"描述系统资源接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/51999"}],"link":"/document/product/849/51998"},{"id":51996,"title":"资源配置相关接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":51997,"title":"创建资源配置接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/51997"},{"id":54667,"title":"删除资源版本","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54667"},{"id":54666,"title":"描述资源配置接口","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/54666"}],"link":"/document/product/849/51996"},{"id":102772,"title":"元数据相关接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":102773,"title":"查询元数据表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/102773"}],"link":"/document/product/849/102772"},{"id":94137,"title":"权限相关接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":100451,"title":"创建工作空间","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100451"},{"id":100579,"title":"删除工作空间","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100579"},{"id":100450,"title":"修改工作空间","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100450"},{"id":94138,"title":"授权工作空间列表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/94138"}],"link":"/document/product/849/94137"},{"id":76831,"title":"集群接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":76832,"title":"查询集群","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76832"}],"link":"/document/product/849/76831"},{"id":52005,"title":"作业接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":74227,"title":"检查快照是否可用","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/74227"},{"id":77740,"title":"复制作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/77740"},{"id":76834,"title":"删除作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76834"},{"id":102554,"title":"获取指定作业的事件","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/102554"},{"id":74226,"title":"查找Savepoint列表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/74226"},{"id":75553,"title":"更新作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/75553"},{"id":52007,"title":"运行作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52007"},{"id":52006,"title":"停止作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52006"},{"id":75095,"title":"触发Savepoint","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/75095"},{"id":52009,"title":"新建作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52009"},{"id":52008,"title":"查询作业","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52008"},{"id":100320,"title":"执行Statement","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100320"},{"id":100321,"title":"查询Statement执行结果","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100321"}],"link":"/document/product/849/52005"},{"id":52003,"title":"作业配置接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":52004,"title":"创建作业配置","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52004"},{"id":100454,"title":"删除作业配置","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100454"},{"id":52875,"title":"查询作业配置","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52875"}],"link":"/document/product/849/52003"},{"id":52001,"title":"其他接口","type":"directory","docType":"default","pdfUrl":"","children":[{"id":77739,"title":"创建文件夹","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/77739"},{"id":100453,"title":"删除文件夹","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100453"},{"id":52002,"title":"删除作业表配置","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52002"},{"id":76833,"title":"自定义树状结构","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/76833"},{"id":100452,"title":"拖拽文件夹","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/100452"},{"id":79568,"title":"查询树状结构资源列表","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/79568"},{"id":102187,"title":"查询文件夹","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/102187"}],"link":"/document/product/849/52001"},{"id":52010,"title":"数据结构","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52010"},{"id":52017,"title":"错误码","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/52017"}],"link":"/document/product/849/51992"},{"id":60519,"title":"最佳实践","type":"directory","docType":"practice","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_60519_cn.pdf","children":[{"id":60520,"title":"使用流计算 Oceanus 和 ES 构建日志分析系统","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60520"},{"id":60521,"title":"使用 MySQL 关联 HBase 维表数据到 ClickHouse","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60521"},{"id":60522,"title":"视频直播解决方案之实时 BI 分析","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/60522"},{"id":61374,"title":"监控解决方案之系统级和应用级实时监控","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/61374"},{"id":64343,"title":"指标统计之自建集群数据实现 UV/PV 统计","type":"page","docType":"default","pdfUrl":"","link":"/document/product/849/64343"}],"link":"/document/product/849/60519"},{"id":16786,"title":"常见问题","type":"page","docType":"faq","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_16786_cn.pdf","link":"/document/product/849/16786"},{"id":93059,"title":"服务等级协议","type":"page","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_93059_cn.pdf","link":"/document/product/849/93059"},{"id":59561,"title":"联系我们","type":"page","docType":"default","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_59561_cn.pdf","link":"/document/product/849/59561"},{"id":17740,"title":"词汇表","type":"page","docType":"glossary","pdfUrl":"https://main.qcloudimg.com/raw/document/product/pdf/849_17740_cn.pdf","link":"/document/product/849/17740"}],"categoryId":849,"title":"流计算 Oceanus","lang":"zh"}

文档中心流计算 Oceanus SQL 开发指南上下游开发指南自定义 Connector

自定义 Connector

最近更新时间：2023-06-21 15:21:53

我的收藏

本页目录：

介绍
若内置的 Connector 无法满足需求，可以考虑自定义 Connector 功能，即用户可以自行上传实现了相应 Source 和 Sink 接口的类实现，然后作业在运行时会动态加载并调用。
版本说明
Flink 版本
说明
1.11
支持
1.13
支持
1.14
支持
1.16
支持
选择合适的 Connector
用户可以选择第三方提供的 Connector 实现包（例如下面介绍的 Bahir），或者自行通过编程的方式实现。
Apache Bahir 第三方包
Apache Bahir 为 Flink 提供了常见的数据源和数据目的的扩展包。
目前 Bahir 支持如下的第三方组件：
ActiveMQ
Akka
Flume
InfluxDB
Kudu
Redis
Netty
自行编程实现
参见 Flink API。
构建并上传 Connector 包
步骤一：源码构建
建议参考现有的 Connector 的项目，修改其 pom.xml 配置文件，引入相关的依赖包，然后通过 Maven 构建一个 JAR 包。
说明
尽量使用 maven-shade-plugin 将常见的依赖（例如 Apache Commons、Guava 等相关的包）进行 shade 化，以避免引入的库与流计算平台本身的类发生冲突。
步骤二：上传程序包
可以在流计算的 依赖管理 界面，上传 Connector 的程序包。首次上传是 V1 版本，以此类推。
步骤三：作业参数引用程序包
在作业的详情页，作业参数选择引用之前上传的程序包和版本。
注意
 请务必确认程序包的版本是否符合预期，避免出现各种不可预知的错误。
步骤四：保存并发布
选择程序包后，可以单击保存，也可以选择直接发布草稿。

上一篇: 模拟上下游 Datagen Logger Blackhole 下一篇: 数据湖 Hudi