protected abstract static class EsInputFormat.EsInputRecordReader<K,V> extends RecordReader<K,V> implements RecordReader<K,V>
Constructor and Description |
---|
EsInputRecordReader() |
EsInputRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
abstract K |
createKey() |
abstract V |
createValue() |
K |
getCurrentKey() |
V |
getCurrentValue() |
long |
getPos() |
float |
getProgress() |
void |
initialize(InputSplit split,
TaskAttemptContext context) |
boolean |
next(K key,
V value) |
boolean |
nextKeyValue() |
protected abstract K |
setCurrentKey(K hadoopKey,
java.lang.Object object)
Sets the current key.
|
protected abstract V |
setCurrentValue(V hadoopValue,
java.lang.Object object)
Sets the current value.
|
public EsInputRecordReader()
public EsInputRecordReader(InputSplit split, Configuration job, Reporter reporter)
public void initialize(InputSplit split, TaskAttemptContext context) throws java.io.IOException
initialize
in class RecordReader<K,V>
java.io.IOException
public boolean nextKeyValue() throws java.io.IOException
nextKeyValue
in class RecordReader<K,V>
java.io.IOException
public K getCurrentKey() throws java.io.IOException
getCurrentKey
in class RecordReader<K,V>
java.io.IOException
public V getCurrentValue()
getCurrentValue
in class RecordReader<K,V>
public float getProgress()
getProgress
in interface RecordReader<K,V>
getProgress
in class RecordReader<K,V>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface RecordReader<K,V>
close
in class RecordReader<K,V>
java.io.IOException
public boolean next(K key, V value) throws java.io.IOException
next
in interface RecordReader<K,V>
java.io.IOException
public abstract K createKey()
createKey
in interface RecordReader<K,V>
public abstract V createValue()
createValue
in interface RecordReader<K,V>
protected abstract K setCurrentKey(K hadoopKey, java.lang.Object object)
hadoopKey
- hadoop keyobject
- the actual value to readprotected abstract V setCurrentValue(V hadoopValue, java.lang.Object object)
hadoopValue
- hadoop valueobject
- the actual value to readpublic long getPos()
getPos
in interface RecordReader<K,V>