Hadoop中的TSV輸入Map Reduce

Question

我試圖運行一個簡單的地圖reduce操作TSV數據集，我對當我嘗試一個簡單的地圖操作時會出現什麼問題感到困惑。以下是我對地圖類的sample Word Count problem的修改。

public static class Map extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> { 
    private Text node = new Text(); 

    public void map(LongWritable key, Text value, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException { 
     String line = value.toString(); 
     String tokens[] = line.split('t'); 
     node.set(tokens[1]); 
     int weight = Integer.parseInt(tokens[2]); 
     output.collect(node, new Writable(weight)); 

    } 
    } 

該輸入可以可視化爲具有三列的TSV文件。上面的代碼在行被分割爲標記的行中出現錯誤method.java.lang.String.split being not applicable。任何想法，我可能會出錯？

Answer 1

String tokens [] = line.split（'t'）;

更改爲

字符串標記[] = line.split（ '\噸'）;

Answer 2

String tokens[] = line.split('t');

它應該是：

String tokens[] = line.split("\t");

使用單引號是char類型，並會引發異常。