Package org.apache.iceberg.pig
Class IcebergPigInputFormat<T>
- java.lang.Object
-
- org.apache.hadoop.mapreduce.InputFormat<java.lang.Void,T>
-
- org.apache.iceberg.pig.IcebergPigInputFormat<T>
-
public class IcebergPigInputFormat<T> extends org.apache.hadoop.mapreduce.InputFormat<java.lang.Void,T>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
IcebergPigInputFormat.IcebergRecordReader<T>
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,T>
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
java.util.List<org.apache.hadoop.mapreduce.InputSplit>
getSplits(org.apache.hadoop.mapreduce.JobContext context)
-
-
-
Method Detail
-
getSplits
public java.util.List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws java.io.IOException
- Specified by:
getSplits
in classorg.apache.hadoop.mapreduce.InputFormat<java.lang.Void,T>
- Throws:
java.io.IOException
-
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,T> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
- Specified by:
createRecordReader
in classorg.apache.hadoop.mapreduce.InputFormat<java.lang.Void,T>
-
-