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

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable,Text> getRecordReader(InputSplit split,JobConf job,Reporter reporter)throws IOException
{
       reporter.setStatus(split.toString());
        String delimiter = job.get("textinputformat.record.delimiter");
        byte[] recordDelimiterBytes = null;
        if (null != delimiter) {
          recordDelimiterBytes = delimiter.getBytes(Charsets.UTF_8);
        }
        return new LineRecordReader(job, (FileSplit) split,recordDelimiterBytes);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, BytesWritable> getRecordReader(
    InputSplit genericSplit, JobConf job, Reporter reporter) throws IOException {
  reporter.setStatus(genericSplit.toString());
  Base64LineRecordReader reader = new Base64LineRecordReader(
      new LineRecordReader(job, (FileSplit) genericSplit));
  reader.configure(job);
  return reader;
}

@Override
public RecordReader<LongWritable, Text> getRecordReader(
        InputSplit genericSplit, JobConf job, Reporter reporter)
        throws IOException {
    reporter.setStatus(genericSplit.toString());
    MyDemoRecordReader reader = new MyDemoRecordReader(
            new LineRecordReader(job, (FileSplit) genericSplit));
    return reader;
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public RecordReader<LongWritable, Text> getRecordReader(
                                          InputSplit genericSplit,
                                          JobConf job,
                                          Reporter reporter) 
throws IOException {
  reporter.setStatus(genericSplit.toString());
  return new LineRecordReader(job, (FileSplit) genericSplit);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public ParagraphRecordReader(JobConf conf, FileSplit split)
        throws IOException {
    lineRecord = new LineRecordReader(conf, split);
    lineKey = lineRecord.createKey();
    lineValue = lineRecord.createValue();
}

public ParagraphRecordReader(JobConf conf, FileSplit split)
        throws IOException {
    lineRecord = new LineRecordReader(conf, split);
    lineKey = lineRecord.createKey();
    lineValue = lineRecord.createValue();
}

public ParagraphRecordReader(JobConf conf, FileSplit split)
        throws IOException {
    lineRecord = new LineRecordReader(conf, split);
    lineKey = lineRecord.createKey();
    lineValue = lineRecord.createValue();
}

public Base64LineRecordReader(LineRecordReader reader) {
  this.reader = reader;
  text = reader.createValue();
}

public MyDemoRecordReader(LineRecordReader reader) {
    this.reader = reader;
    text = reader.createValue();
}

@Override
public RecordReader<LongWritable, Text> getRecordReader(InputSplit inputSplit, JobConf jobConf,
    Reporter reporter) throws IOException {
  return new LineRecordReader(jobConf, (FileSplit) inputSplit);
}

public SequenceRecordReader(JobConf job, FileSplit split) throws IOException {
    lineReader = new LineRecordReader(job, split);
    lineKey = lineReader.createKey();
    lineValue = lineReader.createValue();
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public SimpleJsonRecordReader(Configuration conf, FileSplit split)
        throws IOException {
    rdr = new LineRecordReader(conf, split);
}

public TeraRecordReader(Configuration job,
        FileSplit split) throws IOException {
    in = new LineRecordReader(job, split);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public TeraRecordReader(Configuration job, 
                        FileSplit split) throws IOException {
  in = new LineRecordReader(job, split);
}

public FilenameKeyLineRecordReader(Configuration job,
                                   FileSplit split) throws IOException {
    lineRecordReader = new LineRecordReader(job, (FileSplit) split);
    fileName = split.getPath().getName();
    longKey = new LongWritable();
}