的全托管式的Kafka消息队列。 DLI 支持将作业的输出数据输出到DMS的Kafka实例中。创建DMS Kafka输出流的语法与创建开源Apache Kafka输出流一样，具体请参见 MRS Kafka输出流。 父主题： 创建输出流

查看更多 →

获取项目输出或项目组输出 功能介绍 获取项目输出或项目组输出。 URI URI格式 GET /softcomai/datalake/dataplan/v1.0/north/progress/output 参数说明 无。 请求 请求样例 GET https://ipaddr:por

查看更多 →

为了避免算法推理内部可能出现的内存拷贝，在调用模型管家Process接口时，建议输入数据（输入数据一般可直接使用框架传入的内存，该内存是由框架通过HIAI_DMalloc申请得到）及输出数据都通过HIAI_DMalloc接口申请，这样就能够使能算法推理的零拷贝机制，优化Process时间。如果在推理前需要进行DVPP处理，DVPP的输入内

查看更多 →

extend_info String 扩展信息。 tb_guid String 表物化后的guid，只读。 tb_id String 数据表ID，只读。 logic_tb_name String 逻辑实体名。 logic_tb_guid String 逻辑实体的guid，只读。 description

查看更多 →

在 CDM 集群管理界面，单击集群后的“作业管理”，选择“连接管理 > 新建连接”，进入连接器类型的选择界面，如图2所示。 图2 选择连接器类型 选择“云数据库 MySQL”后单击“下一步”，配置云数据库 MySQL连接的参数。 单击“显示高级属性”可查看更多可选参数，具体请参见配置云数据库MySQL/My

查看更多 →

CS 自搭建数据源场景。终端节点服务连通方式接入MySQL数据源。 操作前准备 用户连接数据源时，检查是否添加了公网IP/内网（VPCEP）安全组。检查步骤： 登录管理服务控制台。 在服务列表中单击“数据库 > 云数据库 GaussDB （for MySQL）”，进入云数据库GaussDB（for

查看更多 →

tor”或者专用数据库连接器（oracle-connector、oracle-partition-connector、mysql-fastpath-connector），输入配置连接参数，单击“测试”验证连接是否可用，待提示“测试成功”后单击“确定”。 与关系数据库连接时，可以选

查看更多 →

tor”或者专用数据库连接器（oracle-connector、oracle-partition-connector、mysql-fastpath-connector），输入配置连接参数，单击“测试”验证连接是否可用，待提示“测试成功”后单击“确定”。 与关系数据库连接时，可以选

查看更多 →

不同类型的关系数据库，需要适配不同的驱动。 - 单次请求行数 可选参数，单击“显示高级属性”后显示。 指定每次请求获取的行数，根据数据源端和作业数据规模的大小配置该参数。如果配置过大或过小，可能影响作业的时长。 1000 单次提交行数 可选参数，单击“显示高级属性”后显示。 指定每

查看更多 →

并获取该任务对应的连接的使用权限。 操作前需要进行如下配置： 从MySQL数据库安装路径下获取MySQL客户端jar包（如mysqlclient-5.8.1.jar），将其保存在Loader服务主备节点的lib路径：“${BIGDATA_HOME}/ FusionInsight _P

查看更多 →

输出模块 输出模块简介 构造用于输出的显示器 输出一帧图片 上传文件 上传缓冲区数据 发送POST请求 发送一条消息 播放音频文件

查看更多 →

输出类算子 数据存储输出 DIS输出 实时分析输出 父主题： 算子使用指南

查看更多 →

DDS输出流 功能描述 DLI将作业的输出数据输出到文档数据库服务（DDS）中。 文档数据库服务（Document Database Service，简称DDS）完全兼容MongoDB协议，提供安全、高可用、高可靠、弹性伸缩和易用的数据库服务，同时提供一键部署、弹性扩容、容灾、备份、恢复、监控和告警等功能。

查看更多 →

都配置。 设置后数据会按照输出时间输出到相应时间目录下。 支持的格式为yyyy/MM/dd/HH/mm， 最小单位只到分钟，大小写敏感。例如配置为yyyy/MM/dd/HH， 则数据会写入对应小时这个时间点所产生的目录下，比如2018-09-10 16时产生的数据就会写到{obs

查看更多 →

子中的c_timeminute。配置primary_key后，在进行数据写入操作时，如果primary_key存在，则进行更新操作，否则进行插入操作。 示例： CREATE SINK STREAM test(c_timeminute LONG, c_cnt LONG) WITH (

查看更多 →

DIS输出流 功能描述 DLI将Flink作业的输出数据写入数据接入服务（DIS）中。适用于将数据过滤后导入DIS通道，进行后续处理的场景。 数据接入服务（Data Ingestion Service，简称DIS）为处理或分析流数据的自定义应用程序构建数据流管道，主要解决云服务外

查看更多 →

PARTITION BY toYYYYMM(d)ORDER BY a; 配置“ClickHouse输出”算子，如下图： 作业执行成功后，查看testck4表中数据： 父主题： 输出算子

查看更多 →

都配置。 设置后数据会按照输出时间输出到相应时间目录下。 支持的格式为yyyy/MM/dd/HH/mm， 最小单位只到分钟，大小写敏感。例如配置为yyyy/MM/dd/HH， 则数据会写入对应小时这个时间点所产生的目录下，比如2018-09-10 16时产生的数据就会写到{obs

查看更多 →

DDS输出流 功能描述 DLI将作业的输出数据输出到文档数据库服务（DDS）中。 文档数据库服务（Document Database Service，简称DDS）完全兼容MongoDB协议，提供安全、高可用、高可靠、弹性伸缩和易用的数据库服务，同时提供一键部署、弹性扩容、容灾、备份、恢复、监控和告警等功能。

查看更多 →

SMN输出流 功能描述 DLI将Flink作业的输出数据输出到消息通知服务（SMN）中。 消息通知服务（Simple Message Notification，简称SMN）为DLI提供可靠的、可扩展的、海量的消息处理服务，它大大简化系统耦合，能够根据用户的需求，向订阅终端主动推送

查看更多 →

该任务对应的连接的使用权限。 操作前需要进行如下配置： 从MySQL数据库安装路径下获取MySQL客户端jar包（如mysqlclient-5.8.1.jar），将其保存在Loader服务主备节点的lib路径：“${BIGDATA_HOME}/FusionInsight_Porter_8

查看更多 →