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