如何在映射器中将字符串作为值传递？

Question

我试图在映射器中将字符串作为值传递，但收到错误，表明它不可写。如何解决？

public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {

    String TempString = value.toString();
    String[] SingleRecord = TempString.split("\t");

    //using Integer.parseInt to calculate profit
    int Amount = Integer.parseInt(SingleRecord[7]);
    int Asset = Integer.parseInt(SingleRecord[8]);
    int SalesPrice = Integer.parseInt(SingleRecord[9]);
    int Profit = Amount*(SalesPrice-Asset);

    String ValueProfit = String.valueOf(Profit);
    String ValueOne = String.valueOf(one);

    custID.set(SingleRecord[2]);
    data.set(ValueOne + ValueProfit);
    context.write(custID, data);

}

Answer 1

Yahoo 的教程说：
可以通过网络与文件进行编组或从文件编组的对象必须遵循称为 Writable 的特定接口，该接口允许 Hadoop 以序列化的方式读取和写入数据传输格式。

来自 Cloudera 网站：
键和值类必须可由框架序列化，因此必须实现 Writable 接口。此外，关键类必须实现 WritableComparable 接口以方便排序。

所以你需要一个Writable 的实现来将它写为上下文中的一个值。 Hadoop 附带了一些股票类，例如IntWritable。您正在寻找的 String 对应物是 Text 类。它可以用作：

context.write(custID, new Text(data));

或

Text outValue = new Text();
val.set(data);
context.write(custID, outValue)   

我的情况，你需要在值类中专门的功能，你可以实现Writable（毕竟没什么大不了的）。但是似乎Text 对你来说已经足够了。

Answer 2

你没有按照上面的导入文本在map函数中设置数据，TextWritable是错误的，用Text也是。