Package org.apache.giraph.io.formats

Class TextVertexInputFormat.TextVertexReaderFromEachLine

  • All Implemented Interfaces:
    org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<I,​V,​E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​V,​E>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage
    Enclosing class:
    TextVertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
    protected abstract class TextVertexInputFormat.TextVertexReaderFromEachLine
extends TextVertexInputFormat.TextVertexReader
    Abstract class to be implemented by the user to read a vertex from each text line.

    • Constructor Detail

      • TextVertexReaderFromEachLine

        protected TextVertexReaderFromEachLine()

    • Method Detail

      • getCurrentVertex

        public final org.apache.giraph.graph.Vertex<I,​V,​E> getCurrentVertex()
                                                                         throws IOException,
                                                                                InterruptedException
        Specified by:
        getCurrentVertex in class org.apache.giraph.io.VertexReader<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
        Throws:
        IOException
        InterruptedException

      • nextVertex

        public final boolean nextVertex()
                         throws IOException,
                                InterruptedException
        Specified by:
        nextVertex in class org.apache.giraph.io.VertexReader<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
        Throws:
        IOException
        InterruptedException

      • getId

        protected abstract I getId​(org.apache.hadoop.io.Text line)
                    throws IOException
        Reads vertex id from the current line.
        Parameters:
        line - the current line
        Returns:
        the vertex id corresponding to the line
        Throws:
        IOException - exception that can be thrown while reading

      • getValue

        protected abstract V getValue​(org.apache.hadoop.io.Text line)
                       throws IOException
        Reads vertex value from the current line.
        Parameters:
        line - the current line
        Returns:
        the vertex value corresponding to the line
        Throws:
        IOException - exception that can be thrown while reading

      • getEdges

        protected abstract Iterable<org.apache.giraph.edge.Edge<I,​E>> getEdges​(org.apache.hadoop.io.Text line)
                                                                      throws IOException
        Reads edges value from the current line.
        Parameters:
        line - the current line
        Returns:
        the edges
        Throws:
        IOException - exception that can be thrown while reading