protected static class EsPigInputFormat.PigJsonEsInputRecordReader extends EsPigInputFormat.AbstractPigEsInputRecordReader<java.lang.String>
| Constructor and Description |
|---|
PigJsonEsInputRecordReader() |
PigJsonEsInputRecordReader(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 |
createValue() |
protected java.lang.String |
setCurrentValue(java.lang.String hadoopValue,
java.lang.Object object)
Sets the current value.
|
createKey, setCurrentKeyclose, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValuepublic PigJsonEsInputRecordReader()
public PigJsonEsInputRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.Reporter reporter)
public java.lang.String createValue()
createValue in interface org.apache.hadoop.mapred.RecordReader<java.lang.String,java.lang.String>createValue in class EsInputFormat.EsInputRecordReader<java.lang.String,java.lang.String>protected java.lang.String setCurrentValue(java.lang.String hadoopValue,
java.lang.Object object)
EsInputFormat.EsInputRecordReadersetCurrentValue in class EsInputFormat.EsInputRecordReader<java.lang.String,java.lang.String>hadoopValue - hadoop valueobject - the actual value to read