public abstract class HiveContextAwareRecordReader<K,V>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected boolean |
isSorted |
protected JobConf |
jobConf |
protected RecordReader |
recordReader |
Constructor and Description |
---|
HiveContextAwareRecordReader(JobConf conf) |
HiveContextAwareRecordReader(RecordReader recordReader) |
HiveContextAwareRecordReader(RecordReader recordReader,
JobConf conf) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
abstract void |
doClose()
Close this
InputSplit to future operations. |
boolean |
doNext(K key,
V value) |
boolean |
foundAllTargets()
Returns true if the current comparison is in the list of stop comparisons, i.e.
|
IOContext |
getIOContext() |
float |
getProgress() |
void |
initIOContext(FileSplit split,
JobConf job,
java.lang.Class inputFormatClass) |
void |
initIOContext(FileSplit split,
JobConf job,
java.lang.Class inputFormatClass,
RecordReader recordReader) |
void |
initIOContext(long startPos,
boolean isBlockPointer,
java.lang.String inputFile) |
void |
initIOContextSortedProps(FileSplit split,
RecordReader recordReader,
JobConf job) |
boolean |
next(K key,
V value) |
void |
setRecordReader(RecordReader recordReader) |
protected void |
updateIOContext() |
protected RecordReader recordReader
protected JobConf jobConf
protected boolean isSorted
public HiveContextAwareRecordReader(JobConf conf) throws java.io.IOException
java.io.IOException
public HiveContextAwareRecordReader(RecordReader recordReader)
public HiveContextAwareRecordReader(RecordReader recordReader, JobConf conf) throws java.io.IOException
java.io.IOException
public void setRecordReader(RecordReader recordReader)
public abstract void doClose() throws java.io.IOException
InputSplit
to future operations.java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
protected void updateIOContext() throws java.io.IOException
java.io.IOException
public IOContext getIOContext()
public void initIOContext(long startPos, boolean isBlockPointer, java.lang.String inputFile)
public void initIOContext(FileSplit split, JobConf job, java.lang.Class inputFormatClass) throws java.io.IOException
java.io.IOException
public void initIOContext(FileSplit split, JobConf job, java.lang.Class inputFormatClass, RecordReader recordReader) throws java.io.IOException
java.io.IOException
public void initIOContextSortedProps(FileSplit split, RecordReader recordReader, JobConf job)
public float getProgress() throws java.io.IOException
java.io.IOException
public boolean foundAllTargets()
Copyright © 2012 The Apache Software Foundation