http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoubleConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoubleConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoubleConsumer.java
index ca98ff0..b7c7a9b 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoubleConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, double) -> void
+ * (float, double) -> void
  */
 public interface FloatDoubleConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoublePredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoublePredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoublePredicate.java
index e410711..348440a 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoublePredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, double) -> boolean
+ * (float, double) -> boolean
  */
 public interface FloatDoublePredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatConsumer.java
index eb54a24..f37f62b 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, float) -> void
+ * (float, float) -> void
  */
 public interface FloatFloatConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatPredicate.java
index 3abfcef..66e716d 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, float) -> boolean
+ * (float, float) -> boolean
  */
 public interface FloatFloatPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntConsumer.java
index 3842846..08045b6 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, int) -> void
+ * (float, int) -> void
  */
 public interface FloatIntConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntPredicate.java
index d65be01..5fb1a3c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, int) -> boolean
+ * (float, int) -> boolean
  */
 public interface FloatIntPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongConsumer.java
index 28bf849..5553807 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, long) -> void
+ * (float, long) -> void
  */
 public interface FloatLongConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongPredicate.java
index 4a13e7d..e05c86c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (float, long) -> boolean
+ * (float, long) -> boolean
  */
 public interface FloatLongPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanConsumer.java
index f9786d2..e41d9a8 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, boolean) -> void
+ * (int, boolean) -> void
  */
 public interface IntBooleanConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanPredicate.java
index 19e8dba..4c8fb50 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, boolean) -> boolean
+ * (int, boolean) -> boolean
  */
 public interface IntBooleanPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntByteConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntByteConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntByteConsumer.java
index 4578d2e..a651f63 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntByteConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, byte) -> void
+ * (int, byte) -> void
  */
 public interface IntByteConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBytePredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBytePredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBytePredicate.java
index bc4d33f..13040c5 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBytePredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, byte) -> boolean
+ * (int, byte) -> boolean
  */
 public interface IntBytePredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoubleConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoubleConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoubleConsumer.java
index 29c721c..56b0c8b 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoubleConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, double) -> void
+ * (int, double) -> void
  */
 public interface IntDoubleConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoublePredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoublePredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoublePredicate.java
index d8ef5c3..2611a24 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoublePredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, double) -> boolean
+ * (int, double) -> boolean
  */
 public interface IntDoublePredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatConsumer.java
index 9ec2e00..36fc692 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, float) -> void
+ * (int, float) -> void
  */
 public interface IntFloatConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatPredicate.java
index 21cb455..fbe417e 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, float) -> boolean
+ * (int, float) -> boolean
  */
 public interface IntFloatPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntConsumer.java
index f08c5bd..568a44f 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, int) -> void
+ * (int, int) -> void
  */
 public interface IntIntConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntPredicate.java
index d8d42b4..93dad62 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, int) -> boolean
+ * (int, int) -> boolean
  */
 public interface IntIntPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongConsumer.java
index 8e8a258..21dd217 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, long) -> void
+ * (int, long) -> void
  */
 public interface IntLongConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongPredicate.java
index b485bff..05921a6 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/IntLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (int, long) -> boolean
+ * (int, long) -> boolean
  */
 public interface IntLongPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanConsumer.java
index 57958a7..a6210af 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, boolean) -> void
+ * (long, boolean) -> void
  */
 public interface LongBooleanConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanPredicate.java
index 951e893..d37066a 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, boolean) -> boolean
+ * (long, boolean) -> boolean
  */
 public interface LongBooleanPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongByteConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongByteConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongByteConsumer.java
index ff94dd5..9a46091 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongByteConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, byte) -> void
+ * (long, byte) -> void
  */
 public interface LongByteConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBytePredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBytePredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBytePredicate.java
index bf30a1e..bdaf74c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBytePredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, byte) -> boolean
+ * (long, byte) -> boolean
  */
 public interface LongBytePredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoubleConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoubleConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoubleConsumer.java
index a4e6372..a12f416 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoubleConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, double) -> void
+ * (long, double) -> void
  */
 public interface LongDoubleConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoublePredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoublePredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoublePredicate.java
index 01a9541..ae683ca 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoublePredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, double) -> boolean
+ * (long, double) -> boolean
  */
 public interface LongDoublePredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatConsumer.java
index 3747a39..da9e04f 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, float) -> void
+ * (long, float) -> void
  */
 public interface LongFloatConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatPredicate.java
index 0330582..b52a520 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, float) -> boolean
+ * (long, float) -> boolean
  */
 public interface LongFloatPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntConsumer.java
index b8d1d41..2e8bdd4 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, int) -> void
+ * (long, int) -> void
  */
 public interface LongIntConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntPredicate.java
