protected static class EsInputFormat.WritableShardRecordReader extends EsInputFormat.ShardRecordReader<org.apache.hadoop.io.Text,java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>>
| Constructor and Description |
|---|
EsInputFormat.WritableShardRecordReader() |
EsInputFormat.WritableShardRecordReader(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 |
createKey() |
java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> |
createValue() |
protected org.apache.hadoop.io.Text |
setCurrentKey(org.apache.hadoop.io.Text oldApiKey,
org.apache.hadoop.io.Text newApiKey,
java.lang.Object object) |
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> oldApiValue,
java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> newApiKey,
java.lang.Object object) |
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValuepublic EsInputFormat.WritableShardRecordReader()
public EsInputFormat.WritableShardRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.Reporter reporter)
public org.apache.hadoop.io.Text createKey()
createKey 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>>createKey in class EsInputFormat.ShardRecordReader<org.apache.hadoop.io.Text,java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>>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.ShardRecordReader<org.apache.hadoop.io.Text,java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>>protected org.apache.hadoop.io.Text setCurrentKey(org.apache.hadoop.io.Text oldApiKey,
org.apache.hadoop.io.Text newApiKey,
java.lang.Object object)
setCurrentKey in class EsInputFormat.ShardRecordReader<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> oldApiValue,
java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> newApiKey,
java.lang.Object object)
setCurrentValue in class EsInputFormat.ShardRecordReader<org.apache.hadoop.io.Text,java.util.Map<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>>