K
- V
- public class CombineHiveRecordReader<K extends WritableComparable,V extends Writable> extends HiveContextAwareRecordReader<K,V>
isSorted, jobConf, recordReader
Constructor and Description |
---|
CombineHiveRecordReader(InputSplit split,
Configuration conf,
Reporter reporter,
java.lang.Integer partition) |
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 CombineHiveRecordReader(InputSplit split, Configuration conf, Reporter reporter, java.lang.Integer partition) 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