创建输出流 CloudTable HBase输出流 CloudTable OpenTSDB输出流 MRS OpenTSDB输出流 CSS Elasticsearch输出流 D CS 输出流 DDS输出流 DIS输出流 DMS输出流 DWS输出流（通过JDBC方式） DWS输出流（通过OBS转储方式）

查看更多 →

的全托管式的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

查看更多 →

自定义Flink log4j日志输出级别不生效 用户问题 MRS 3.1.0集群自定义Flink log4j日志级别不生效。 问题现象 在使用MRS 3.1.0集群Flink数据分析时，将“$Flink_HOME/conf”目录下的“log4j.properties”文件中日志级别修改为INFO级别日志。

查看更多 →

Kafka生产者写入单条记录过长问题 问题背景与现象 用户在开发一个Kafka应用，作为一个生产者调用新接口（org.apache.kafka.clients.producer.*）往Kafka写数据，单条记录大小为1100055，超过了kafka配置文件server.properties中message

查看更多 →

不透明度：设置图表在画布上的透明度，可通过滑动条进行设置，也可手动输入百分比，比例越大透明程度越低。 图2 尺寸位置 进度条 内半径：设置内半径，输入不能为空，且输入值在0到100之间。 外半径：设置外半径，输入不能为空，且输入值在0到100之间。 背景色：设置进度条的背景色。 进度条颜色：设置进度条的颜色。 图3

查看更多 →

数据输出配置 数据存储输出 将数据输出到IoT数据分析服务的存储，以便进一步分析（资产建模、实时分析、时序分析）使用。 用户可以配置算子名称、选择存储组、填写存储名称，并选择所需要的属性及属性类型等信息，如图所示： DIS输出 将数据输出到DIS云服务，IoT数据分析服务仅在华为云部署时支持输出到DIS云服务。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

接将该流字段的内容作为一个完整的记录进行编码。 注意事项 当配置项支持参数化时，表示将记录中的一列或者多列作为该配置项的一部分。例如当配置项设置为car_${car_brand}时，如果一条记录的car_brand列值为BMW，则该配置项在该条记录下为car_BMW。 示例 将c

查看更多 →

RDS输出流 功能描述 DLI将Flink作业的输出数据输出到关系型数据库（RDS）中。目前支持PostgreSQL和MySQL两种数据库。PostgreSQL数据库可存储更加复杂类型的数据，支持空间信息服务、多版本并发控制（MVCC）、高并发，适用场景包括位置应用、金融保险、互

查看更多 →

field2”。 enable_output_null 否 当编码格式为json时，需使用该参数来配置是否输出空字段。 当该参数为“true”表示输出空字段（值为null），若为“false”表示不输出空字段。默认值为“true”。 encode_class_name 否 当encode为us

查看更多 →

ClickHouse输出 概述 “ClickHouse输出”算子，用于配置已生成的字段输出到ClickHouse表的列。 输入与输出 输入：需要输出的字段 输出：ClickHouse表 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 数据库名 配置ClickHouse表所在的数据库

查看更多 →

接将该流字段的内容作为一个完整的记录进行编码。 注意事项 当配置项支持参数化时，表示将记录中的一列或者多列作为该配置项的一部分。例如当配置项设置为car_${car_brand}时，如果一条记录的car_brand列值为BMW，则该配置项在该条记录下为car_BMW。 示例 将c

查看更多 →

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

查看更多 →

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

查看更多 →

选择“按流运行显示”页签，显示流在对应时间段内的运行记录，包含流名称、运行状态、运行时间和耗时（单位为ms）。 单击，可以设置流信息所显示的字段。 单击某一条流运行记录，可查看当时流的各个节点（触发事件或执行动作）的运行详情，包括节点运行时间，运行状态，每个节点的输入输出等，以及该流的运行总次数，成功次数和失败次数。

查看更多 →

排序字段/顺序：使查询结果根据某个字段进行升序或者降序排序。 记录行的偏移量：分页，跳过前n条记录，从第n+1条记录开始。 记录行的最大数目：分页，每页最多显示的记录数。 记录的总行数存入变量：限定查询出来的总记录数，存入变量中。 （输出）源/目标：输出的结果。其中，“源”为需要查询的字段，查询结

查看更多 →

择“下载”页签，对状态为“准备完成”的日志文件，单击操作列中的“下载”，下载错误日志。 图2 下载错误日志 建议下载的单条日志不超过10000行并且日志大小不超过10MB，否则下载的日志信息会被截断。 系统会自动加载下载准备任务，加载时长受日志文件大小及网络环境影响。 下载准备过程中，日志文件状态显示为“准备中

查看更多 →

剔重 若查询记录有重复值，是否需要删掉重复记录只保留一条记录。 默认不勾选，表示不删掉重复记录。 条件 单击“新增行”，可设置查询数据的条件。 （排序）排序字段/顺序 将查询结果，根据某个字段，进行升序或降序排序。 记录行的偏移量 分页，跳过前n条记录，从第n+1条记录开始。 从全局上下文拖拽数值变量或者直接输入“{

查看更多 →