Class TextVertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>

  • Type Parameters:
    I - Vertex index value
    V - Vertex value
    E - Edge value
    All Implemented Interfaces:
    org.apache.giraph.conf.GiraphConfigurationSettable<I,​V,​E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​V,​E>
    Direct Known Subclasses:
    PageRank.SimplePageRankVertexOutputFormat, SSSP.SimpleSuperstepVertexOutputFormat

    public abstract class TextVertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
    extends org.apache.giraph.io.VertexOutputFormat<I,​V,​E>
    Abstract class that users should subclass to use their own text based vertex output format.
    • Field Detail

      • textOutputFormat

        protected GiraphTextOutputFormat textOutputFormat
        Giraph made this file protected here, so we need to provide this
    • Constructor Detail

      • TextVertexOutputFormat

        public TextVertexOutputFormat()
    • Method Detail

      • checkOutputSpecs

        public void checkOutputSpecs​(org.apache.hadoop.mapreduce.JobContext context)
                              throws IOException,
                                     InterruptedException
        Specified by:
        checkOutputSpecs in class org.apache.giraph.io.OutputFormat<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
        Throws:
        IOException
        InterruptedException
      • getOutputCommitter

        public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter​(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                       throws IOException,
                                                                              InterruptedException
        Specified by:
        getOutputCommitter in class org.apache.giraph.io.OutputFormat<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
        Throws:
        IOException
        InterruptedException