• 資料夾

/tmp/ProductEmp/conf/store.txt	商品資訊檔
/tmp/ProductEmp/input/	銷售紀錄資料夾
/tmp/ProductEmp/hdfs/	hadoop運算資料夾
/tmp/ProductEmp/out/	hadoop 輸出
/tmp/ProductEmp/result/db.js	最後結果檔

設定初始內容

• /tmp/ProductEmp/conf/store.txt

  01 ; 微波爐 ; 3000
  02 ; 烤箱   ; 800
  03 ; 電暖氣 ; 1000
  04 ; 收音機 ; 300
  05 ; 冷氣機 ; 30000
  

• /tmp/ProductEmp/input/0102.txt

  jazz:   01
  jazz:   02
  jazz:   02
  jazz:   03
  jazz:   05
  jazz:   01
  lia:    02
  lia:    03
  waue:   02
  shun:   02
  len:    02
  

運算後最後結果將會呈現

• /tmp/ProductEmp/result/db.js

  var aDataSet = [
          ['01','微波爐','3000','2','6000'],
          ['02','烤箱','800','6','4800'],
          ['03','電暖氣','1000','3','3000'],
          ['04','收音機','300','0','0'],
          ['05','冷氣機','30000','1','30000']
  ];
  
  

               BufferedReader fi = new BufferedReader(
                                new FileReader(new File(file_in)));

                String line;
                while ((line = fi.readLine()) != null) {

                        String[] str = line.split(";");
                        int length = str.length -1;

                        for (int i = 0; i < length; i++) {
                                E2PutData.putData(table_name, str[0], family, "P" + (i+1),
                                                str[(i + 1)]);
                        }
                        System.out.println();
                }
                fi.close();