Package com.alibaba.graphscope.example.giraph.format

Class P2PEdgeMultipleLongInputFormat

  • All Implemented Interfaces:
    org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Writable,​MultipleLongWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Writable,​MultipleLongWritable>
    public class P2PEdgeMultipleLongInputFormat
extends TextEdgeInputFormat<org.apache.hadoop.io.LongWritable,​MultipleLongWritable>

    • Constructor Detail

      • P2PEdgeMultipleLongInputFormat

        public P2PEdgeMultipleLongInputFormat()

    • Method Detail

      • createEdgeReader

        public org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,​MultipleLongWritable> 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,​MultipleLongWritable>
        Parameters:
        split - the split to be read
        context - the information about the task
        Returns:
        a new record reader
        Throws:
        IOException