Page History

 public static class PagerankTextReaderWikipediaLinkDatasetReader extends
      VertexInputReader<LongWritable, Text, Text, NullWritable, DoubleWritable> {

    @Override
    public boolean parseVertex(LongWritable key, Text value,
        Vertex<Text, DoubleWritableNullWritable, NullWritable>DoubleWritable> vertex) {
      String[] vertexAdjacents = value.toString().split(":");
      vertex.setVertexID(new Text(vertexAdjacents[0].trim()));
      String[] split = vertexAdjacents[1].split(" ");
      for (int i = 0; i < split.length; i++) {
        if (!split[i].isEmpty()) {
          vertex.addEdge(new Edge<Text, NullWritable>(
              new Text(split[i].trim()), null));
        }
      }
      return true;
    }
  }