public class ArchiveRecordInputFormat.ArchiveRecordReader extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
Constructor and Description |
---|
ArchiveRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.LongWritable |
getCurrentKey() |
ArchiveRecordWritable |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit archiveRecordSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
public ArchiveRecordReader()
public final void initialize(org.apache.hadoop.mapreduce.InputSplit archiveRecordSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
IOException
public final boolean nextKeyValue() throws IOException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
IOException
public final org.apache.hadoop.io.LongWritable getCurrentKey()
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
public final ArchiveRecordWritable getCurrentValue()
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
public final float getProgress() throws IOException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,ArchiveRecordWritable>
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,ArchiveRecordWritable>
IOException
Copyright © 2017–2020 The Archives Unleashed Project. All rights reserved.