| 4 | | 注意要点:[[BR]] |
| | 5 | |
| | 6 | == 使用HBASE作为输入 == |
| | 7 | |
| | 8 | {{{ |
| | 9 | public static class MapClass extends TableMapper... |
| | 10 | }}} |
| | 11 | 可以使用TableInputFormate的参数 |
| | 12 | |
| | 13 | hbase.mapreduce.inputtable |
| | 14 | hbase.mapreduce.scan /** 输入字符串转换为Scan */ |
| | 15 | hbase.mapreduce.scan.row.start /** Scan start row */ |
| | 16 | hbase.mapreduce.scan.row.stop /** Scan stop row */ |
| | 17 | hbase.mapreduce.scan.column.family /** Column Family to Scan */ |
| | 18 | hbase.mapreduce.scan.columns /** Space delimited list of columns to scan. */ |
| | 19 | hbase.mapreduce.scan.timestamp /** The timestamp used to filter columns with a specific timestamp. */ |
| | 20 | hbase.mapreduce.scan.timerange.start |
| | 21 | hbase.mapreduce.scan.timerange.end |
| | 22 | hbase.mapreduce.scan.maxversions |
| | 23 | hbase.mapreduce.scan.cacheblocks /** Set to false to disable server-side caching of blocks for this scan. */ |
| | 24 | hbase.mapreduce.scan.cachedrows /** The number of rows for caching that will be passed to scanners. */ |
| | 25 | |
| | 26 | |
| | 27 | == 注意要点:[[BR]] == |
| | 28 | |