protected static class EsInputFormat.WritableShardRecordReader extends EsInputFormat.ShardRecordReader<Text,java.util.Map<Writable,Writable>>
| Constructor and Description |
|---|
EsInputFormat.WritableShardRecordReader() |
EsInputFormat.WritableShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
Text |
createKey() |
java.util.Map<Writable,Writable> |
createValue() |
protected Text |
setCurrentKey(Text oldApiKey,
Text newApiKey,
java.lang.Object object) |
protected java.util.Map<Writable,Writable> |
setCurrentValue(java.util.Map<Writable,Writable> oldApiValue,
java.util.Map<Writable,Writable> newApiKey,
java.lang.Object object) |
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValuepublic EsInputFormat.WritableShardRecordReader()
public EsInputFormat.WritableShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
public Text createKey()
createKey in interface RecordReader<Text,java.util.Map<Writable,Writable>>createKey in class EsInputFormat.ShardRecordReader<Text,java.util.Map<Writable,Writable>>public java.util.Map<Writable,Writable> createValue()
createValue in interface RecordReader<Text,java.util.Map<Writable,Writable>>createValue in class EsInputFormat.ShardRecordReader<Text,java.util.Map<Writable,Writable>>protected Text setCurrentKey(Text oldApiKey, Text newApiKey, java.lang.Object object)
setCurrentKey in class EsInputFormat.ShardRecordReader<Text,java.util.Map<Writable,Writable>>