VPReducer.java 文件源码

@Override
public void reduce(Text key, Iterable<TextPair> values, Context context) throws IOException, InterruptedException {
    for (TextPair value : values) {
        // Use key (Predicate) as folder name for Vertical Partitioning
        multipleOutputs.write(NullWritable.get(), new Text(value.getFirst() + "\t" + value.getSecond()),
                Util.generateFileName(key.toString()));
        // Write all parsed triples also to "inputData" for queries where Predicate is not known
        multipleOutputs.write(NullWritable.get(), new Text(value.getFirst() + "\t" + key.toString() + "\t" + value.getSecond()),
                Util.generateFileName("inputData"));
    }

}