public class WacWarcInputFormat.WarcRecordReader extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
Constructor and Description |
---|
WarcRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.LongWritable |
getCurrentKey() |
WarcRecordWritable |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
public WarcRecordReader()
public final void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
IOException
public final boolean nextKeyValue() throws IOException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
IOException
public final org.apache.hadoop.io.LongWritable getCurrentKey()
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
public final WarcRecordWritable getCurrentValue()
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
public final float getProgress() throws IOException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
IOException
public final void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,WarcRecordWritable>
IOException
Copyright © 2017 The Archives Unleased Project. All rights reserved.