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

  • Type Parameters:
    I - Vertex id
    E - Edge data
    All Implemented Interfaces:
    org.apache.giraph.conf.GiraphConfigurationSettable<I,​org.apache.hadoop.io.Writable,​E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​org.apache.hadoop.io.Writable,​E>
    Direct Known Subclasses:
    CircleEdgeInputFormat, DatagenEdgeInputFormat, LiveJournalEdgeInputFormat, P2PEdgeInputFormat, P2PEdgeMultipleLongInputFormat

    public abstract class TextEdgeInputFormat<I extends org.apache.hadoop.io.WritableComparable,​E extends org.apache.hadoop.io.Writable>
    extends org.apache.giraph.io.EdgeInputFormat<I,​E>
    Abstract class that users should subclass to use their own text based edge output format.
    • Constructor Detail

      • TextEdgeInputFormat

        public TextEdgeInputFormat()
    • Method Detail

      • checkInputSpecs

        public void checkInputSpecs​(org.apache.hadoop.conf.Configuration conf)
        Specified by:
        checkInputSpecs in class org.apache.giraph.io.GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,​org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
      • getSplits

        public List<org.apache.hadoop.mapreduce.InputSplit> getSplits​(org.apache.hadoop.mapreduce.JobContext context,
                                                                      int minSplitCountHint)
                                                               throws IOException,
                                                                      InterruptedException
        Specified by:
        getSplits in class org.apache.giraph.io.GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,​org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
        Throws:
        IOException
        InterruptedException