|
elasticsearch-hadoop-pig | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.apache.hadoop.mapreduce.InputFormat<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat<String,Map>
org.elasticsearch.hadoop.pig.EsPigInputFormat
public class EsPigInputFormat
| Nested Class Summary | |
|---|---|
protected static class |
EsPigInputFormat.PigShardRecordReader
|
| Nested classes/interfaces inherited from class org.elasticsearch.hadoop.mr.EsInputFormat |
|---|
EsInputFormat.ShardInputSplit, EsInputFormat.ShardRecordReader<K,V>, EsInputFormat.WritableShardRecordReader |
| Constructor Summary | |
|---|---|
EsPigInputFormat()
|
|
| Method Summary | |
|---|---|
EsPigInputFormat.PigShardRecordReader |
createRecordReader(InputSplit split,
TaskAttemptContext context)
|
EsPigInputFormat.PigShardRecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter)
|
| Methods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat |
|---|
getSplits, getSplits |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public EsPigInputFormat()
| Method Detail |
|---|
public EsPigInputFormat.PigShardRecordReader createRecordReader(InputSplit split,
TaskAttemptContext context)
createRecordReader in class EsInputFormat<String,Map>
public EsPigInputFormat.PigShardRecordReader getRecordReader(InputSplit split,
JobConf job,
Reporter reporter)
getRecordReader in interface InputFormat<String,Map>getRecordReader in class EsInputFormat<String,Map>
|
elasticsearch-hadoop-pig | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||