全托管式的Kafka消息队列。 DLI 支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。创建DMS Kafka输入流的语法与创建开源Apache Kafka输入流一样，具体请参见开源Kafka输入流。 父主题： 创建输入流

查看更多 →

创建输入流 CloudTable HBase输入流 DIS输入流 DMS输入流 MRS Kafka输入流 开源Kafka输入流 OBS输入流 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）

查看更多 →

目前只适用于 CS V格式。 设置引用符号后，必须保证每个字段中包含0个或者偶数个引用符号，否则会解析失败。 version_id 否 版本号，当obs里的桶或对象有设置版本的时候需填写，否则不用配置该项。 注意事项 在创建Source Stream时可以指定时间模型以便在后续计算中使用，当前DLI支持Processing

查看更多 →

托管式的Kafka消息队列。 DLI支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。 创建DMS Kafka输入流的语法与创建开源Apache Kafka输入流一样，具体请参见开源Kafka输入流。 父主题： 创建输入流

查看更多 →

类型：配置字段类型。 数据格式：字段类型为“DATE”或“TIM”E或“TIMESTAMP”时，需指定特定时间格式，其他字段类型指定无效。时间格式如：“yyyyMMdd HH:mm:ss”。 长度：配置字段长度，字段值太长则按配置的长度截取，类型为“CHAR”时实际长度不足则空格补齐，类

查看更多 →

"type": "string" } } } 状态码 正常 状态码如表3所示。 表3 状态码 状态码 描述 200 流程输入查询成功 异常 状态码如6.3-状态码所示。 父主题： Workflow

查看更多 →

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

查看更多 →

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

查看更多 →

在“Notebook”区域下，新建一个ipynb文件。 在新建的Notobook中，在代码输入栏输入如下命令。 !pip install xxx 在Terminal中安装 在Terminal里激活需要的anaconda python环境后再进行安装。 例如，通过terminal在“TensorFlow-1

查看更多 →

get_workflow_inputs(workflow_id)查询流程输入。

查看更多 →

任务输入/输出参数 task.input（任务输入参数） task.input参数说明 参数 是否必选 类型 说明 type 是 String 视频数据的输入类型： obs：表示从华为云OBS中读取视频数据。 url：表示从指定的URL地址中读取视频数据。 edgecamera：表示从指定的边缘摄像头读取数据。

查看更多 →

配置分析任务输入 点击目标分析任务，如下图1所示。 图1 目标分析任务 点击资产ID的修改图标进行修改，如下图2所示（只有属性引用类型为“引用其他资产属性”的输入参数需要配置资产ID）。 图2 资产ID 父主题： 工作台

查看更多 →

待读取数据的表名，如需指定namespace，可表示为：namespace_name:table_name 。 table_columns 是 待读取的列，具体形式如："rowKey,f1:c1,f1:c2,f2:c1"，并且保证与source相同的列数。 注意事项 在创建Source Stream时可以

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

帮助提示：为字段添加帮助信息。设置后，标题字段后会显示。 描述信息：为字段添加附件的说明信息。 状态：设置字段的状态，如普通、禁用、只读和隐藏。 普通：设置为普通后，页面上该字段可正常显示，且可进行配置。 只读：设置为只读后，页面上该字段只可读。 禁用：设置为禁用后，页面上该字段仍可显示，但不可进行配置。

查看更多 →

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

查看更多 →

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

查看更多 →

指定无效。时间格式如：“yyyyMMdd HH:mm:ss”。 长度：配置字段长度，字段值实际长度太长则按配置的长度截取，“类型”为“CHAR”时实际长度不足则空格补齐，“类型”为“VARCHAR”时实际长度不足则不补齐。 map 是 无 数据处理规则 按照输入字段的长度依次截取源文件，生成字段。

查看更多 →

不支持对LOB字段设置过滤条件，如CLOB、BLOB、BYTEA等大字段类型。 不支持库名、表名带有换行符的对象设置过滤规则。 不支持for update等行级锁的语法做过滤条件。 不支持对列名做函数操作，如果使用函数操作可能导致数据不一致。 建议不要对非精确类型字段设置过滤条件，如FLOAT、DECIMAL、DOUBLE等。

查看更多 →