protected abstract static class EsPigInputFormat.AbstractPigEsInputRecordReader<V> extends EsInputFormat.EsInputRecordReader<java.lang.String,V>
| Constructor and Description |
|---|
AbstractPigEsInputRecordReader() |
AbstractPigEsInputRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.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, setCurrentValuepublic AbstractPigEsInputRecordReader()
public AbstractPigEsInputRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.Reporter reporter)
public java.lang.String createKey()
createKey in interface org.apache.hadoop.mapred.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.EsInputRecordReadersetCurrentKey in class EsInputFormat.EsInputRecordReader<java.lang.String,V>hadoopKey - hadoop keyobject - the actual value to read