You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ed...@apache.org on 2016/10/14 20:44:01 UTC
[1/3] git commit: updated refs/heads/trunk to 70c6545
Repository: giraph
Updated Branches:
refs/heads/trunk bf4c371de -> 70c6545a6
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-examples/src/main/java/org/apache/giraph/examples/scc/SccLongLongNullTextInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-examples/src/main/java/org/apache/giraph/examples/scc/SccLongLongNullTextInputFormat.java b/giraph-examples/src/main/java/org/apache/giraph/examples/scc/SccLongLongNullTextInputFormat.java
index e5a4c86..1de5f61 100644
--- a/giraph-examples/src/main/java/org/apache/giraph/examples/scc/SccLongLongNullTextInputFormat.java
+++ b/giraph-examples/src/main/java/org/apache/giraph/examples/scc/SccLongLongNullTextInputFormat.java
@@ -51,7 +51,7 @@ public class SccLongLongNullTextInputFormat extends
}
/**
- * Vertex reader associated with {@link LongLongNullLongTextInputFormat}.
+ * Vertex reader associated with {@link SccLongLongNullTextInputFormat}.
*/
public class LongLongNullVertexReader extends
TextVertexReaderFromEachLineProcessed<String[]> {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-examples/src/main/java/org/apache/giraph/examples/utils/BrachaTouegDeadlockVertexValue.java
----------------------------------------------------------------------
diff --git a/giraph-examples/src/main/java/org/apache/giraph/examples/utils/BrachaTouegDeadlockVertexValue.java b/giraph-examples/src/main/java/org/apache/giraph/examples/utils/BrachaTouegDeadlockVertexValue.java
index 920fdda..f26548e 100644
--- a/giraph-examples/src/main/java/org/apache/giraph/examples/utils/BrachaTouegDeadlockVertexValue.java
+++ b/giraph-examples/src/main/java/org/apache/giraph/examples/utils/BrachaTouegDeadlockVertexValue.java
@@ -301,7 +301,7 @@ public class BrachaTouegDeadlockVertexValue implements Writable {
}
/**
- * @return ArrayList<Long> list of parent IDs collected
+ * @return list of parent IDs collected
*/
public ArrayList<Long> getParents() {
return this.parents;
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-examples/src/test/java/org/apache/giraph/examples/BrachaTouegDeadlockComputationTest.java
----------------------------------------------------------------------
diff --git a/giraph-examples/src/test/java/org/apache/giraph/examples/BrachaTouegDeadlockComputationTest.java b/giraph-examples/src/test/java/org/apache/giraph/examples/BrachaTouegDeadlockComputationTest.java
index 6f32eb2..3d34cd5 100644
--- a/giraph-examples/src/test/java/org/apache/giraph/examples/BrachaTouegDeadlockComputationTest.java
+++ b/giraph-examples/src/test/java/org/apache/giraph/examples/BrachaTouegDeadlockComputationTest.java
@@ -31,7 +31,7 @@ import org.junit.Ignore;
import org.junit.Test;
/**
- * Tests for {@link BrachaTougeDeadlockComputation}
+ * Tests for {@link BrachaTouegDeadlockComputation}
*/
public class BrachaTouegDeadlockComputationTest {
/** Giraph shared configuration */
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-examples/src/test/java/org/apache/giraph/examples/scc/SccComputationTestInMemory.java
----------------------------------------------------------------------
diff --git a/giraph-examples/src/test/java/org/apache/giraph/examples/scc/SccComputationTestInMemory.java b/giraph-examples/src/test/java/org/apache/giraph/examples/scc/SccComputationTestInMemory.java
index 28d5f5c..feaba12 100644
--- a/giraph-examples/src/test/java/org/apache/giraph/examples/scc/SccComputationTestInMemory.java
+++ b/giraph-examples/src/test/java/org/apache/giraph/examples/scc/SccComputationTestInMemory.java
@@ -52,7 +52,7 @@ public class SccComputationTestInMemory {
}
/**
- * Connects the {@outgoingVertices} to the given vertex id
+ * Connects the outgoingVertices to the given vertex id
* with null-valued edges.
*
* @param graph
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
index 8ef91f6..333871d 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
@@ -126,7 +126,7 @@ public abstract class GoraEdgeInputFormat
* Gets the splits for a data store.
* @param context JobContext
* @param minSplitCountHint Hint for a minimum split count
- * @return List<InputSplit> A list of splits
+ * @return A list of splits
*/
@Override
public List<InputSplit> getSplits(JobContext context, int minSplitCountHint)
@@ -249,7 +249,7 @@ public abstract class GoraEdgeInputFormat
/**
* Finishes the reading process.
- * @throws IOException.
+ * @throws IOException
*/
@Override
public void close() throws IOException {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
index ee5e7b6..0892849 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
@@ -141,7 +141,7 @@ public abstract class GoraVertexInputFormat<
* Gets the splits for a data store.
* @param context JobContext
* @param minSplitCountHint Hint for a minimum split count
- * @return List<InputSplit> A list of splits
+ * @return A list of splits
*/
@Override
public List<InputSplit> getSplits(JobContext context, int minSplitCountHint)
@@ -279,7 +279,7 @@ public abstract class GoraVertexInputFormat<
/**
* Finishes the reading process.
- * @throws IOException.
+ * @throws IOException
*/
@Override
public void close() throws IOException {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-gora/src/main/java/org/apache/giraph/io/gora/utils/ExtraGoraInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/utils/ExtraGoraInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/utils/ExtraGoraInputFormat.java
index b40a361..fed042d 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/utils/ExtraGoraInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/utils/ExtraGoraInputFormat.java
@@ -87,7 +87,7 @@ public class ExtraGoraInputFormat<K, T extends PersistentBase>
/**
* Gets splits.
* @param context for the job.
- * @return List<InputSplit> splits found
+ * @return splits found
*/
@Override
public List<InputSplit> getSplits(JobContext context) throws IOException,
@@ -146,7 +146,7 @@ public class ExtraGoraInputFormat<K, T extends PersistentBase>
/**
* Gets the partitioned query from the conf object passed.
* @param conf Configuration object.
- * @return Query<K, T> passed inside the configuration object
+ * @return passed inside the configuration object
* @throws IOException Exception that might be thrown.
*/
public Query<K, T> getQuery(Configuration conf) throws IOException {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 3528919..af3303f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -905,7 +905,7 @@ under the License.
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
- <version>2.10</version>
+ <version>2.15</version>
<configuration>
<configLocation>${checkstyle.config.path}</configLocation>
<consoleOutput>true</consoleOutput>
[3/3] git commit: updated refs/heads/trunk to 70c6545
Posted by ed...@apache.org.
GIRAPH-1122 Javadoc generation fails for Giraph 1.2.0
Test Plan: mvn clean site -DskipTests -Phadoop_2 -Ddependency.locations.enabled=false
Reviewers: majakabiljo, dionysis.logothetis
Reviewed By: dionysis.logothetis
Differential Revision: https://reviews.facebook.net/D64995
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/70c6545a
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/70c6545a
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/70c6545a
Branch: refs/heads/trunk
Commit: 70c6545a6821977b22cce62e993fc14eafe994d9
Parents: bf4c371
Author: Sergey Edunov <ed...@fb.com>
Authored: Fri Oct 14 13:43:50 2016 -0700
Committer: Sergey Edunov <ed...@fb.com>
Committed: Fri Oct 14 13:43:50 2016 -0700
----------------------------------------------------------------------
.../block_app/framework/api/BlockApiHandle.java | 3 +++
.../framework/piece/DefaultParentPiece.java | 8 ++------
.../block_app/reducers/array/ArrayOfHandles.java | 3 ++-
.../comm/flow_control/CreditBasedFlowControl.java | 4 ++--
.../giraph/comm/requests/SendWorkerDataRequest.java | 2 +-
.../comm/requests/SendWorkerEdgesRequest.java | 2 +-
.../comm/requests/SendWorkerMessagesRequest.java | 2 +-
.../requests/SendWorkerOneMessageToManyRequest.java | 2 +-
.../apache/giraph/conf/FacebookConfiguration.java | 1 -
.../org/apache/giraph/conf/GiraphConfiguration.java | 16 ++++++++--------
.../org/apache/giraph/conf/GiraphConstants.java | 2 +-
.../conf/ImmutableClassesGiraphConfiguration.java | 2 +-
.../java/org/apache/giraph/function/Consumer.java | 2 +-
.../java/org/apache/giraph/function/Function.java | 2 +-
.../org/apache/giraph/function/ObjectTransfer.java | 4 ++--
.../org/apache/giraph/function/PairConsumer.java | 2 +-
.../org/apache/giraph/function/PairFunction.java | 2 +-
.../org/apache/giraph/function/PairPredicate.java | 2 +-
.../java/org/apache/giraph/function/Predicate.java | 2 +-
.../java/org/apache/giraph/function/Supplier.java | 2 +-
.../org/apache/giraph/function/TripleFunction.java | 2 +-
.../giraph/function/primitive/BooleanConsumer.java | 2 +-
.../giraph/function/primitive/BooleanPredicate.java | 2 +-
.../giraph/function/primitive/ByteConsumer.java | 2 +-
.../giraph/function/primitive/BytePredicate.java | 2 +-
.../function/primitive/Double2ObjFunction.java | 2 +-
.../giraph/function/primitive/DoubleConsumer.java | 2 +-
.../giraph/function/primitive/DoublePredicate.java | 2 +-
.../giraph/function/primitive/FloatConsumer.java | 2 +-
.../giraph/function/primitive/FloatPredicate.java | 2 +-
.../giraph/function/primitive/Int2ObjFunction.java | 2 +-
.../giraph/function/primitive/IntConsumer.java | 2 +-
.../giraph/function/primitive/IntPredicate.java | 2 +-
.../giraph/function/primitive/IntSupplier.java | 2 +-
.../giraph/function/primitive/LongConsumer.java | 2 +-
.../giraph/function/primitive/LongPredicate.java | 2 +-
.../function/primitive/Obj2BooleanFunction.java | 2 +-
.../giraph/function/primitive/Obj2ByteFunction.java | 2 +-
.../function/primitive/Obj2DoubleFunction.java | 2 +-
.../function/primitive/Obj2FloatFunction.java | 2 +-
.../giraph/function/primitive/Obj2IntFunction.java | 2 +-
.../giraph/function/primitive/Obj2LongFunction.java | 2 +-
.../function/primitive/Obj2ShortFunction.java | 2 +-
.../giraph/function/primitive/PrimitiveRefs.java | 2 --
.../giraph/function/primitive/ShortConsumer.java | 2 +-
.../giraph/function/primitive/ShortPredicate.java | 2 +-
.../primitive/pairs/BooleanBooleanConsumer.java | 2 +-
.../primitive/pairs/BooleanBooleanPredicate.java | 2 +-
.../primitive/pairs/BooleanByteConsumer.java | 2 +-
.../primitive/pairs/BooleanBytePredicate.java | 2 +-
.../primitive/pairs/BooleanDoubleConsumer.java | 2 +-
.../primitive/pairs/BooleanDoublePredicate.java | 2 +-
.../primitive/pairs/BooleanFloatConsumer.java | 2 +-
.../primitive/pairs/BooleanFloatPredicate.java | 2 +-
.../primitive/pairs/BooleanIntConsumer.java | 2 +-
.../primitive/pairs/BooleanIntPredicate.java | 2 +-
.../primitive/pairs/BooleanLongConsumer.java | 2 +-
.../primitive/pairs/BooleanLongPredicate.java | 2 +-
.../primitive/pairs/ByteBooleanConsumer.java | 2 +-
.../primitive/pairs/ByteBooleanPredicate.java | 2 +-
.../function/primitive/pairs/ByteByteConsumer.java | 2 +-
.../function/primitive/pairs/ByteBytePredicate.java | 2 +-
.../primitive/pairs/ByteDoubleConsumer.java | 2 +-
.../primitive/pairs/ByteDoublePredicate.java | 2 +-
.../function/primitive/pairs/ByteFloatConsumer.java | 2 +-
.../primitive/pairs/ByteFloatPredicate.java | 2 +-
.../function/primitive/pairs/ByteIntConsumer.java | 2 +-
.../function/primitive/pairs/ByteIntPredicate.java | 2 +-
.../function/primitive/pairs/ByteLongConsumer.java | 2 +-
.../function/primitive/pairs/ByteLongPredicate.java | 2 +-
.../primitive/pairs/DoubleBooleanConsumer.java | 2 +-
.../primitive/pairs/DoubleBooleanPredicate.java | 2 +-
.../primitive/pairs/DoubleByteConsumer.java | 2 +-
.../primitive/pairs/DoubleBytePredicate.java | 2 +-
.../primitive/pairs/DoubleDoubleConsumer.java | 2 +-
.../primitive/pairs/DoubleDoublePredicate.java | 2 +-
.../primitive/pairs/DoubleFloatConsumer.java | 2 +-
.../primitive/pairs/DoubleFloatPredicate.java | 2 +-
.../function/primitive/pairs/DoubleIntConsumer.java | 2 +-
.../primitive/pairs/DoubleIntPredicate.java | 2 +-
.../primitive/pairs/DoubleLongConsumer.java | 2 +-
.../primitive/pairs/DoubleLongPredicate.java | 2 +-
.../primitive/pairs/FloatBooleanConsumer.java | 2 +-
.../primitive/pairs/FloatBooleanPredicate.java | 2 +-
.../function/primitive/pairs/FloatByteConsumer.java | 2 +-
.../primitive/pairs/FloatBytePredicate.java | 2 +-
.../primitive/pairs/FloatDoubleConsumer.java | 2 +-
.../primitive/pairs/FloatDoublePredicate.java | 2 +-
.../primitive/pairs/FloatFloatConsumer.java | 2 +-
.../primitive/pairs/FloatFloatPredicate.java | 2 +-
.../function/primitive/pairs/FloatIntConsumer.java | 2 +-
.../function/primitive/pairs/FloatIntPredicate.java | 2 +-
.../function/primitive/pairs/FloatLongConsumer.java | 2 +-
.../primitive/pairs/FloatLongPredicate.java | 2 +-
.../primitive/pairs/IntBooleanConsumer.java | 2 +-
.../primitive/pairs/IntBooleanPredicate.java | 2 +-
.../function/primitive/pairs/IntByteConsumer.java | 2 +-
.../function/primitive/pairs/IntBytePredicate.java | 2 +-
.../function/primitive/pairs/IntDoubleConsumer.java | 2 +-
.../primitive/pairs/IntDoublePredicate.java | 2 +-
.../function/primitive/pairs/IntFloatConsumer.java | 2 +-
.../function/primitive/pairs/IntFloatPredicate.java | 2 +-
.../function/primitive/pairs/IntIntConsumer.java | 2 +-
.../function/primitive/pairs/IntIntPredicate.java | 2 +-
.../function/primitive/pairs/IntLongConsumer.java | 2 +-
.../function/primitive/pairs/IntLongPredicate.java | 2 +-
.../primitive/pairs/LongBooleanConsumer.java | 2 +-
.../primitive/pairs/LongBooleanPredicate.java | 2 +-
.../function/primitive/pairs/LongByteConsumer.java | 2 +-
.../function/primitive/pairs/LongBytePredicate.java | 2 +-
.../primitive/pairs/LongDoubleConsumer.java | 2 +-
.../primitive/pairs/LongDoublePredicate.java | 2 +-
.../function/primitive/pairs/LongFloatConsumer.java | 2 +-
.../primitive/pairs/LongFloatPredicate.java | 2 +-
.../function/primitive/pairs/LongIntConsumer.java | 2 +-
.../function/primitive/pairs/LongIntPredicate.java | 2 +-
.../function/primitive/pairs/LongLongConsumer.java | 2 +-
.../function/primitive/pairs/LongLongPredicate.java | 2 +-
.../giraph/function/vertex/ConsumerWithVertex.java | 2 +-
.../giraph/function/vertex/FunctionWithVertex.java | 2 +-
.../giraph/function/vertex/SupplierFromVertex.java | 6 +++---
.../apache/giraph/graph/AbstractComputation.java | 5 ++---
.../giraph/graph/GiraphTransferRegulator.java | 2 +-
.../java/org/apache/giraph/io/EdgeInputFormat.java | 1 -
.../main/java/org/apache/giraph/io/EdgeReader.java | 2 +-
.../AdjacencyListTextVertexOutputFormat.java | 3 ++-
.../io/formats/LongLongNullTextInputFormat.java | 2 +-
.../org/apache/giraph/jython/JythonComputation.java | 4 +++-
.../giraph/jython/JythonGiraphComputation.java | 1 +
.../JythonOutgoingMessageValueFactory.java | 1 +
.../apache/giraph/mapping/AbstractLongByteOps.java | 2 +-
.../apache/giraph/mapping/LongByteMappingStore.java | 2 +-
.../mapping/translate/LongByteTranslateEdge.java | 2 +-
.../giraph/mapping/translate/TranslateEdge.java | 2 +-
.../giraph/mapping/translate/package-info.java | 2 +-
.../master/AggregatorToGlobalCommTranslation.java | 2 +-
.../giraph/metrics/GiraphMetricsRegistry.java | 3 +--
.../org/apache/giraph/partition/PartitionUtils.java | 2 +-
.../org/apache/giraph/reducers/ReduceOperation.java | 1 +
.../apache/giraph/reducers/impl/MaxPairReducer.java | 2 +-
.../types/heaps/FixedCapacityIntByteMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityIntDoubleMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityIntFloatMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityIntIntMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityIntLongMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityLongByteMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityLongDoubleMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityLongFloatMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityLongIntMinHeap.java | 4 ++--
.../types/heaps/FixedCapacityLongLongMinHeap.java | 4 ++--
.../types/heaps/Int2ByteMapEntryIterable.java | 3 ++-
.../types/heaps/Int2DoubleMapEntryIterable.java | 3 ++-
.../types/heaps/Int2FloatMapEntryIterable.java | 3 ++-
.../giraph/types/heaps/Int2IntMapEntryIterable.java | 3 ++-
.../types/heaps/Int2LongMapEntryIterable.java | 3 ++-
.../types/heaps/Long2ByteMapEntryIterable.java | 3 ++-
.../types/heaps/Long2DoubleMapEntryIterable.java | 3 ++-
.../types/heaps/Long2FloatMapEntryIterable.java | 3 ++-
.../types/heaps/Long2IntMapEntryIterable.java | 3 ++-
.../types/heaps/Long2LongMapEntryIterable.java | 3 ++-
.../org/apache/giraph/types/ops/NumericTypeOps.java | 4 ++--
.../java/org/apache/giraph/types/ops/TypeOps.java | 2 +-
.../org/apache/giraph/utils/ArrayListWritable.java | 2 +-
.../giraph/utils/ByteArrayOneMessageToManyIds.java | 2 +-
.../org/apache/giraph/utils/CheckpointingUtils.java | 4 ++--
.../giraph/utils/ExtendedByteArrayOutputBuffer.java | 2 +-
.../main/java/org/apache/giraph/utils/Varint.java | 1 -
.../java/org/apache/giraph/worker/LocalData.java | 2 +-
.../kryo/serializers/ArraysAsListSerializer.java | 4 ++--
.../giraph/generate/GeneratePrimitiveClasses.java | 2 +-
.../java/org/apache/giraph/yarn/TestYarnJob.java | 2 +-
.../org/apache/giraph/zk/TestPredicateLock.java | 2 --
.../templates/FixedCapacityType2TypeMinHeap.java | 4 ++--
giraph-core/templates/Obj2TypeFunction.java | 2 +-
.../templates/Type2TypeMapEntryIterable.java | 3 ++-
giraph-core/templates/TypeConsumer.java | 2 +-
giraph-core/templates/TypePredicate.java | 2 +-
giraph-core/templates/TypeTypeConsumer.java | 2 +-
giraph-core/templates/TypeTypePredicate.java | 2 +-
.../examples/BrachaTouegDeadlockComputation.java | 6 +++---
.../scc/SccLongLongNullTextInputFormat.java | 2 +-
.../utils/BrachaTouegDeadlockVertexValue.java | 2 +-
.../BrachaTouegDeadlockComputationTest.java | 2 +-
.../examples/scc/SccComputationTestInMemory.java | 2 +-
.../apache/giraph/io/gora/GoraEdgeInputFormat.java | 4 ++--
.../giraph/io/gora/GoraVertexInputFormat.java | 4 ++--
.../giraph/io/gora/utils/ExtraGoraInputFormat.java | 4 ++--
pom.xml | 2 +-
188 files changed, 232 insertions(+), 224 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/api/BlockApiHandle.java
----------------------------------------------------------------------
diff --git a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/api/BlockApiHandle.java b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/api/BlockApiHandle.java
index 4c52826..20fe8ae 100644
--- a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/api/BlockApiHandle.java
+++ b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/api/BlockApiHandle.java
@@ -17,6 +17,9 @@
*/
package org.apache.giraph.block_app.framework.api;
+import org.apache.giraph.block_app.framework.block.Block;
+import org.apache.giraph.block_app.framework.block.BlockWithApiHandle;
+
import static com.google.common.base.Preconditions.checkNotNull;
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/piece/DefaultParentPiece.java
----------------------------------------------------------------------
diff --git a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/piece/DefaultParentPiece.java b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/piece/DefaultParentPiece.java
index 0963efb..bfec1df 100644
--- a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/piece/DefaultParentPiece.java
+++ b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/piece/DefaultParentPiece.java
@@ -70,8 +70,8 @@ public abstract class DefaultParentPiece<I extends WritableComparable,
WM extends Writable, S> extends AbstractPiece<I, V, E, M, WV, WM, S> {
// TODO move to GiraphConstants
/**
- * This option will tell which message encode & store enum to force, when
- * combining is not enabled.
+ * This option will tell which message encode & store enum to force,
+ * when combining is not enabled.
*
* MESSAGE_ENCODE_AND_STORE_TYPE and this property are basically upper
* and lower bound on message store type, when looking them in order from
@@ -106,15 +106,11 @@ public abstract class DefaultParentPiece<I extends WritableComparable,
* Override to register any potential reducers used by this piece,
* through calls to {@code reduceApi}, which will return reducer handles
* for simple.
- * <br/>
* Tip: Without defining a field, first write here name of the field and what
* you want to reduce, like:
- * <br/>
* {@code totalSum = reduceApi.createLocalReducer(SumReduce.DOUBLE); }
- * <br/>
* and then use tools your IDE provides to generate field signature itself,
* which might be slightly complex:
- * <br/>
* {@code ReducerHandle<DoubleWritable, DoubleWritable> totalSum; }
*/
public void registerReducers(CreateReducersApi reduceApi, S executionStage) {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-block-app/src/main/java/org/apache/giraph/block_app/reducers/array/ArrayOfHandles.java
----------------------------------------------------------------------
diff --git a/giraph-block-app/src/main/java/org/apache/giraph/block_app/reducers/array/ArrayOfHandles.java b/giraph-block-app/src/main/java/org/apache/giraph/block_app/reducers/array/ArrayOfHandles.java
index 053fd61..69d56e5 100644
--- a/giraph-block-app/src/main/java/org/apache/giraph/block_app/reducers/array/ArrayOfHandles.java
+++ b/giraph-block-app/src/main/java/org/apache/giraph/block_app/reducers/array/ArrayOfHandles.java
@@ -64,7 +64,8 @@ public class ArrayOfHandles<H> implements ArrayHandle<H> {
/**
* ReducerArrayHandle implemented as an array of separate reducer handles.
*
- * @param <H> Handle type
+ * @param <S> Handle type
+ * @param <R> Reduce value type
*/
public static class ArrayOfReducers<S, R>
extends ArrayOfHandles<ReducerHandle<S, R>>
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/comm/flow_control/CreditBasedFlowControl.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/flow_control/CreditBasedFlowControl.java b/giraph-core/src/main/java/org/apache/giraph/comm/flow_control/CreditBasedFlowControl.java
index 9b15b9b..5f28bc6 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/flow_control/CreditBasedFlowControl.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/flow_control/CreditBasedFlowControl.java
@@ -59,8 +59,8 @@ import com.google.common.collect.Sets;
/**
* Representation of credit-based flow control policy. With this policy there
* can be limited number of open requests from any worker x to any other worker
- * y. This number is called 'credit'. Let's denote this number by C{x->y}. This
- * implementation assumes that for a particular worker W, all values of C{x->W}
+ * y. This number is called 'credit'. Let's denote this number by C{x->y}. This
+ * implementation assumes that for a particular worker W, all values of C{x->W}
* are the same. Let's denote this value by CR_W. CR_W may change due to other
* reasons (e.g. memory pressure observed in an out-of-core mechanism). However,
* CR_W is always in range [0, MAX_CR], where MAX_CR is a user-defined constant.
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java
index ceb5050..a861898 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java
@@ -58,7 +58,7 @@ public abstract class SendWorkerDataRequest<I extends WritableComparable, T,
/**
* Constructor used to send request.
*
- * @param partVertData Map of remote partitions => VertexIdData
+ * @param partVertData Map of remote partitions => VertexIdData
*/
public SendWorkerDataRequest(
PairList<Integer, B> partVertData) {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java
index 00cf6ef..e17ed7b 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java
@@ -45,7 +45,7 @@ public class SendWorkerEdgesRequest<I extends WritableComparable,
/**
* Constructor used to send request.
*
- * @param partVertEdges Map of remote partitions =>
+ * @param partVertEdges Map of remote partitions =>
* ByteArrayVertexIdEdges
*/
public SendWorkerEdgesRequest(
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
index 1f09739..8354094 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
@@ -43,7 +43,7 @@ public class SendWorkerMessagesRequest<I extends WritableComparable,
/**
* Constructor used to send request.
*
- * @param partVertMsgs Map of remote partitions =>
+ * @param partVertMsgs Map of remote partitions =>
* VertexIdMessages
*/
public SendWorkerMessagesRequest(
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneMessageToManyRequest.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneMessageToManyRequest.java b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneMessageToManyRequest.java
index bdaa871..7861f56 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneMessageToManyRequest.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneMessageToManyRequest.java
@@ -46,7 +46,7 @@ import org.apache.hadoop.io.WritableComparable;
public class SendWorkerOneMessageToManyRequest<I extends WritableComparable,
M extends Writable> extends WritableRequest<I, Writable, Writable>
implements WorkerRequest<I, Writable, Writable> {
- /** ByteArrayOneMessageToManyIds encoding of vertexId & messages */
+ /** ByteArrayOneMessageToManyIds encoding of vertexId & messages */
protected ByteArrayOneMessageToManyIds<I, M> oneMessageToManyIds;
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/conf/FacebookConfiguration.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/FacebookConfiguration.java b/giraph-core/src/main/java/org/apache/giraph/conf/FacebookConfiguration.java
index 0ba04f3..e11f3d0 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/FacebookConfiguration.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/FacebookConfiguration.java
@@ -94,7 +94,6 @@ public class FacebookConfiguration implements BulkConfigurator {
* {@link #CONFIGURE_JAVA_OPTS} setting
*
* @param conf Configuration
- * @return Configuration
*/
@Override
public void configure(GiraphConfiguration conf) {
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
index 4164c3a..ffed2e0 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
@@ -1104,7 +1104,7 @@ public class GiraphConfiguration extends Configuration
* Get the local hostname on the given interface.
*
* @return The local hostname
- * @throws UnknownHostException
+ * @throws UnknownHostException IP address of a host could not be determined
*/
public String getLocalHostname() throws UnknownHostException {
return DNS.getDefaultHost(
@@ -1116,7 +1116,7 @@ public class GiraphConfiguration extends Configuration
* Return local host name by default. Or local host IP if preferIP
* option is set.
* @return local host name or IP
- * @throws UnknownHostException
+ * @throws UnknownHostException IP address of a host could not be determined
*/
public String getLocalHostOrIp() throws UnknownHostException {
if (GiraphConstants.PREFER_IP_ADDRESSES.get(this)) {
@@ -1165,9 +1165,9 @@ public class GiraphConfiguration extends Configuration
/**
* Get string, replacing variables in the output.
*
- * %JOB_ID% => job id
- * %TASK_ID% => task id
- * %USER% => owning user name
+ * %JOB_ID% => job id
+ * %TASK_ID% => task id
+ * %USER% => owning user name
*
* @param key name of key to lookup
* @param context mapper context
@@ -1180,9 +1180,9 @@ public class GiraphConfiguration extends Configuration
/**
* Get string, replacing variables in the output.
*
- * %JOB_ID% => job id
- * %TASK_ID% => task id
- * %USER% => owning user name
+ * %JOB_ID% => job id
+ * %TASK_ID% => task id
+ * %USER% => owning user name
*
* @param key name of key to lookup
* @param defaultValue value to return if no mapping exists. This can also
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java
index 437d08a..14b8ddd 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java
@@ -1101,7 +1101,7 @@ public interface GiraphConstants {
"edges every time.");
/**
- * This option will tell which message encode & store enum to use when
+ * This option will tell which message encode & store enum to use when
* combining is not enabled
*/
EnumConfOption<MessageEncodeAndStoreType> MESSAGE_ENCODE_AND_STORE_TYPE =
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java b/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
index 91c8ed1..1d541c3 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
@@ -1289,7 +1289,7 @@ public class ImmutableClassesGiraphConfiguration<I extends WritableComparable,
}
/**
- * Has the user enabled compression in netty client & server
+ * Has the user enabled compression in netty client & server
*
* @return true if ok to do compression of netty requests
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/Consumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/Consumer.java b/giraph-core/src/main/java/org/apache/giraph/function/Consumer.java
index b5d49ab..3c21985 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/Consumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/Consumer.java
@@ -22,7 +22,7 @@ import java.io.Serializable;
/**
* Function:
- * (T) -> void
+ * (T) -> void
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/Function.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/Function.java b/giraph-core/src/main/java/org/apache/giraph/function/Function.java
index 3354fda..61f8061 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/Function.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/Function.java
@@ -22,7 +22,7 @@ import java.io.Serializable;
/**
* Function:
- * (F) -> T
+ * (F) -> T
*
* @param <F> Argument type
* @param <T> Result type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/ObjectTransfer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/ObjectTransfer.java b/giraph-core/src/main/java/org/apache/giraph/function/ObjectTransfer.java
index a67dd12..9c2b105 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/ObjectTransfer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/ObjectTransfer.java
@@ -81,7 +81,7 @@ public class ObjectTransfer<T> implements Supplier<T>, Consumer<T> {
* and to make code work without compile errors/warnings.
*
* In Java7, some callsites might need explicit types:
- * object.<LongWritable, DoubleWritable, Writable>castToSupplier()
+ * object.<LongWritable, DoubleWritable, Writable>castToSupplier()
* In Java8, object.castToSupplier() is always going to be enough.
*
* @param <I> Vertex id type
@@ -107,7 +107,7 @@ public class ObjectTransfer<T> implements Supplier<T>, Consumer<T> {
* and to make code work without compile errors/warnings.
*
* In Java7, some callsites might need explicit types:
- * object.<LongWritable, DoubleWritable, Writable>castToConsumer()
+ * object.<LongWritable, DoubleWritable, Writable>castToConsumer()
* In Java8, object.castToConsumer() is always going to be enough.
*
* @param <I> Vertex id type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/PairConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/PairConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/PairConsumer.java
index b1c633f..50ca8ab 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/PairConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/PairConsumer.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Function:
- * (T1, T2) -> void
+ * (T1, T2) -> void
*
* @param <T1> First argument type
* @param <T2> Second argument type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/PairFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/PairFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/PairFunction.java
index 49ee3bf..ff1bcc1 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/PairFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/PairFunction.java
@@ -22,7 +22,7 @@ import java.io.Serializable;
/**
* Function:
- * (F1, F2) -> T
+ * (F1, F2) -> T
*
* @param <F1> First argument type
* @param <F2> Second argument type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/PairPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/PairPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/PairPredicate.java
index 5203ef7..ef4c840 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/PairPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/PairPredicate.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Function:
- * (T) -> boolean
+ * (T) -> boolean
*
* @param <T1> First argument type
* @param <T2> Second argument type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/Predicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/Predicate.java b/giraph-core/src/main/java/org/apache/giraph/function/Predicate.java
index 0e4e3fd..73a350c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/Predicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/Predicate.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Function:
- * (T) -> boolean
+ * (T) -> boolean
* <br>
* Specialization of com.google.common.base.Predicate, that is also
* Serializable.
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/Supplier.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/Supplier.java b/giraph-core/src/main/java/org/apache/giraph/function/Supplier.java
index ce746d0..a7487f0 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/Supplier.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/Supplier.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Function:
- * () -> T
+ * () -> T
* <br>
* Specialization of com.google.common.base.Supplier, that is also
* Serializable.
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/TripleFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/TripleFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/TripleFunction.java
index 0c6a73c..89a011c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/TripleFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/TripleFunction.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Function:
- * (F1, F2, F3) -> T
+ * (F1, F2, F3) -> T
*
* @param <F1> First argument type
* @param <F2> Second argument type
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanConsumer.java
index a3e7991..3749b24 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean) -> void
+ * (boolean) -> void
*/
public interface BooleanConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanPredicate.java
index 13f28a9..793d02e 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean) -> boolean
+ * (boolean) -> boolean
*/
public interface BooleanPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ByteConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ByteConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ByteConsumer.java
index a936be8..60f74cb 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ByteConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte) -> void
+ * (byte) -> void
*/
public interface ByteConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BytePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BytePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BytePredicate.java
index d21fa30..5ecf4d2 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/BytePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/BytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte) -> boolean
+ * (byte) -> boolean
*/
public interface BytePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Double2ObjFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Double2ObjFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Double2ObjFunction.java
index 3feca25..98827bd 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Double2ObjFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Double2ObjFunction.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double) -> T
+ * (double) -> T
*
* @param <T> Result type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoubleConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoubleConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoubleConsumer.java
index f34e595..b321a3d 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoubleConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double) -> void
+ * (double) -> void
*/
public interface DoubleConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoublePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoublePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoublePredicate.java
index 60803a8..e854da3 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoublePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/DoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double) -> boolean
+ * (double) -> boolean
*/
public interface DoublePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatConsumer.java
index db2999e..ad68a8a 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float) -> void
+ * (float) -> void
*/
public interface FloatConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatPredicate.java
index 45c12f9..db2ded8 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/FloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float) -> boolean
+ * (float) -> boolean
*/
public interface FloatPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Int2ObjFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Int2ObjFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Int2ObjFunction.java
index 973c41b..b791bbb 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Int2ObjFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Int2ObjFunction.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (int) -> T
+ * (int) -> T
*
* @param <T> Result type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntConsumer.java
index f47ab74..3a7653c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (int) -> void
+ * (int) -> void
*/
public interface IntConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntPredicate.java
index a475d6e..a991f74 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (int) -> boolean
+ * (int) -> boolean
*/
public interface IntPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntSupplier.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntSupplier.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntSupplier.java
index c71b6d6..5f4113b 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntSupplier.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/IntSupplier.java
@@ -21,7 +21,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * () -> int
+ * () -> int
*/
public interface IntSupplier extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongConsumer.java
index 6ad9f80..8b7160f 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (long) -> void
+ * (long) -> void
*/
public interface LongConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongPredicate.java
index 4724d63..407e683 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/LongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (long) -> boolean
+ * (long) -> boolean
*/
public interface LongPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2BooleanFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2BooleanFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2BooleanFunction.java
index 0e39fca..1bed928 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2BooleanFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2BooleanFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> boolean
+ * (T) -> boolean
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ByteFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ByteFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ByteFunction.java
index 88d1ed3..acd3ea9 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ByteFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ByteFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> byte
+ * (T) -> byte
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2DoubleFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2DoubleFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2DoubleFunction.java
index 11b0fdf..0b0929c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2DoubleFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2DoubleFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> double
+ * (T) -> double
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2FloatFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2FloatFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2FloatFunction.java
index 01fb8bc..37e55ba 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2FloatFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2FloatFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> float
+ * (T) -> float
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2IntFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2IntFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2IntFunction.java
index 628c45e..428f6bc 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2IntFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2IntFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> int
+ * (T) -> int
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2LongFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2LongFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2LongFunction.java
index 4933523..12f4256 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2LongFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2LongFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> long
+ * (T) -> long
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ShortFunction.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ShortFunction.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ShortFunction.java
index 8208239..65c50dc 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ShortFunction.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/Obj2ShortFunction.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (T) -> short
+ * (T) -> short
*
* @param <T> Argument type
*/
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/PrimitiveRefs.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/PrimitiveRefs.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/PrimitiveRefs.java
index c83676f..5220686 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/PrimitiveRefs.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/PrimitiveRefs.java
@@ -117,8 +117,6 @@ public interface PrimitiveRefs {
/**
* Convenience class holding object values,
* for use when lambdas need to mutate capturing object local variable.
- *
- * <O> object
*/
public class ObjRef<O> {
/** value */
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortConsumer.java
index 125902c..0efd535 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (short) -> void
+ * (short) -> void
*/
public interface ShortConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortPredicate.java
index 1181f9f..b952685 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/ShortPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (short) -> boolean
+ * (short) -> boolean
*/
public interface ShortPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanConsumer.java
index 374dff2..12bd3c3 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, boolean) -> void
+ * (boolean, boolean) -> void
*/
public interface BooleanBooleanConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanPredicate.java
index 854f601..74ff7d8 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, boolean) -> boolean
+ * (boolean, boolean) -> boolean
*/
public interface BooleanBooleanPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanByteConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanByteConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanByteConsumer.java
index 6897bff..d9282e0 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanByteConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, byte) -> void
+ * (boolean, byte) -> void
*/
public interface BooleanByteConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBytePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBytePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBytePredicate.java
index fd2d2b2..319afa6 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBytePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, byte) -> boolean
+ * (boolean, byte) -> boolean
*/
public interface BooleanBytePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoubleConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoubleConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoubleConsumer.java
index c7d030e..39c6aa5 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoubleConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, double) -> void
+ * (boolean, double) -> void
*/
public interface BooleanDoubleConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoublePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoublePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoublePredicate.java
index 72c23d7..3fe6506 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoublePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, double) -> boolean
+ * (boolean, double) -> boolean
*/
public interface BooleanDoublePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatConsumer.java
index dd52ac8..0ec9719 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, float) -> void
+ * (boolean, float) -> void
*/
public interface BooleanFloatConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatPredicate.java
index f9a768a..cb49f21 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, float) -> boolean
+ * (boolean, float) -> boolean
*/
public interface BooleanFloatPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntConsumer.java
index b8d45a9..9ab7e92 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, int) -> void
+ * (boolean, int) -> void
*/
public interface BooleanIntConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntPredicate.java
index ec8bbc0..5e1cc0f 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, int) -> boolean
+ * (boolean, int) -> boolean
*/
public interface BooleanIntPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongConsumer.java
index f814955..c308544 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, long) -> void
+ * (boolean, long) -> void
*/
public interface BooleanLongConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongPredicate.java
index 80701b7..d4683e5 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/BooleanLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (boolean, long) -> boolean
+ * (boolean, long) -> boolean
*/
public interface BooleanLongPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanConsumer.java
index 047d4b7..e5aff3a 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, boolean) -> void
+ * (byte, boolean) -> void
*/
public interface ByteBooleanConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanPredicate.java
index be9a605..0238a1c 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, boolean) -> boolean
+ * (byte, boolean) -> boolean
*/
public interface ByteBooleanPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteByteConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteByteConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteByteConsumer.java
index 529e728..f013730 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteByteConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, byte) -> void
+ * (byte, byte) -> void
*/
public interface ByteByteConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBytePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBytePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBytePredicate.java
index 3c55276..e618b66 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBytePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, byte) -> boolean
+ * (byte, byte) -> boolean
*/
public interface ByteBytePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoubleConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoubleConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoubleConsumer.java
index d956883..dbfe5ee 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoubleConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, double) -> void
+ * (byte, double) -> void
*/
public interface ByteDoubleConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoublePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoublePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoublePredicate.java
index 35d3ea9..60335ab 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoublePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, double) -> boolean
+ * (byte, double) -> boolean
*/
public interface ByteDoublePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatConsumer.java
index 2336ff6..8046533 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, float) -> void
+ * (byte, float) -> void
*/
public interface ByteFloatConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatPredicate.java
index ddb2ff7..d300018 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, float) -> boolean
+ * (byte, float) -> boolean
*/
public interface ByteFloatPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntConsumer.java
index cddda29..4a84655 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, int) -> void
+ * (byte, int) -> void
*/
public interface ByteIntConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntPredicate.java
index 94434f8..3954334 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, int) -> boolean
+ * (byte, int) -> boolean
*/
public interface ByteIntPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongConsumer.java
index 25ecf95..93efeab 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, long) -> void
+ * (byte, long) -> void
*/
public interface ByteLongConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongPredicate.java
index 18ab03e..a309d98 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/ByteLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (byte, long) -> boolean
+ * (byte, long) -> boolean
*/
public interface ByteLongPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanConsumer.java
index 983f4fc..c01df67 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, boolean) -> void
+ * (double, boolean) -> void
*/
public interface DoubleBooleanConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanPredicate.java
index 660e98b..6521ad9 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, boolean) -> boolean
+ * (double, boolean) -> boolean
*/
public interface DoubleBooleanPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleByteConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleByteConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleByteConsumer.java
index 9b20464..fdbdc06 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleByteConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, byte) -> void
+ * (double, byte) -> void
*/
public interface DoubleByteConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBytePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBytePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBytePredicate.java
index 07012b0..2a55a21 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBytePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, byte) -> boolean
+ * (double, byte) -> boolean
*/
public interface DoubleBytePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoubleConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoubleConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoubleConsumer.java
index 3f974bc..61f18f4 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoubleConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoubleConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, double) -> void
+ * (double, double) -> void
*/
public interface DoubleDoubleConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoublePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoublePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoublePredicate.java
index 90733d8..363be52 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoublePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleDoublePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, double) -> boolean
+ * (double, double) -> boolean
*/
public interface DoubleDoublePredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatConsumer.java
index 878e2fa..417a874 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, float) -> void
+ * (double, float) -> void
*/
public interface DoubleFloatConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatPredicate.java
index d86dd13..141cbd8 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleFloatPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, float) -> boolean
+ * (double, float) -> boolean
*/
public interface DoubleFloatPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntConsumer.java
index e63afa2..8d20eea 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, int) -> void
+ * (double, int) -> void
*/
public interface DoubleIntConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntPredicate.java
index 7c48085..af80fd0 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleIntPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, int) -> boolean
+ * (double, int) -> boolean
*/
public interface DoubleIntPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongConsumer.java
index 3d2c1c2..7ca5e2e 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, long) -> void
+ * (double, long) -> void
*/
public interface DoubleLongConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongPredicate.java
index 45f4337..a297e34 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/DoubleLongPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (double, long) -> boolean
+ * (double, long) -> boolean
*/
public interface DoubleLongPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanConsumer.java
index cc9b989..87be0a8 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float, boolean) -> void
+ * (float, boolean) -> void
*/
public interface FloatBooleanConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanPredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanPredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanPredicate.java
index 5947094..a38ec35 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanPredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBooleanPredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float, boolean) -> boolean
+ * (float, boolean) -> boolean
*/
public interface FloatBooleanPredicate extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatByteConsumer.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatByteConsumer.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatByteConsumer.java
index cf0f05f..15bf428 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatByteConsumer.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatByteConsumer.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float, byte) -> void
+ * (float, byte) -> void
*/
public interface FloatByteConsumer extends Serializable {
/**
http://git-wip-us.apache.org/repos/asf/giraph/blob/70c6545a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBytePredicate.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBytePredicate.java b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBytePredicate.java
index 6d19b56..7514066 100644
--- a/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBytePredicate.java
+++ b/giraph-core/src/main/java/org/apache/giraph/function/primitive/pairs/FloatBytePredicate.java
@@ -24,7 +24,7 @@ import java.io.Serializable;
/**
* Primitive specialization of Function:
- * (float, byte) -> boolean
+ * (float, byte) -> boolean
*/
public interface FloatBytePredicate extends Serializable {
/**
[2/3] git commit: updated refs/heads/trunk to 70c6545
Posted by ed...@apache.org.
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<Vertex<I, V, E>, T>,
+ * 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 & 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>]+
+ * <VertexId><tab><Vertex Value><tab>
+ * [<EdgeId><tab><EdgeValue>]+
*
* @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 & 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<LongWritable, ByteWritable>
*
* 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 & 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 & 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 & 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->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<T> 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<WorkerInfo, VertexEdgeCount> 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<L, R>, 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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, < 0 if first entry is smaller than the
+ * second one, and > 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<Int2ByteMap.Entry>
*/
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<Int2DoubleMap.Entry>
*/
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<Int2FloatMap.Entry>
*/
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<Int2IntMap.Entry>
*/
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<Int2LongMap.Entry>
*/
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<Long2ByteMap.Entry>
*/
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<Long2DoubleMap.Entry>
*/
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<Long2FloatMap.Entry>
*/
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<Long2IntMap.Entry>
*/
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<Long2LongMap.Entry>
*/
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<value2 and
+ * positive value if value1>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<T> 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<M> 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 > id count > 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&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&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 & 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 & 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->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 -> 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, < 0 if first entry is smaller than the
+ * second one, and > 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) -> ${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<${type1.camel}2${type2.camel}Map.Entry>
*/
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}) -> 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}) -> 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}) -> 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}) -> 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.