Ignore:
Timestamp:
Jul 3, 2008, 5:25:22 PM (16 years ago)
Author:
waue
Message:

test!

Location:
sample/hadoop-0.16/tw/org/nchc/code
Files:
6 edited

Legend:

Unmodified
Added
Removed
  • sample/hadoop-0.16/tw/org/nchc/code/HBaseRecord.java

    r23 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/02/2008
    6  * Upgrade to 0.17
    76 */
    87
     
    163162    conf.setNumReduceTasks(setup.reduceTasks);
    164163
    165     // 0.16
    166     // conf.setInputPath(new Path(setup.file_path));
    167     Convert.setInputPath(conf, new Path(setup.file_path));
     164    conf.setInputPath(new Path(setup.file_path));
    168165
    169166    conf.setMapperClass(IdentityMapper.class);
  • sample/hadoop-0.16/tw/org/nchc/code/HBaseRecord2.java

    r23 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/01/2008
    6  * Upgrade to 0.17
    76 */
    87
     
    152151    conf.setNumMapTasks(setup.mapTasks);
    153152    conf.setNumReduceTasks(setup.reduceTasks);
    154     // 0.16
    155 //    conf.setInputPath(new Path(setup.file_path));
    156     Convert.setInputPath(conf, new Path(setup.file_path));
     153    conf.setInputPath(new Path(setup.file_path));
    157154    conf.setMapperClass(IdentityMapper.class);
    158155    conf.setCombinerClass(IdentityReducer.class);
  • sample/hadoop-0.16/tw/org/nchc/code/HBaseRecordPro.java

    r25 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/02/2008
    6  * Upgrade to 0.17
    76 */
    87
  • sample/hadoop-0.16/tw/org/nchc/code/WordCount.java

    r25 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/02/2008
    6  * Upgrade to 0.17
    76 */
    87
  • sample/hadoop-0.16/tw/org/nchc/code/WordCountFromHBase.java

    r25 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/02/2008
    6  * Upgrade to 0.17
    76 */
    87
  • sample/hadoop-0.16/tw/org/nchc/code/WordCountIntoHBase.java

    r23 r27  
    44 * From :  NCHC. Taiwn
    55 * Last Update Date: 07/02/2008
    6  * Upgrade to 0.17
    76 */
    87
     
    107106    conf.setNumMapTasks(mapTasks);
    108107    conf.setNumReduceTasks(reduceTasks);
    109     // 0.16
    110     // conf.setInputPath(new Path(Input_Path));
    111     Convert.setInputPath(conf, new Path(Input_Path));
     108    conf.setInputPath(new Path(Input_Path));   
    112109    conf.setMapperClass(IdentityMapper.class);
    113110    conf.setCombinerClass(IdentityReducer.class);
Note: See TracChangeset for help on using the changeset viewer.