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(InputSplit split,
TaskAttemptContext context) |
EsPigInputFormat.PigShardRecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
getSplits, getSplitspublic EsPigInputFormat.PigShardRecordReader createRecordReader(InputSplit split, TaskAttemptContext context)
createRecordReader in class EsInputFormat<java.lang.String,java.util.Map>public EsPigInputFormat.PigShardRecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter)
getRecordReader in interface InputFormat<java.lang.String,java.util.Map>getRecordReader in class EsInputFormat<java.lang.String,java.util.Map>