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