public class EsPigInputFormat extends EsInputFormat<java.lang.String,java.util.Map>
| Modifier and Type | Class and Description |
|---|---|
protected static class |
EsPigInputFormat.PigShardRecordReader |
EsInputFormat.ShardInputSplit, EsInputFormat.ShardRecordReader<K,V>, EsInputFormat.WritableShardRecordReader| Constructor and Description |
|---|
EsPigInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
EsPigInputFormat.PigShardRecordReader |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
EsPigInputFormat.PigShardRecordReader |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
getSplits, getSplitspublic EsPigInputFormat.PigShardRecordReader createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
createRecordReader in class EsInputFormat<java.lang.String,java.util.Map>public EsPigInputFormat.PigShardRecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
getRecordReader in interface org.apache.hadoop.mapred.InputFormat<java.lang.String,java.util.Map>getRecordReader in class EsInputFormat<java.lang.String,java.util.Map>