尚硅谷大數據技術之Flume(新）第5章 Flume高級之自定義MySQLSource
5.5.3 MySql表準備
1)?創建MySqlSource數據庫
CREATE DATABASE mysqlsource；
2) 在MySqlSource數據庫下創建數據表Student和元數據表Flume_meta
CREATE TABLE `student` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL,
PRIMARY KEY (`id`)
);
CREATE TABLE `flume_meta` (
`source_tab` varchar(255) NOT NULL,
`currentIndex` varchar(255) NOT NULL,
PRIMARY KEY (`source_tab`)
);
- 向數據表中添加數據
1?zhangsan
2?lisi
3?wangwu
4?zhaoliu
5.5.4?測試并查看結果
- 任務執行
[atguigu@hadoop102 flume]$ bin/flume-ng agent --conf conf/ --name a1 \
--conf-file job/mysql.conf -Dflume.root.logger=INFO,console
- 結果展示，如圖6-2所示：
圖6-2 結果展示
