public class BucketizedHiveRecordReader<K extends WritableComparable,V extends Writable> extends HiveContextAwareRecordReader<K,V>
Modifier and Type | Field and Description |
---|---|
protected int |
idx |
protected InputFormat |
inputFormat |
protected long |
progress |
protected Reporter |
reporter |
protected BucketizedHiveInputSplit |
split |
isSorted, jobConf, recordReader
Constructor and Description |
---|
BucketizedHiveRecordReader(InputFormat inputFormat,
BucketizedHiveInputSplit bucketizedSplit,
JobConf jobConf,
Reporter reporter) |
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() |
protected boolean |
initNextRecordReader()
Get the record reader for the next chunk in this
BucketizedHiveRecordReader.
|
close, foundAllTargets, getIOContext, initIOContext, initIOContext, initIOContext, initIOContextSortedProps, next, setRecordReader, updateIOContext
protected final BucketizedHiveInputSplit split
protected final InputFormat inputFormat
protected final Reporter reporter
protected long progress
protected int idx
public BucketizedHiveRecordReader(InputFormat inputFormat, BucketizedHiveInputSplit bucketizedSplit, JobConf jobConf, Reporter reporter) 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
public boolean doNext(K key, V value) throws java.io.IOException
doNext
in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>
java.io.IOException
protected boolean initNextRecordReader() throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation