public class HiveRecordReader<K extends WritableComparable,V extends Writable> extends HiveContextAwareRecordReader<K,V>
isSorted, jobConf, recordReader
Constructor and Description |
---|
HiveRecordReader(RecordReader recordReader) |
HiveRecordReader(RecordReader recordReader,
JobConf conf) |
Modifier and Type | Method and Description |
---|---|
K |
createKey() |
V |
createValue() |
void |
doClose()
Close this
InputSplit to future operations. |
boolean |
doNext(K key,
V value) |
long |
getPos() |
float |
getProgress() |
close, foundAllTargets, getIOContext, initIOContext, initIOContext, initIOContext, initIOContextSortedProps, next, setRecordReader, updateIOContext
public HiveRecordReader(RecordReader recordReader) throws java.io.IOException
java.io.IOException
public HiveRecordReader(RecordReader recordReader, JobConf conf) throws java.io.IOException
java.io.IOException
public void doClose() throws java.io.IOException
HiveContextAwareRecordReader
InputSplit
to future operations.doClose
in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>
java.io.IOException
public K createKey()
public V createValue()
public long getPos() throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
getProgress
in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>
java.io.IOException
Copyright © 2012 The Apache Software Foundation