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