protected abstract static class EsInputFormat.ShardRecordReader<K,V>
extends org.apache.hadoop.mapreduce.RecordReader<K,V>
implements org.apache.hadoop.mapred.RecordReader<K,V>
Constructor and Description |
---|
EsInputFormat.ShardRecordReader() |
EsInputFormat.ShardRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.conf.Configuration job,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
abstract K |
createKey() |
abstract V |
createValue() |
K |
getCurrentKey() |
V |
getCurrentValue() |
long |
getPos() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
next(K key,
V value) |
boolean |
nextKeyValue() |
protected abstract K |
setCurrentKey(K oldApiKey,
K newApiKey,
java.lang.Object object) |
protected abstract V |
setCurrentValue(V oldApiValue,
V newApiKey,
java.lang.Object object) |
public EsInputFormat.ShardRecordReader()
public EsInputFormat.ShardRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.conf.Configuration job, org.apache.hadoop.mapred.Reporter reporter)
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws java.io.IOException
public boolean nextKeyValue() throws java.io.IOException
public K getCurrentKey() throws java.io.IOException
public V getCurrentValue()
public float getProgress()
public void close() throws java.io.IOException
public abstract K createKey()
public abstract V createValue()
protected abstract V setCurrentValue(V oldApiValue, V newApiKey, java.lang.Object object)