Java 类org.apache.hadoop.mapred.SequenceFileRecordReader 实例源码

public ContentAsTextRecordReader(Configuration conf, FileSplit split)
    throws IOException {
  sequenceFileRecordReader = new SequenceFileRecordReader<Text, Content>(
      conf, split);
  innerKey = sequenceFileRecordReader.createKey();
  innerValue = sequenceFileRecordReader.createValue();
}

@Override
public RecordReader<K,V> getRecordReader(InputSplit split,JobConf job, Reporter reporter)
       throws IOException 
   {
    if(reporter!=null)
        reporter.setStatus(split.toString());
    return new SequenceFileRecordReader<>(job, (FileSplit) split);
   }

public ContentAsTextRecordReader(Configuration conf, FileSplit split)
  throws IOException {
  sequenceFileRecordReader = new SequenceFileRecordReader<Text, Content>(
    conf, split);
  innerKey = (Text)sequenceFileRecordReader.createKey();
  innerValue = (Content)sequenceFileRecordReader.createValue();
}

@Override
public RecordReader<K, V> getRecordReader(InputSplit split, JobConf job, Reporter reporter)
        throws IOException {

    reporter.setStatus(split.toString());

    return new SequenceFileRecordReader<K, V>(job, (FileSplit) split);
}

@Override
public RecordReader getRecordReader(InputSplit split,
        JobConf job, Reporter reporter) throws IOException {

    SplitLen = split.getLength();
    FileSplit f = (FileSplit)split; 
    path = f.getPath();
    j=job;

    return new SequenceFileRecordReader(job, (FileSplit) split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

public RecordReader<LongWritable, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, Text>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job,
      (FileSplit) split);
}

@Override
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit) split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
        JobConf job, Reporter reporter) throws IOException
{
    return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

/**
 * {@inheritDoc}
 */
public RecordReader<Text, PolicyInfo> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, PolicyInfo>(job,
      (FileSplit) split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

@Override
public void initialize(GuaguaFileSplit split) throws IOException {
    FileSplit fileSplit = new FileSplit(new Path(split.getPath()), split.getOffset(), split.getLength(),
            (String[]) null);
    this.sequenceReader = new SequenceFileRecordReader<KEY, VALUE>(conf, fileSplit);
}

@Override
public void initialize(GuaguaFileSplit split) throws IOException {
    FileSplit fileSplit = new FileSplit(new Path(split.getPath()), split.getOffset(), split.getLength(),
            (String[]) null);
    this.sequenceReader = new SequenceFileRecordReader<KEY, VALUE>(conf, fileSplit);
}

@Override
public void initialize(GuaguaFileSplit split) throws IOException {
    FileSplit fileSplit = new FileSplit(new Path(split.getPath()), split.getOffset(), split.getLength(),
            (String[]) null);
    this.sequenceReader = new SequenceFileRecordReader<KEY, VALUE>(conf, fileSplit);
}

@Override
public void initialize(GuaguaFileSplit split) throws IOException {
    FileSplit fileSplit = new FileSplit(new Path(split.getPath()), split.getOffset(), split.getLength(),
            (String[]) null);
    this.sequenceReader = new SequenceFileRecordReader<KEY, VALUE>(conf, fileSplit);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}

/** {@inheritDoc} */
public RecordReader<Text, FileOperation> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, FileOperation>(job,
      (FileSplit)split);
}

/**
 * Returns a reader for this split of the src file list.
 */
public RecordReader<Text, Text> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<Text, Text>(job, (FileSplit)split);
}

@Override
public RecordReader<LongWritable, HarEntry> getRecordReader(InputSplit split,
    JobConf job, Reporter reporter) throws IOException {
  return new SequenceFileRecordReader<LongWritable, HarEntry>(job,
             (FileSplit)split);
}