Package com.alibaba.graphscope.format

Class LongLongInputFormat

  • All Implemented Interfaces:
    org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,​LongLong>, org.apache.hadoop.mapred.JobConfigurable
    public class LongLongInputFormat
extends org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.LongWritable,​LongLong>
implements org.apache.hadoop.mapred.JobConfigurable

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileInputFormat

        org.apache.hadoop.mapred.FileInputFormat.Counter

    • Field Summary

      • Fields inherited from class org.apache.hadoop.mapred.FileInputFormat

        INPUT_DIR_NONRECURSIVE_IGNORE_SUBDIRS, INPUT_DIR_RECURSIVE, LOG, NUM_INPUT_FILES

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void configure​(org.apache.hadoop.mapred.JobConf jobConf)  
      org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong> getRecordReader​(org.apache.hadoop.mapred.InputSplit genericSplit, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)  
      protected boolean isSplittable​(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file)  

      • Methods inherited from class org.apache.hadoop.mapred.FileInputFormat

        addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, isSplitable, listStatus, makeSplit, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize

    • Constructor Detail

      • LongLongInputFormat

        public LongLongInputFormat()

    • Method Detail

      • isSplittable

        protected boolean isSplittable​(org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.fs.Path file)

      • getRecordReader

        public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong> getRecordReader​(org.apache.hadoop.mapred.InputSplit genericSplit,
                                                                                                               org.apache.hadoop.mapred.JobConf job,
                                                                                                               org.apache.hadoop.mapred.Reporter reporter)
                                                                                                        throws IOException
        Specified by:
        getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,​LongLong>
        Specified by:
        getRecordReader in class org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.LongWritable,​LongLong>
        Throws:
        IOException

      • configure

        public void configure​(org.apache.hadoop.mapred.JobConf jobConf)
        Specified by:
        configure in interface org.apache.hadoop.mapred.JobConfigurable