1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.giraph.reducers.impl;
20
21 import java.io.DataInput;
22 import java.io.DataOutput;
23 import java.io.IOException;
24 import org.apache.giraph.reducers.ReduceSameTypeOperation;
25 import org.apache.hadoop.io.LongWritable;
26
27
28
29
30 public class LongXorReduce extends ReduceSameTypeOperation<LongWritable> {
31
32
33
34 public static final LongXorReduce INSTANCE = new LongXorReduce();
35
36
37 public LongXorReduce() {
38 }
39
40 @Override public LongWritable createInitialValue() {
41 return new LongWritable(0L);
42 }
43
44 @Override public LongWritable reduce(LongWritable curValue,
45 LongWritable valueToReduce) {
46 curValue.set(curValue.get() ^ valueToReduce.get());
47 return curValue;
48 }
49
50 @Override public void write(DataOutput out) throws IOException {
51 }
52
53 @Override public void readFields(DataInput in) throws IOException {
54 }
55 }