hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thomas Jungblut <thomas.jungb...@googlemail.com>
Subject Re: svn commit: r1347678 - /incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java
Date Fri, 08 Jun 2012 05:23:15 GMT
Thanks!

2012/6/8 Edward J. Yoon <edwardyoon@apache.org>

> Arguments were defined in wrong order. I've committed to TRUNK directly.
>
> On Fri, Jun 8, 2012 at 12:25 AM,  <tjungblut@apache.org> wrote:
> > Author: tjungblut
> > Date: Thu Jun  7 15:25:15 2012
> > New Revision: 1347678
> >
> > URL: http://svn.apache.org/viewvc?rev=1347678&view=rev
> > Log:
> > fix small bug
> >
> > Modified:
> >
>  incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java
> >
> > Modified:
> incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java
> > URL:
> http://svn.apache.org/viewvc/incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java?rev=1347678&r1=1347677&r2=1347678&view=diff
> >
> ==============================================================================
> > ---
> incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java
> (original)
> > +++
> incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/InlinkCount.java
> Thu Jun  7 15:25:15 2012
> > @@ -34,12 +34,13 @@ import org.apache.hama.graph.GraphJob;
> >  import org.apache.hama.graph.Vertex;
> >  import org.apache.hama.graph.VertexInputReader;
> >
> > -public class InlinkCount extends Vertex<Text, NullWritable,
> IntWritable> {
> > +public class InlinkCount extends Vertex<Text, IntWritable,
> NullWritable> {
> >
> >   @Override
> >   public void compute(Iterator<IntWritable> messages) throws IOException
> {
> >
> >     if (getSuperstepCount() == 0L) {
> > +      setValue(new IntWritable(0));
> >       sendMessageToNeighbors(new IntWritable(1));
> >     } else {
> >       while (messages.hasNext()) {
> > @@ -50,7 +51,7 @@ public class InlinkCount extends Vertex<
> >   }
> >
> >   public static class InlinkCountTextReader extends
> > -      VertexInputReader<LongWritable, Text, Text, NullWritable,
> IntWritable> {
> > +      VertexInputReader<LongWritable, Text, Text, IntWritable,
> NullWritable> {
> >
> >     /**
> >      * The text file essentially should look like: <br/>
> > @@ -62,7 +63,7 @@ public class InlinkCount extends Vertex<
> >      */
> >     @Override
> >     public boolean parseVertex(LongWritable key, Text value,
> > -        Vertex<Text, NullWritable, IntWritable> vertex) {
> > +        Vertex<Text, IntWritable, NullWritable> vertex) {
> >       String[] split = value.toString().split("\t");
> >       for (int i = 0; i < split.length; i++) {
> >         if (i == 0) {
> >
> >
>
>
>
> --
> Best Regards, Edward J. Yoon
> @eddieyoon
>



-- 
Thomas Jungblut
Berlin <thomas.jungblut@gmail.com>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message