public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
StringTokenizer itr = new StringTokenizer(value.toString(), "\n");
while (itr.hasMoreTokens()) {
filename = ((FileSplit) context.getInputSplit()).getPath().getName();
term.set(itr.nextToken());
offset.set(((LongWritable) key).get());
if(key.toString() == "cipher")
result.set(filename + '@' + offset.toString() + '@' + value.toString());
else
result.set(filename + '@' + offset.toString());
context.write(term, result);
}
}
在 2014年7月20日星期日UTC+8上午3时21分09秒,杨博文写道: