自拓展输入流 用户可通过编写代码实现从想要的云生态或者开源生态获取数据，作为Flink作业的输入数据。 语法格式 1 2 3 4 5 6 7 CREATE SOURCE STREAM stream_id (attr_name attr_type (',' attr_name attr_type)*

查看更多 →

EdgeHub输入流（EOS） 功能描述 创建边缘作业source流，从EdgeHub中获取数据。用户数据写入EdgeHub中，Flink边缘作业从中读取数据，作为流计算的数据输入。 适用于物联网IOT场景，将实时流计算能力从云端延伸到边缘，在边缘快速实现对流数据实时、快速、准确

查看更多 →

MRS Kafka输入流 功能描述 创建source流从Kafka获取数据，作为作业的输入数据。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。MRS基于Apache

查看更多 →

固定宽度文件输入 概述 “固定宽度文件输入”算子，将文件的每一行，按可配置长度的字符或字节，转换成多个输入字段。 输入与输出 输入：文本文件 输出：多个字段 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 换行符 用户根据数据实际情况，填写字符串作为换行符。支持任何字符串。默认使用操作系统的换行符。

查看更多 →

CloudTable HBase输入流 功能描述 创建source流从 表格存储服务 CloudTable的HBase中获取数据，作为作业的输入数据。HBase是一个稳定可靠，性能卓越、可伸缩、面向列的分布式云存储系统，适用于海量数据存储以及分布式计算的场景，用户可以利用HBase搭

查看更多 →

开源Kafka输入流 功能描述 创建source流从Kafka获取数据，作为作业的输入数据。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kaf

查看更多 →

输入输出定义 连接参数 连接器无需认证，无连接参数。 定义输入 输入参数 此触发事件在流类型执行动作中使用，它的输入是在创建流类型执行动作的第二步“配置输入”中定义的，在该触发事件中单击右下角“mock数据”可以填写数据用于mock测试。 输出参数 和输入参数相同。 定义输出 输入参数

查看更多 →

条数据。 图3 设置数字输入框数据联动 输入框最小值：输入数字的最小值。 输入框最大值：输入数字的最大值。 当数字输入框为数据联动时，最大/最小值按组件默认配置，即最大值为253-1。 最大值不建议超过最大安全整数，若需填写更大数值，建议使用单行文本输入。 展示小数位：设置数字小数点后的位数。

查看更多 →

自定义”，输入数字，单击“√”保存。 以下为非必填项： 忽略“生产包”状态的文件：系统进行文件清理时将保留“生产包”状态的文件，请参考设置生产包的发布状态。 忽略文件路径：系统进行文件清理时将保留匹配用户设置的文件路径的软件包，支持设置多个文件路径(以”/“开头，多路径之间用英文分号隔开)。

查看更多 →

class Reducer类名 mapred.input.dir MapReduce处理数据的输入目录 mapred.output.dir MapReduce处理后结果数据输出目录 mapred.map.tasks MapReduce map任务个数 “${变量名}”表示：该值来自“job

查看更多 →

使用MapReduce 配置使用分布式缓存执行MapReduce任务 配置MapReduce shuffle address 配置MapReduce集群管理员列表 通过Windows系统提交MapReduce任务 配置MapReduce任务日志归档和清理机制 MapReduce性能调优

查看更多 →

运行单算子需要构造算子输入数据，并以二进制格式保存到算子工程下。cd $HOME/tools/projects/customop_te/operator/python data_gen.py reduction在算子工程中会生成如图1所示数据文件。数据文件说明如表1所示。

查看更多 →

语音输入输出 找到界面下方对话框，单击对话框左边的。 对着输入需要数智员工回答的问题提示词的语音。 单击，变成，即可播放数智员工回答的答案。 图1 语音输入界面 图2 语音输出界面 父主题： 实施步骤

查看更多 →

药物数据输入格式说明 药物虚拟筛选平台的输入数据，需要输入蛋白质和配体小分子数据。参考以下数据要求，将数据上传至项目中。 输入蛋白质，pdb格式，将要进行对接的所有靶标蛋白放在一个文件夹内。 输入配体小分子，配体小分子为如下格式的txt文件。 第一列为smiles字符串，第二列为smiles名称，中间用tab键分割。

查看更多 →

作业输入输出规范 用户完成自定义难例挖掘镜像上传后，在运行作业容器时，Octopus平台会向作业容器中注入以下环境变量： rosbag_path: 作为数据源的rosbag存放路径，例如/tmp/data/20220620.bag output_dir: 难例挖掘作业运行结果输出目录，例如/tmp/output

查看更多 →

作业输入输出规范 Input 平台会以环境变量的形式提供以下参数： rosbag_path： rosbag路径，以.bag结尾。 output_dir：最终输出路径，应为Opendata格式数据。 tmp_dir：供⽤户存储临时文件的⽬录。 task_content_json：⼈

查看更多 →

单行文本输入 单行文本输入用于录入普通的文本，且只能有一行。单行文本输入和多行文本输入、文本、富文本呈现的效果，如图1所示。 图1 各文本组件效果呈现图 在表单设计页面，从“常用控件”中，拖拽“单行文本输入”组件至表单设计区域，如图2所示。 图2 拖拽单行文本输入组件到设计区并设置属性

查看更多 →

如果列表中的选项不满足需要，可以自定义时间，单击“自定义”，输入数字，单击“√”保存。 以下为非必填项： 忽略“生产包”状态的文件：系统进行文件清理时将保留“生产包”状态的文件。 忽略文件路径：系统进行文件清理时将保留匹配用户设置的文件路径的软件包，支持设置多个文件路径(以”/“开头，多路径之间用英文分号隔开)。 父主题：

查看更多 →

\"/usr/bin/gtar\" could not handle archive."} 原因分析 安装路径输入不合法，部署Linux主机应用时输入Windows格式的路径。 处理方法 输入符合系统标准的安装路径。 父主题： 安装JDK

查看更多 →

\"/usr/bin/gtar\" could not handle archive."} 原因分析 安装路径输入不合法，部署Linux主机应用时输入Windows格式的路径。 处理方法 输入符合系统标准的安装路径。 父主题： 配置文件修改

查看更多 →

\"/usr/bin/gtar\" could not handle archive."} 原因分析 安装路径输入不合法，部署Linux主机应用时输入Windows格式的路径。 处理方法 输入符合系统标准的安装路径。 父主题： Ansible

查看更多 →