模板介绍

模板说明

CDC或者MQ中的实时流数据如果选择传入本组件，则本组件会对实时流中的数据字段进行转换、清洗等操作，通过本组件可以让实时流数据与批数据进行合并以打宽实时数据表

流程图

依赖表结构

CREATE TABLE `orders` (
  `id` int(11) NOT NULL,
  `user_id` int(11) DEFAULT NULL,
  `product` varchar(50) DEFAULT NULL,
  `quantity` int(11) DEFAULT NULL,
  `price` decimal(10,2) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

CREATE TABLE `users` (
  `id` int(11) NOT NULL,
  `name` varchar(50) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  `gender` varchar(10) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

CREATE TABLE `order_test` (
  `id` int(10) NOT NULL,
  `user_id` int(10) DEFAULT NULL,
  `product` varchar(50) DEFAULT '',
  `quantity` int(10) DEFAULT NULL,
  `price` decimal(10,2) DEFAULT NULL,
  `name` varchar(50) DEFAULT '',
  `age` int(10) DEFAULT NULL,
  `gender` varchar(10) DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

使用评价