1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.giraph.examples;
20
21 import org.apache.giraph.graph.Vertex;
22 import org.apache.giraph.io.formats.TextVertexOutputFormat;
23 import org.apache.hadoop.io.DoubleWritable;
24 import org.apache.hadoop.io.LongWritable;
25 import org.apache.hadoop.io.NullWritable;
26 import org.apache.hadoop.io.Text;
27 import org.apache.hadoop.mapreduce.TaskAttemptContext;
28
29 import java.io.IOException;
30
31
32
33
34
35 public class VertexWithDoubleValueNullEdgeTextOutputFormat extends
36 TextVertexOutputFormat<LongWritable, DoubleWritable, NullWritable> {
37 @Override
38 public TextVertexWriter createVertexWriter(TaskAttemptContext context)
39 throws IOException, InterruptedException {
40 return new VertexWithDoubleValueWriter();
41 }
42
43
44
45
46
47 public class VertexWithDoubleValueWriter extends TextVertexWriter {
48 @Override
49 public void writeVertex(
50 Vertex<LongWritable, DoubleWritable, NullWritable> vertex)
51 throws IOException, InterruptedException {
52 StringBuilder output = new StringBuilder();
53 output.append(vertex.getId().get());
54 output.append('\t');
55 output.append(vertex.getValue().get());
56 getRecordWriter().write(new Text(output.toString()), null);
57 }
58 }
59 }