Changeset 27 for sample/hadoop-0.16/tw/org/nchc/code
- Timestamp:
- Jul 3, 2008, 5:25:22 PM (16 years ago)
- 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 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/02/2008 6 * Upgrade to 0.177 6 */ 8 7 … … 163 162 conf.setNumReduceTasks(setup.reduceTasks); 164 163 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)); 168 165 169 166 conf.setMapperClass(IdentityMapper.class); -
sample/hadoop-0.16/tw/org/nchc/code/HBaseRecord2.java
r23 r27 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/01/2008 6 * Upgrade to 0.177 6 */ 8 7 … … 152 151 conf.setNumMapTasks(setup.mapTasks); 153 152 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)); 157 154 conf.setMapperClass(IdentityMapper.class); 158 155 conf.setCombinerClass(IdentityReducer.class); -
sample/hadoop-0.16/tw/org/nchc/code/HBaseRecordPro.java
r25 r27 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/02/2008 6 * Upgrade to 0.177 6 */ 8 7 -
sample/hadoop-0.16/tw/org/nchc/code/WordCount.java
r25 r27 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/02/2008 6 * Upgrade to 0.177 6 */ 8 7 -
sample/hadoop-0.16/tw/org/nchc/code/WordCountFromHBase.java
r25 r27 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/02/2008 6 * Upgrade to 0.177 6 */ 8 7 -
sample/hadoop-0.16/tw/org/nchc/code/WordCountIntoHBase.java
r23 r27 4 4 * From : NCHC. Taiwn 5 5 * Last Update Date: 07/02/2008 6 * Upgrade to 0.177 6 */ 8 7 … … 107 106 conf.setNumMapTasks(mapTasks); 108 107 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)); 112 109 conf.setMapperClass(IdentityMapper.class); 113 110 conf.setCombinerClass(IdentityReducer.class);
Note: See TracChangeset
for help on using the changeset viewer.