index 95b2834..3e89172 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, int) -> boolean
+ * (long, int) -> boolean
  */
 public interface LongIntPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongConsumer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongConsumer.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongConsumer.java
index 5d7085f..c061fc7 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongConsumer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, long) -> void
+ * (long, long) -> void
  */
 public interface LongLongConsumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongPredicate.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongPredicate.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongPredicate.java
index 0bc7f61..e522a3d 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongPredicate.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/LongLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
 
 /**
  * Primitive specialization of Function:
- * (long, long) -> boolean
+ * (long, long) -> boolean
  */
 public interface LongLongPredicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/vertex/ConsumerWithVertex.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/ConsumerWithVertex.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/ConsumerWithVertex.java
index 3b6ba0e..d4ad58c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/ConsumerWithVertex.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/ConsumerWithVertex.java
@@ -27,7 +27,7 @@ import org.apache.hadoop.io.WritableComparable;
 
 /**
  * Function:
- * (vertex, T) -> void
+ * (vertex, T) -> void
  *
  * A class that can consume objects of a single type, when given a vertex.
  *

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/vertex/FunctionWithVertex.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/FunctionWithVertex.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/FunctionWithVertex.java
index e7552c9..a8f5890 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/FunctionWithVertex.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/FunctionWithVertex.java
@@ -26,7 +26,7 @@ import org.apache.hadoop.io.WritableComparable;
 
 /**
  * Function:
- * (vertex, F) -> T
+ * (vertex, F) -> T
  *
  * Determines an output value based on a vertex and an input value.
  *

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/vertex/SupplierFromVertex.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/SupplierFromVertex.java
 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/SupplierFromVertex.java
index bf2a4b1..894926e 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/function/vertex/SupplierFromVertex.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/function/vertex/SupplierFromVertex.java
@@ -25,12 +25,12 @@ import org.apache.hadoop.io.WritableComparable;
 
 /**
  * Function:
- * (vertex) -> T
+ * (vertex) -> T
  *
  * A class that can supply objects of a single type, when given a vertex.
  *
- * (doesn't extend Function<Vertex<I, V, E>, T>, because of different
- * method names)
+ * (doesn't extend Function&lt;Vertex&lt;I, V, E&gt;, T&gt;,
+ * because of different method names)
  *
  * @param <I> Vertex id type
  * @param <V> Vertex value type

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java 
b/giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java
index 086bc48..a4b61b2 100644
--- a/giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java
+++ b/giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java
@@ -37,7 +37,7 @@ import org.apache.hadoop.mapreduce.Mapper;
  * See {@link Computation} for explanation of the interface.
  *
  * This is a abstract class helper for users to implement their computations.
- * It implements all of the methods required by the {@link Computation
+ * It implements all of the methods required by the {@link Computation}
  * interface except for the {@link #compute(Vertex, Iterable)} which we leave
  * to the user to define.
  *
@@ -101,9 +101,8 @@ public abstract class AbstractComputation<I extends 
WritableComparable,
    *
    * @param graphState Graph state
    * @param workerClientRequestProcessor Processor for handling requests
-   * @param graphTaskManager Graph-wide BSP Mapper for this Vertex
+   * @param serviceWorker Graph-wide BSP Mapper for this Vertex
    * @param workerGlobalCommUsage Worker global communication usage
-   * @param workerContext Worker context
    */
   @Override
   public void initialize(

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
 
b/giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
index 19034ca..c261efb 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
@@ -145,7 +145,7 @@ public class GiraphTransferRegulator {
     edgeAccumulator.clear();
   }
 
-  /** Increment V & E counts for new vertex read, store values
+  /** Increment V &amp; E counts for new vertex read, store values
    * for that outgoing _temporary_ Partition, which shares the
    * Partition ID for the actual remote Partition the collection
    * will eventually be processed in.

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java 
b/giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java
index 1f4451f..9dcd70e 100644
--- a/giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java
+++ b/giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java
@@ -50,7 +50,6 @@ public abstract class EdgeInputFormat<I extends 
WritableComparable,
    * @param context the information about the task
    * @return a new record reader
    * @throws IOException
-   * @throws InterruptedException
    */
   public abstract EdgeReader<I, E> createEdgeReader(
       InputSplit split,

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java 
b/giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java
index 83a0369..848106d 100644
--- a/giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java
+++ b/giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java
@@ -28,7 +28,7 @@ import org.apache.hadoop.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 
 /**
- * Analogous to {@link org.apache.giraph.bsp.BspRecordReader} for edges.
+ * Analogous to org.apache.giraph.bsp.BspRecordReader for edges.
  * Will read the edges from an input split.
  *
  * @param <I> Vertex id

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
 
b/giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
index 8efbfd0..9c129cb 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
@@ -30,7 +30,8 @@ import java.io.IOException;
  * OutputFormat to write out the graph nodes as text, value-separated (by
  * tabs, by default).  With the default delimiter, a vertex is written out as:
  *
- * <VertexId><tab><Vertex Value><tab>[<EdgeId><tab><EdgeValue>]+
+ * &lt;VertexId&gt;&lt;tab&gt;&lt;Vertex Value&gt;&lt;tab&gt;
+ * [&lt;EdgeId&gt;&lt;tab&gt;&lt;EdgeValue&gt;]+
  *
  * @param <I> Vertex index value
  * @param <V> Vertex value

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
 
b/giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
index 4d47862..014b41f 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
@@ -50,7 +50,7 @@ public class LongLongNullTextInputFormat extends
   }
 
   /**
-   * Vertex reader associated with {@link LongLongNullLongTextInputFormat}.
+   * Vertex reader associated with {@link LongLongNullTextInputFormat}.
    */
   public class LongLongNullVertexReader extends
       TextVertexReaderFromEachLineProcessed<String[]> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java 
b/giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java
index 87c823c..8b035de 100644
--- a/giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java
+++ b/giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java
@@ -20,8 +20,10 @@ package org.apache.giraph.jython;
 import org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable;
 import org.apache.giraph.edge.Edge;
 import org.apache.giraph.edge.OutEdges;
+import org.apache.giraph.graph.Computation;
 import org.apache.giraph.graph.GraphType;
 import org.apache.giraph.graph.Vertex;
+import org.apache.giraph.jython.wrappers.JythonWritableWrapper;
 import org.apache.giraph.worker.WorkerContext;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableComparable;
@@ -63,7 +65,7 @@ public abstract class JythonComputation extends
 
   /**
    * Prepare for computation. This method is executed exactly once prior to
-   * {@link #compute(Vertex, Iterable)} being called for any of the vertices
+   * {@link #compute(Object, Iterable)} being called for any of the vertices
    * in the partition.
    */
   public void preSuperstep() { }

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java
 
b/giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java
index d1022a7..4b78b89 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java
@@ -18,6 +18,7 @@
 package org.apache.giraph.jython;
 
 import org.apache.giraph.graph.AbstractComputation;
+import org.apache.giraph.graph.Computation;
 import org.apache.giraph.graph.GraphType;
 import org.apache.giraph.graph.Language;
 import org.apache.giraph.graph.Vertex;

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
 
b/giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
index 45f6387..ea03bac 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
@@ -17,6 +17,7 @@
  */
 package org.apache.giraph.jython.factories;
 
+import org.apache.giraph.factories.MessageValueFactory;
 import org.apache.giraph.jython.JythonOptions;
 import org.apache.hadoop.io.Writable;
 

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/mapping/AbstractLongByteOps.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/mapping/AbstractLongByteOps.java 
b/giraph-core/src/main/java/org/apache/giraph/mapping/AbstractLongByteOps.java
index 2e2310b..f020ec1 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/mapping/AbstractLongByteOps.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/mapping/AbstractLongByteOps.java
@@ -37,7 +37,7 @@ public abstract class AbstractLongByteOps
   }
 
   /**
-   * Compute partition given id, partitionCount, workerCount & target
+   * Compute partition given id, partitionCount, workerCount &amp; target
    * @param id vertex id
    * @param partitionCount number of partitions
    * @param workerCount number of workers

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/mapping/LongByteMappingStore.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/mapping/LongByteMappingStore.java 
b/giraph-core/src/main/java/org/apache/giraph/mapping/LongByteMappingStore.java
index afee7d2..ab35cdc 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/mapping/LongByteMappingStore.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/mapping/LongByteMappingStore.java
@@ -37,7 +37,7 @@ import com.google.common.collect.MapMaker;
 
 /**
  *
- * An implementation of MappingStore<LongWritable, ByteWritable>
+ * An implementation of MappingStore&lt;LongWritable, ByteWritable&gt;
  *
  * Methods implemented here are thread safe by default because it is guaranteed
  * that each entry is written to only once.

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/LongByteTranslateEdge.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/LongByteTranslateEdge.java
 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/LongByteTranslateEdge.java
index 102ef50..c0abc12 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/LongByteTranslateEdge.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/LongByteTranslateEdge.java
@@ -31,7 +31,7 @@ import org.apache.hadoop.io.Writable;
 
 /**
  * Basic implementation of Translate Edge
- * where I = LongWritable & B = ByteWritable
+ * where I = LongWritable &amp; B = ByteWritable
  *
  * @param <E> edge value type
  */

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/TranslateEdge.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/TranslateEdge.java
 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/TranslateEdge.java
index 85e8768..1d89196 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/TranslateEdge.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/TranslateEdge.java
@@ -40,7 +40,7 @@ public interface TranslateEdge<I extends WritableComparable, 
E extends Writable>
   void initialize(BspServiceWorker<I, ? extends Writable, E> service);
 
   /**
-   * Translate Id & return a new instance
+   * Translate Id &amp; return a new instance
    *
    * @param targetId edge target Id
    * @return a new translated Id instance

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/package-info.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/package-info.java
 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/package-info.java
index 8536e83..e842352 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/mapping/translate/package-info.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/mapping/translate/package-info.java
@@ -17,6 +17,6 @@
  */
 
 /**
- * Definitions & sample implementations of edge translation logic
+ * Definitions &amp; sample implementations of edge translation logic
  */
 package org.apache.giraph.mapping.translate;

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/master/AggregatorToGlobalCommTranslation.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/master/AggregatorToGlobalCommTranslation.java
 
b/giraph-core/src/main/java/org/apache/giraph/master/AggregatorToGlobalCommTranslation.java
index 60538e2..c392116 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/master/AggregatorToGlobalCommTranslation.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/master/AggregatorToGlobalCommTranslation.java
@@ -113,7 +113,7 @@ public class AggregatorToGlobalCommTranslation
   }
 
   /**
-   * Called after master compute, to do aggregator->reduce/broadcast
+   * Called after master compute, to do aggregator-&gt;reduce/broadcast
    * translation
    */
   public void postMasterCompute() {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/metrics/GiraphMetricsRegistry.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/metrics/GiraphMetricsRegistry.java
 
b/giraph-core/src/main/java/org/apache/giraph/metrics/GiraphMetricsRegistry.java
index cb97fbe..ab2fad7 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/metrics/GiraphMetricsRegistry.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/metrics/GiraphMetricsRegistry.java
@@ -274,8 +274,7 @@ public class GiraphMetricsRegistry {
    * Get a Gauge that is already present in the MetricsRegistry
    *
    * @param name String name of Gauge
-   * @param <T> value type Gauge returns
-   * @return Gauge<T> from MetricsRegistry
+   * @return Gauge&lt;T&gt; from MetricsRegistry
    */
   public <T> Gauge<T> getExistingGauge(String name) {
     Metric metric = registry.allMetrics().get(makeMetricName(name));

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java 
b/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
index 33fe114..38b879b 100644
--- a/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
+++ b/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
@@ -54,7 +54,7 @@ public class PartitionUtils {
   private PartitionUtils() { }
 
   /**
-   * Compare edge counts for Entry<WorkerInfo, VertexEdgeCount> objects.
+   * Compare edge counts for Entry&lt;WorkerInfo, VertexEdgeCount&gt; objects.
    */
   private static class EdgeCountComparator implements
       Comparator<Entry<WorkerInfo, VertexEdgeCount>>, Serializable {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/reducers/ReduceOperation.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/reducers/ReduceOperation.java 
b/giraph-core/src/main/java/org/apache/giraph/reducers/ReduceOperation.java
index ef501d1..38afa2c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/reducers/ReduceOperation.java
+++ b/giraph-core/src/main/java/org/apache/giraph/reducers/ReduceOperation.java
@@ -17,6 +17,7 @@
  */
 package org.apache.giraph.reducers;
 
+import org.apache.giraph.master.AggregatorReduceOperation;
 import org.apache.hadoop.io.Writable;
 
 /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/reducers/impl/MaxPairReducer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/reducers/impl/MaxPairReducer.java 
b/giraph-core/src/main/java/org/apache/giraph/reducers/impl/MaxPairReducer.java
index 8527004..e7e404d 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/reducers/impl/MaxPairReducer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/reducers/impl/MaxPairReducer.java
@@ -30,7 +30,7 @@ import org.apache.hadoop.io.WritableComparable;
 
 
 /**
- * Aggregating PairWritable<L, R>, by taking pair with largest second value.
+ * Aggregating PairWritable&lt;L, R&gt;, by taking pair with largest second 
value.
  *
  * @param <L> Type of the left value
  * @param <R> Type of the right value

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
index 003f355..d3dd1e0 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityIntByteMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(int key1, byte value1,
       int key2, byte value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
index 02cb667..aef4509 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityIntDoubleMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(int key1, double value1,
       int key2, double value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
index f1a7253..a9c2f37 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityIntFloatMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(int key1, float value1,
       int key2, float value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
index a6865f1..3cb15e1 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityIntIntMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(int key1, int value1,
       int key2, int value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
index b07c5b2..3c8c1f6 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityIntLongMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(int key1, long value1,
       int key2, long value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
index 106fd71..65fadf4 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityLongByteMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(long key1, byte value1,
       long key2, byte value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
index 90a5455..4350655 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityLongDoubleMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(long key1, double value1,
       long key2, double value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
index 2be0d24..1d79015 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityLongFloatMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(long key1, float value1,
       long key2, float value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
index 5bbecfe..67b4154 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityLongIntMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(long key1, int value1,
       long key2, int value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
index 7db14a0..b318d17 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
@@ -155,8 +155,8 @@ public class FixedCapacityLongLongMinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(long key1, long value1,
       long key2, long value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2ByteMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2ByteMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2ByteMapEntryIterable.java
index d37cc5b..bac1ab5 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2ByteMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2ByteMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Int2ByteMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Int2ByteMap.Entry&gt;
  */
 public interface Int2ByteMapEntryIterable
     extends ObjectIterable<Int2ByteMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2DoubleMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2DoubleMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2DoubleMapEntryIterable.java
index f636b6b..8776c3e 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2DoubleMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2DoubleMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Int2DoubleMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Int2DoubleMap.Entry&gt;
  */
 public interface Int2DoubleMapEntryIterable
     extends ObjectIterable<Int2DoubleMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2FloatMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2FloatMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2FloatMapEntryIterable.java
index 70fd2eb..09111f5 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2FloatMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2FloatMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Int2FloatMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Int2FloatMap.Entry&gt;
  */
 public interface Int2FloatMapEntryIterable
     extends ObjectIterable<Int2FloatMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2IntMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2IntMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2IntMapEntryIterable.java
index 0762276..7d48705 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2IntMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2IntMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Int2IntMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Int2IntMap.Entry&gt;
  */
 public interface Int2IntMapEntryIterable
     extends ObjectIterable<Int2IntMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2LongMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2LongMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2LongMapEntryIterable.java
index 3e03d14..b4e5c8c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2LongMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Int2LongMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Int2LongMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Int2LongMap.Entry&gt;
  */
 public interface Int2LongMapEntryIterable
     extends ObjectIterable<Int2LongMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2ByteMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2ByteMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2ByteMapEntryIterable.java
index 490464c..4c27d78 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2ByteMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2ByteMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Long2ByteMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Long2ByteMap.Entry&gt;
  */
 public interface Long2ByteMapEntryIterable
     extends ObjectIterable<Long2ByteMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2DoubleMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2DoubleMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2DoubleMapEntryIterable.java
index fc57b9f..8b7cb17 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2DoubleMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2DoubleMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Long2DoubleMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Long2DoubleMap.Entry&gt;
  */
 public interface Long2DoubleMapEntryIterable
     extends ObjectIterable<Long2DoubleMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2FloatMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2FloatMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2FloatMapEntryIterable.java
index 43a8d6f..802f54c 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2FloatMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2FloatMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Long2FloatMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Long2FloatMap.Entry&gt;
  */
 public interface Long2FloatMapEntryIterable
     extends ObjectIterable<Long2FloatMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2IntMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2IntMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2IntMapEntryIterable.java
index 08e44d4..da99c71 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2IntMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2IntMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Long2IntMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Long2IntMap.Entry&gt;
  */
 public interface Long2IntMapEntryIterable
     extends ObjectIterable<Long2IntMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2LongMapEntryIterable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2LongMapEntryIterable.java
 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2LongMapEntryIterable.java
index b696ea2..e1e78a1 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2LongMapEntryIterable.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/types/heaps/Long2LongMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and ObjectIterator<Long2LongMap.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;Long2LongMap.Entry&gt;
  */
 public interface Long2LongMapEntryIterable
     extends ObjectIterable<Long2LongMap.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/ops/NumericTypeOps.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/types/ops/NumericTypeOps.java 
b/giraph-core/src/main/java/org/apache/giraph/types/ops/NumericTypeOps.java
index a9786a9..362e9d6 100644
--- a/giraph-core/src/main/java/org/apache/giraph/types/ops/NumericTypeOps.java
+++ b/giraph-core/src/main/java/org/apache/giraph/types/ops/NumericTypeOps.java
@@ -77,8 +77,8 @@ public interface NumericTypeOps<T> extends TypeOps<T> {
    *
    * @param value1 First value
    * @param value2 Second value
-   * @return 0 if values are equal, negative value if value1<value2 and
-   *         positive value if value1>value2
+   * @return 0 if values are equal, negative value if value1&lt;value2 and
+   *         positive value if value1&gt;value2
    */
   int compare(T value1, T value2);
 }

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/types/ops/TypeOps.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/types/ops/TypeOps.java 
b/giraph-core/src/main/java/org/apache/giraph/types/ops/TypeOps.java
index 7b54ee6..c1bea07 100644
--- a/giraph-core/src/main/java/org/apache/giraph/types/ops/TypeOps.java
+++ b/giraph-core/src/main/java/org/apache/giraph/types/ops/TypeOps.java
@@ -31,7 +31,7 @@ package org.apache.giraph.types.ops;
 public interface TypeOps<T> {
   /**
    * Class object for generic type T.
-   * @return Class<T> object
+   * @return Class&lt;T&gt; object
    */
   Class<T> getTypeClass();
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/utils/ArrayListWritable.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/utils/ArrayListWritable.java 
b/giraph-core/src/main/java/org/apache/giraph/utils/ArrayListWritable.java
index 2d9928a..28d876d 100644
--- a/giraph-core/src/main/java/org/apache/giraph/utils/ArrayListWritable.java
+++ b/giraph-core/src/main/java/org/apache/giraph/utils/ArrayListWritable.java
@@ -86,7 +86,7 @@ public abstract class ArrayListWritable<M extends Writable> 
extends ArrayList<M>
 
   /**
    * Subclasses must set the class type appropriately and can use
-   * setClass(Class<M> refClass) to do it.
+   * setClass(Class&lt;M&gt; refClass) to do it.
    */
   public abstract void setClass();
 

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneMessageToManyIds.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneMessageToManyIds.java
 
b/giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneMessageToManyIds.java
index 674b0b0..284f437 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneMessageToManyIds.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneMessageToManyIds.java
@@ -64,7 +64,7 @@ public class ByteArrayOneMessageToManyIds<I extends 
WritableComparable,
 
   /**
    * Add a message.
-   * The order is: the message>id count>ids .
+   * The order is: the message &gt; id count &gt; ids .
    *
    * @param ids   The byte array which holds target ids
    *              of this message on the worker

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/utils/CheckpointingUtils.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/utils/CheckpointingUtils.java 
b/giraph-core/src/main/java/org/apache/giraph/utils/CheckpointingUtils.java
index 2a6f785..498f199 100644
--- a/giraph-core/src/main/java/org/apache/giraph/utils/CheckpointingUtils.java
+++ b/giraph-core/src/main/java/org/apache/giraph/utils/CheckpointingUtils.java
@@ -81,12 +81,12 @@ public class CheckpointingUtils {
   }
 
   /**
-   * Path to checkpoint&halt node in hdfs.
+   * Path to checkpoint&amp;halt node in hdfs.
    * It is set to let client know that master has
    * successfully finished checkpointing and job can be restarted.
    * @param conf Immutable configuration of the job
    * @param jobId job ID
-   * @return path to checkpoint&halt node in hdfs.
+   * @return path to checkpoint&amp;halt node in hdfs.
    */
   public static Path getCheckpointMarkPath(Configuration conf,
                                            String jobId) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/utils/ExtendedByteArrayOutputBuffer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/utils/ExtendedByteArrayOutputBuffer.java
 
b/giraph-core/src/main/java/org/apache/giraph/utils/ExtendedByteArrayOutputBuffer.java
index 3103f30..960f31e 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/utils/ExtendedByteArrayOutputBuffer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/utils/ExtendedByteArrayOutputBuffer.java
@@ -112,7 +112,7 @@ public class ExtendedByteArrayOutputBuffer {
   }
 
   /**
-   * Holder for index & DataOutput objects
+   * Holder for index &amp; DataOutput objects
    */
   public static class IndexAndDataOut {
     /** Index */

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/utils/Varint.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/utils/Varint.java 
b/giraph-core/src/main/java/org/apache/giraph/utils/Varint.java
index addcc2f..66ae06e 100644
--- a/giraph-core/src/main/java/org/apache/giraph/utils/Varint.java
+++ b/giraph-core/src/main/java/org/apache/giraph/utils/Varint.java
@@ -48,7 +48,6 @@ import java.io.IOException;
  * Google's Protocol Buffers</a>. It uses fewer bytes to encode smaller values,
  * but will use slightly more bytes to encode large values.
  * </p>
- * <p/>
  * <p>
  * Signed values are further encoded using so-called zig-zag encoding in order
  * to make them "compatible" with variable-length encoding.

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/worker/LocalData.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/worker/LocalData.java 
b/giraph-core/src/main/java/org/apache/giraph/worker/LocalData.java
index 9612344..63ac0dd 100644
--- a/giraph-core/src/main/java/org/apache/giraph/worker/LocalData.java
+++ b/giraph-core/src/main/java/org/apache/giraph/worker/LocalData.java
@@ -47,7 +47,7 @@ public class LocalData<I extends WritableComparable, V 
extends Writable,
   /**
    * Constructor
    *
-   * Set configuration, create & initialize mapping store
+   * Set configuration, create &amp; initialize mapping store
    * @param conf giraph configuration
    */
   public LocalData(ImmutableClassesGiraphConfiguration<I, V, E> conf) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/writable/kryo/serializers/ArraysAsListSerializer.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/writable/kryo/serializers/ArraysAsListSerializer.java
 
b/giraph-core/src/main/java/org/apache/giraph/writable/kryo/serializers/ArraysAsListSerializer.java
index 3d66eb7..162fb44 100644
--- 
a/giraph-core/src/main/java/org/apache/giraph/writable/kryo/serializers/ArraysAsListSerializer.java
+++ 
b/giraph-core/src/main/java/org/apache/giraph/writable/kryo/serializers/ArraysAsListSerializer.java
@@ -28,8 +28,8 @@ import com.esotericsoftware.kryo.io.Output;
 /**
  * Special serializer for Arrays.asList() as they can not be
  * deserialized in a standard way.
- * {@see
- * https://groups.google.com/forum/#!msg/kryo-users/2lXTCEOSxA0/gLzIZRtaNCUJ}
+ *
+ * https://groups.google.com/forum/#!msg/kryo-users/2lXTCEOSxA0/gLzIZRtaNCUJ
  */
 public class ArraysAsListSerializer extends Serializer<List> {
   @Override

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/test/java/org/apache/giraph/generate/GeneratePrimitiveClasses.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/test/java/org/apache/giraph/generate/GeneratePrimitiveClasses.java
 
b/giraph-core/src/test/java/org/apache/giraph/generate/GeneratePrimitiveClasses.java
index 4e19ca2..1c82eca 100644
--- 
a/giraph-core/src/test/java/org/apache/giraph/generate/GeneratePrimitiveClasses.java
+++ 
b/giraph-core/src/test/java/org/apache/giraph/generate/GeneratePrimitiveClasses.java
@@ -44,7 +44,7 @@ import freemarker.template.TemplateNotFoundException;
  * to appropriate generate* function.</p>
  *
  * <p>Templates are using freemarker template format, which given
- * template file and map of String->Object replacements generates
+ * template file and map of String-&gt;Object replacements generates
  * new file.</p>
  * Main rules:
  * <ul>

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java 
b/giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java
index ed365b4..e69677f 100644
--- a/giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java
+++ b/giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java
@@ -53,7 +53,7 @@ import org.junit.Test;
 /**
  * Tests the Giraph on YARN workflow. Basically, the plan is to use a
  * <code>MiniYARNCluster</code> to run a small test job through our
- * GiraphYarnClient -> GiraphApplicationMaster -> GiraphYarnTask (2 no-ops)
+ * GiraphYarnClient -&gt; GiraphApplicationMaster -gt; GiraphYarnTask (2 
no-ops)
  * No "real" BSP code need be tested here, as it is not aware it is running on
  * YARN once the job is in progress, so the existing MRv1 BSP tests are fine.
  */

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/test/java/org/apache/giraph/zk/TestPredicateLock.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/test/java/org/apache/giraph/zk/TestPredicateLock.java 
b/giraph-core/src/test/java/org/apache/giraph/zk/TestPredicateLock.java
index 9f32570..c90be93 100644
--- a/giraph-core/src/test/java/org/apache/giraph/zk/TestPredicateLock.java
+++ b/giraph-core/src/test/java/org/apache/giraph/zk/TestPredicateLock.java
@@ -128,8 +128,6 @@ public class TestPredicateLock {
 
   /**
    * Thread signaled test to make sure the the event is signaled correctly
-   *
-   * @throws InterruptedException
    */
   @Test
   public void testWaitMsecs() {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/FixedCapacityType2TypeMinHeap.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/FixedCapacityType2TypeMinHeap.java 
b/giraph-core/templates/FixedCapacityType2TypeMinHeap.java
index d381ddf..5dc37bc 100644
--- a/giraph-core/templates/FixedCapacityType2TypeMinHeap.java
+++ b/giraph-core/templates/FixedCapacityType2TypeMinHeap.java
@@ -155,8 +155,8 @@ public class 
FixedCapacity${type1.camel}${type2.camel}MinHeap
    * @param value1 First value
    * @param key2   Second key
    * @param value2 Second value
-   * @return 0 if entries are equal, < 0 if first entry is smaller than the
-   * second one, and > 0 if first entry is larger than the second one
+   * @return 0 if entries are equal, &lt; 0 if first entry is smaller than the
+   * second one, and &gt; 0 if first entry is larger than the second one
    */
   protected int compare(${type1.lower} key1, ${type2.lower} value1,
       ${type1.lower} key2, ${type2.lower} value2) {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/Obj2TypeFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/Obj2TypeFunction.java 
b/giraph-core/templates/Obj2TypeFunction.java
index b256283..c91e144 100644
--- a/giraph-core/templates/Obj2TypeFunction.java
+++ b/giraph-core/templates/Obj2TypeFunction.java
@@ -23,7 +23,7 @@ ${generated_message}
 
 /**
  * Primitive specialization of Function:
- * (T) -> ${type.lower}
+ * (T) -&gt; ${type.lower}
  *
  * @param <T> Argument type
  */

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/Type2TypeMapEntryIterable.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/Type2TypeMapEntryIterable.java 
b/giraph-core/templates/Type2TypeMapEntryIterable.java
index a03634b..16b56e9 100644
--- a/giraph-core/templates/Type2TypeMapEntryIterable.java
+++ b/giraph-core/templates/Type2TypeMapEntryIterable.java
@@ -23,7 +23,8 @@ import it.unimi.dsi.fastutil.objects.ObjectIterable;
 import it.unimi.dsi.fastutil.objects.ObjectIterator;
 
 /**
- * Iterable which has its size and 
ObjectIterator<${type1.camel}2${type2.camel}Map.Entry>
+ * Iterable which has its size and
+ * ObjectIterator&lt;${type1.camel}2${type2.camel}Map.Entry&gt;
  */
 public interface ${type1.camel}2${type2.camel}MapEntryIterable
     extends ObjectIterable<${type1.camel}2${type2.camel}Map.Entry> {

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/TypeConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/TypeConsumer.java 
b/giraph-core/templates/TypeConsumer.java
index 9bea280..c68b67f 100644
--- a/giraph-core/templates/TypeConsumer.java
+++ b/giraph-core/templates/TypeConsumer.java
@@ -23,7 +23,7 @@ ${generated_message}
 
 /**
  * Primitive specialization of Function:
- * (${type.lower}) -> void
+ * (${type.lower}) -&gt; void
  */
 public interface ${type.camel}Consumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/TypePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/TypePredicate.java 
b/giraph-core/templates/TypePredicate.java
index eb4203e..305ae07 100644
--- a/giraph-core/templates/TypePredicate.java
+++ b/giraph-core/templates/TypePredicate.java
@@ -23,7 +23,7 @@ ${generated_message}
 
 /**
  * Primitive specialization of Function:
- * (${type.lower}) -> boolean
+ * (${type.lower}) -&gt; boolean
  */
 public interface ${type.camel}Predicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/TypeTypeConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/TypeTypeConsumer.java 
b/giraph-core/templates/TypeTypeConsumer.java
index 90a4ed5..55c41d9 100644
--- a/giraph-core/templates/TypeTypeConsumer.java
+++ b/giraph-core/templates/TypeTypeConsumer.java
@@ -23,7 +23,7 @@ ${generated_message}
 
 /**
  * Primitive specialization of Function:
- * (${type1.lower}, ${type2.lower}) -> void
+ * (${type1.lower}, ${type2.lower}) -&gt; void
  */
 public interface ${type1.camel}${type2.camel}Consumer extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/templates/TypeTypePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/templates/TypeTypePredicate.java 
b/giraph-core/templates/TypeTypePredicate.java
index 7d29d5c..0d99cff 100644
--- a/giraph-core/templates/TypeTypePredicate.java
+++ b/giraph-core/templates/TypeTypePredicate.java
@@ -23,7 +23,7 @@ ${generated_message}
 
 /**
  * Primitive specialization of Function:
- * (${type1.lower}, ${type2.lower}) -> boolean
+ * (${type1.lower}, ${type2.lower}) -&gt; boolean
  */
 public interface ${type1.camel}${type2.camel}Predicate extends Serializable {
   /**

http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-examples/src/main/java/org/apache/giraph/examples/BrachaTouegDeadlockComputation.java
----------------------------------------------------------------------
diff --git 
a/giraph-examples/src/main/java/org/apache/giraph/examples/BrachaTouegDeadlockComputation.java
 
b/giraph-examples/src/main/java/org/apache/giraph/examples/BrachaTouegDeadlockComputation.java
index 466912f..52c5f4b 100644
--- 
a/giraph-examples/src/main/java/org/apache/giraph/examples/BrachaTouegDeadlockComputation.java
+++ 
b/giraph-examples/src/main/java/org/apache/giraph/examples/BrachaTouegDeadlockComputation.java
@@ -32,12 +32,12 @@ import org.apache.hadoop.io.LongWritable;
 import org.apache.log4j.Logger;
 
 /**
- * This code demonstrates the Bracha Toueg deadlock detection algorithm.<br />
+ * This code demonstrates the Bracha Toueg deadlock detection algorithm.
  * The Bracha Toueg algorithm is a distributed, asynchronous, centralized
  * algorithm for deadlock detection. The algorithm is executed on a snapshot of
- * a undirected graph which depicts the corresponding wait-for-graph.<br />
+ * a undirected graph which depicts the corresponding wait-for-graph.
  * Consequently the algorithm works on <b>directed graphs</b> but assumes
- * the possibility to communicate in both ways on all the edges.<br />
+ * the possibility to communicate in both ways on all the edges.
  * This is an adaptation of the standard algorithm for Giraph/Pregel system.
  * Since the value of the vertex is dumped during checkpointing, the algorithm
  * keeps all the state of the vertex in the value.

Reply via email to