Hi Mr.Seo, Please look at VertexInputReader.convertRecord() method. see also PartitioningRunner and RecordConverter classes[1].
1. http://svn.apache.org/repos/asf/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java On Fri, May 3, 2013 at 5:49 PM, Jiwon Seo <[email protected]> wrote: > Hi, > > I'm trying to understand how vertex loading is done in hama. > > The part that I don't understand is, the relation between VertexInputReader > and InputFormat. > > As far as I understand, VertexInputReader.parseVertex is the method to > initialize each vertex, but it is not clear where the function is called in > Hama 0.6.1. > In Hama 0.6.0, the parseVertex function is explicitly called inside > GraphJobRunner::loadVertices, but in Hama 0.6.1, it is replaced with > peer.readNext(vertex, NullWritable.get()), and parseVertex does not seem to > get called. Where is the function called? > > Thanks, > > -Jiwon -- Best Regards, Edward J. Yoon @eddieyoon
