? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?Kettle使用_13 表輸入并發運行與復制數量

需求: 通過并行方式完成事實表sales_fact_1998（該表有約16萬條記錄）到文本的輸出。

解決方法：結合表輸入和文件文本輸出組件解決，這里需要同時設置表輸入、文本文件輸出組件的復制數量。

Previous work:

準備FoodMart數據庫并初始化數據。其中建表語句(以Mysql為例)見下：

CREATE TABLE `sales_fact_1998` (`product_id` int(11) NOT NULL,`time_id` int(11) NOT NULL,`customer_id` int(11) NOT NULL,`promotion_id` int(11) NOT NULL,`store_id` int(11) NOT NULL,`store_sales` decimal(10,4) NOT NULL,`store_cost` decimal(10,4) NOT NULL,`unit_sales` decimal(10,4) NOT NULL,KEY `i_sls_98_cust_id` (`customer_id`),KEY `i_sls_1998_prod_id` (`product_id`),KEY `i_sls_1998_promo` (`promotion_id`),KEY `i_sls_1998_store` (`store_id`),KEY `i_sls_1998_time_id` (`time_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

完整的數據（含建表語句）見下：

鏈接：https://pan.baidu.com/s/1RcW1i-U3PD64t3r28SmqJg

提取碼：6yee

Step1：新建個轉換。

Step2：找到表輸入組件，該組件在轉換里的輸入分類下。

Step3：配置標輸入組件，這里讀取表里所有數據。

Step4：拖文本文件輸出組件到轉換里。

Step5：通過SHIFT連接表輸入組件和文本文件輸出組件,選擇主輸出步驟。

Step6：配置文本文件輸出組件。

Step7：同時配置表輸入組件和文本文件輸出組件的復制數量，這里都設置為4。

完整流程示意:

Step8：運行驗證。

總結

以上是生活随笔為你收集整理的Kettle使用_13 表输入并发运行与复制数量的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。