org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class PigInputFormat.RecordReaderFactory

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.RecordReaderFactory

Enclosing class:

PigInputFormat

protected static class PigInputFormat.RecordReaderFactory
extends java.lang.Object

Helper class to create record reader

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapreduce.TaskAttemptContext	context
protected LoadFuncDecorator	decorator
protected org.apache.hadoop.mapreduce.InputFormat	inputFormat
protected long	limit
protected PigSplit	pigSplit

Constructor Summary

Constructors

Constructor and Description
RecordReaderFactory(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple>	createRecordReader()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputFormat

protected org.apache.hadoop.mapreduce.InputFormat inputFormat

pigSplit

protected PigSplit pigSplit

decorator

protected LoadFuncDecorator decorator

context

protected org.apache.hadoop.mapreduce.TaskAttemptContext context

limit

protected long limit

Constructor Detail

RecordReaderFactory

public RecordReaderFactory(org.apache.hadoop.mapreduce.InputSplit split,
                           org.apache.hadoop.mapreduce.TaskAttemptContext context)
                    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple> createRecordReader()
                                                                                             throws java.io.IOException,
                                                                                                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException