org.apache.hadoop.hive.ql.io.orc
Class OrcNewInputFormat
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,OrcStruct>
org.apache.hadoop.hive.ql.io.orc.OrcNewInputFormat
public class OrcNewInputFormat
- extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,OrcStruct>
An InputFormat for ORC files. Keys are meaningless,
value is the OrcStruct object
Method Summary |
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,OrcStruct> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
|
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext jobContext)
|
OrcNewInputFormat
public OrcNewInputFormat()
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,OrcStruct> createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException,
InterruptedException
- Specified by:
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,OrcStruct>
- Throws:
IOException
InterruptedException
getSplits
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext jobContext)
throws IOException,
InterruptedException
- Specified by:
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,OrcStruct>
- Throws:
IOException
InterruptedException
Copyright © 2014 The Apache Software Foundation. All rights reserved.