protected static class PigInputFormat.RecordReaderFactory extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.mapreduce.TaskAttemptContext |
context |
protected org.apache.hadoop.mapreduce.InputFormat |
inputFormat |
protected long |
limit |
protected LoadFunc |
loadFunc |
protected PigSplit |
pigSplit |
Constructor and Description |
---|
RecordReaderFactory(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple> |
createRecordReader() |
protected org.apache.hadoop.mapreduce.InputFormat inputFormat
protected PigSplit pigSplit
protected LoadFunc loadFunc
protected org.apache.hadoop.mapreduce.TaskAttemptContext context
protected long limit
public RecordReaderFactory(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
IOException
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple> createRecordReader() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2007-2017 The Apache Software Foundation