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

查看更多 →

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

查看更多 →

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

查看更多 →

field_names 是 待插入数据字段的key，具体形式如："f1,f2,f3"，并且保证与sink中数据列一一对应。 batch_insert_data_num 否 表示一次性批量写入的数据量，值必须为正整数，默认值为10。 示例 将流qualified_cars 的数据输出到文档数据库collectionTest。

查看更多 →

数指定真正需要编码的数据，格式为${field_name}，表示直接将该流字段的内容作为一个完整的记录进行编码。 注意事项 当配置项支持参数化时，表示将记录中的一列或者多列作为该配置项的一部分。例如当配置项设置为car_${car_brand}时，如果一条记录的car_brand

查看更多 →

该配置项用于指定数据的处理方式，需要配置为${field_name}的形式，field_name的类型必读为string，field_name所代表的真正内容表示为D或者DELETE时，表示删除数据库中该条记录，其余默认插入数据。 注意事项 stream_id所定义的流格式需和数据库中的表格式一致。

查看更多 →

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

查看更多 →

数指定真正需要编码的数据，格式为${field_name}，表示直接将该流字段的内容作为一个完整的记录进行编码。 注意事项 当配置项支持参数化时，表示将记录中的一列或者多列作为该配置项的一部分。例如当配置项设置为car_${car_brand}时，如果一条记录的car_brand

查看更多 →

field_names 是 待插入数据字段的key，具体形式如："f1,f2,f3"，并且保证与sink中数据列一一对应。 batch_insert_data_num 否 表示一次性批量写入的数据量，值必须为正整数，默认值为10。 示例 将流qualified_cars 的数据输出到文档数据库collectionTest。

查看更多 →

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

查看更多 →

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

查看更多 →

AI_DVPP_DFree接口的说明，以及Graph配置文件（receive_memory_without_dvpp参数）的说明，请参见《Matrix API参考》。 表1 内存要求说明 功能模块 输入内存 输出内存 VPC 请使用Matrix提供的接口申请/释放内存： 使用HI

查看更多 →

构造用于输出的显示器 构造显示器，用来将图片显示到显示器或是输出到视频流。如果创建失败则抛出一个CreateError，开发者可以查看技能日志或输出来定位错误原因。 如果是H264_FILE类型的，需要注意，生成的文件仅是h264编码的裸视频流，不含帧率等信息，而且HiLens

查看更多 →

。 输出顺序 使用“--cli-query”指定的JMESPath表达式不同，输出的结果中各参数的排列顺序可能不同。部分表达式的输出结果不会带有输出数据的属性名（即参数的key值），故用户需对输出数据的顺序有所把握，以便于数据处理。不同类型的JMESPath表达式，输出结果的顺序如下表所示：

查看更多 →

MapReduce MapReduce基本原理 MapReduce与其他组件的关系 MapReduce开源增强特性 父主题： 组件介绍

查看更多 →

应用中，不同的键值对应的region不同，这就需要设定特殊的partitioner类分配map的输出结果。 setSortComparatorClass(Class<extends RawComparator> cls) 指定MapReduce作业的map任务的输出结果压缩类，默

查看更多 →

class”项。该方法用来分配map的输出结果到哪个reduce类，默认使用HashPartitioner，均匀分配map的每条键值对记录。例如在hbase应用中，不同的键值对应的region不同，这就需要设定特殊的partitioner类分配map的输出结果。 setSortComp

查看更多 →

常会把输入的数据集切分为若干独立的数据块，由map任务（task）以完全并行的方式来处理。框架会对map的输出先进行排序，然后把结果输入给reduce任务，最后返回给客户端。通常作业的输入和输出都会被存储在文件系统中。整个框架负责任务的调度和监控，以及重新执行已经失败的任务。 MapReduce主要特点如下：

查看更多 →

MapReduce任务commit阶段优化 操作场景 默认情况下，如果一个MR任务会产生大量的输出结果文件，那么该job在最后的commit阶段会耗费较长的时间将每个task的临时输出结果commit到最终的结果输出目录。特别是在大集群中，大Job的commit过程会严重影响任务的性能表现。

查看更多 →

edgecamera：表示从指定的边缘摄像头读取数据。 vis：表示从 视频接入服务 中读取视频数据。 edgerestful：表示从客户自定义的流媒体 服务器 读取视频数据。 vcn ：表示从华为云VCN中读取视频数据。 data 是 List<Object> 数据输入内容，data的元素的输入内容信息不能重复。

查看更多 →

输出格式相关 KooCLI支持的输出格式有哪些？ 如何定义JMESPath表达式 KooCLI与输出相关的系统参数有哪些，推荐使用哪些？ 新输出参数cli-output，cli-query，cli-output-num在使用时的注意事项有哪些？ 旧输出参数cli-output-r

查看更多 →