Class LiveJournalEdgeInputFormat

  • All Implemented Interfaces:
    org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Writable,​org.apache.hadoop.io.LongWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Writable,​org.apache.hadoop.io.LongWritable>

    public class LiveJournalEdgeInputFormat
    extends TextEdgeInputFormat<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable>
    • Constructor Detail

      • LiveJournalEdgeInputFormat

        public LiveJournalEdgeInputFormat()
    • Method Detail

      • createEdgeReader

        public org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable> createEdgeReader​(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                                           org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                                                    throws IOException
        Create an edge reader for a given split. The framework will call EdgeReader.initialize(InputSplit, TaskAttemptContext) before the split is used.
        Specified by:
        createEdgeReader in class org.apache.giraph.io.EdgeInputFormat<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable>
        Parameters:
        split - the split to be read
        context - the information about the task
        Returns:
        a new record reader
        Throws:
        IOException