protected abstract static class EsInputFormat.AbstractWritableEsInputRecordReader<V> extends EsInputFormat.EsInputRecordReader<org.apache.hadoop.io.Text,V>
Constructor and Description |
---|
AbstractWritableEsInputRecordReader() |
AbstractWritableEsInputRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.Text |
createKey() |
protected org.apache.hadoop.io.Text |
setCurrentKey(org.apache.hadoop.io.Text hadoopKey,
java.lang.Object object)
Sets the current key.
|
close, createValue, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue, setCurrentValue
public AbstractWritableEsInputRecordReader()
public AbstractWritableEsInputRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.conf.Configuration job, org.apache.hadoop.mapred.Reporter reporter)
public org.apache.hadoop.io.Text createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,V>
createKey
in class EsInputFormat.EsInputRecordReader<org.apache.hadoop.io.Text,V>
protected org.apache.hadoop.io.Text setCurrentKey(org.apache.hadoop.io.Text hadoopKey, java.lang.Object object)
EsInputFormat.EsInputRecordReader
setCurrentKey
in class EsInputFormat.EsInputRecordReader<org.apache.hadoop.io.Text,V>
hadoopKey
- hadoop keyobject
- the actual value to read