普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
运维指南
  • 阻塞数据直到步骤都完成组件-阻塞直到步骤完成
  • 开发步骤

# 阻塞数据直到步骤都完成组件-阻塞直到步骤完成

一个作业中两个转换让其中一个转换按照最后输出。 主要步骤如下:

  • 模型
  • 开发步骤
    • 准备数据
    • 关系型数据库配置
    • 直接写日志
    • 关系型数据库配置1
    • 阻塞组件配置
    • 阻塞组件下游日志
    • 运行结果 input

# 开发步骤

# 步骤1:准备数据

DROP TABLE IF EXISTS `students`;
CREATE TABLE `students` (
`ID` int NOT NULL,
`NAME` varchar(10) DEFAULT NULL,
`AGE` decimal(3,0) DEFAULT NULL,
`GENDER` varchar(10) DEFAULT NULL,
PRIMARY KEY (`ID`)
) ;

INSERT INTO `students` (`ID`, `NAME`, `AGE`, `GENDER`) VALUES (10001, 'WARD', 25, 'male');
INSERT INTO `students` (`ID`, `NAME`, `AGE`, `GENDER`) VALUES (10002, 'JONES', 32, 'female');
INSERT INTO `students` (`ID`, `NAME`, `AGE`, `GENDER`) VALUES (10003, 'BLAKE', 15, 'female');
INSERT INTO `students` (`ID`, `NAME`, `AGE`, `GENDER`) VALUES (10004, 'SCOTT', 53, 'male');
INSERT INTO `students` (`ID`, `NAME`, `AGE`, `GENDER`) VALUES (10005, 'KING', 22, 'no');

# 步骤2:关系型数据库配置

选择造好的数据进行输入。

input

# 步骤3:直接写日志

未阻塞数据直接写日志。

input

# 步骤4:关系型数据库配置1

选择造好的数据进行输入。

input

# 步骤5:阻塞组件配置

在阻塞组件中选择上游步骤。

input

# 步骤6:阻塞组件下游日志

对阻塞的数据进行日志输出。

input

# 最后一步:运行结果

运行结果如下,阻塞日志在最后面才进行输出,也就是等所有步骤运行完成才会运行它。

input

← 阻塞到最后一行组件-阻塞到最后一行 Rest Client组件-Rest请求1 →