Author: jghoman
Date: Fri Aug 26 01:13:47 2011
New Revision: 1161954
URL: http://svn.apache.org/viewvc?rev=1161954&view=rev
Log:
GIRAPH-3. Vertex:sentMsgToAllEdges should be sendMsg. (jghoman)
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/Vertex.java
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java?rev=1161954&r1=1161953&r2=1161954&view=diff
==============================================================================
---
incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
(original)
+++
incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
Fri Aug 26 01:13:47 2011
@@ -73,7 +73,7 @@ public class PageRankBenchmark extends
if (getSuperstep() < getConf().getInt(SUPERSTEP_COUNT, -1)) {
long edges = getOutEdgeMap().size();
- sentMsgToAllEdges(
+ sendMsgToAllEdges(
new DoubleWritable(getVertexValue().get() / edges));
} else {
voteToHalt();
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java?rev=1161954&r1=1161953&r2=1161954&view=diff
==============================================================================
---
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java
(original)
+++
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java
Fri Aug 26 01:13:47 2011
@@ -57,7 +57,7 @@ public class SimpleFailVertex extends
}
}
long edges = getOutEdgeMap().size();
- sentMsgToAllEdges(
+ sendMsgToAllEdges(
new DoubleWritable(getVertexValue().get() / edges));
} else {
voteToHalt();
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java?rev=1161954&r1=1161953&r2=1161954&view=diff
==============================================================================
---
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java
(original)
+++
incubator/giraph/trunk/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java
Fri Aug 26 01:13:47 2011
@@ -124,7 +124,7 @@ public class SimplePageRankVertex extend
if (getSuperstep() < 30) {
long edges = getOutEdgeMap().size();
- sentMsgToAllEdges(
+ sendMsgToAllEdges(
new DoubleWritable(getVertexValue().get() / edges));
} else {
voteToHalt();
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java?rev=1161954&r1=1161953&r2=1161954&view=diff
==============================================================================
---
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java
(original)
+++
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertex.java
Fri Aug 26 01:13:47 2011
@@ -138,7 +138,7 @@ public interface BasicVertex<I extends W
/**
* Send a message to all edges.
*/
- void sentMsgToAllEdges(M msg);
+ void sendMsgToAllEdges(M msg);
/**
* After this is called, the compute() code will no longer be called for
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/Vertex.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/Vertex.java?rev=1161954&r1=1161953&r2=1161954&view=diff
==============================================================================
--- incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/Vertex.java
(original)
+++ incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/Vertex.java
Fri Aug 26 01:13:47 2011
@@ -200,7 +200,7 @@ public abstract class Vertex<
}
@Override
- public final void sentMsgToAllEdges(M msg) {
+ public final void sendMsgToAllEdges(M msg) {
if (msg == null) {
throw new IllegalArgumentException(
"sendMsgToAllEdges: Cannot send null message to all edges");