K
- V
- public class RCFileRecordReader<K extends org.apache.hadoop.io.LongWritable,V extends BytesRefArrayWritable> extends Object implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
Constructor and Description |
---|
RCFileRecordReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapred.FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.LongWritable |
createKey() |
BytesRefArrayWritable |
createValue() |
RCFile.KeyBuffer |
getKeyBuffer() |
Class<?> |
getKeyClass() |
long |
getPos() |
float |
getProgress()
Return the progress within the input split.
|
long |
getStart() |
Class<?> |
getValueClass() |
protected boolean |
next(org.apache.hadoop.io.LongWritable key) |
boolean |
next(org.apache.hadoop.io.LongWritable key,
BytesRefArrayWritable value) |
boolean |
nextBlock() |
void |
resetBuffer() |
protected void |
seek(long pos) |
void |
sync(long pos) |
public RCFileRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split) throws IOException
IOException
public Class<?> getKeyClass()
public Class<?> getValueClass()
public org.apache.hadoop.io.LongWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
public BytesRefArrayWritable createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
public boolean nextBlock() throws IOException
IOException
public boolean next(org.apache.hadoop.io.LongWritable key, BytesRefArrayWritable value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
IOException
protected boolean next(org.apache.hadoop.io.LongWritable key) throws IOException
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
IOException
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
IOException
public RCFile.KeyBuffer getKeyBuffer()
protected void seek(long pos) throws IOException
IOException
public void sync(long pos) throws IOException
IOException
public void resetBuffer()
public long getStart()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,BytesRefArrayWritable>
IOException
Copyright © 2023 The Apache Software Foundation. All rights reserved.