org.apache.hadoop.hive.llap.io.api.impl

Class LlapInputFormat

java.lang.Object

org.apache.hadoop.hive.llap.io.api.impl.LlapInputFormat

All Implemented Interfaces:

VectorizedInputFormatInterface, CombineHiveInputFormat.AvoidSplitCombination, SelfDescribingInputFormatInterface, org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>

public class LlapInputFormat
extends Object
implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>, VectorizedInputFormatInterface, SelfDescribingInputFormatInterface, CombineHiveInputFormat.AvoidSplitCombination

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>	checkLlapSplit(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)
VectorizedSupport.Support[]	getSupportedFeatures()
boolean	shouldSkipCombine(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                                                                                         org.apache.hadoop.mapred.JobConf job,
                                                                                                                                                         org.apache.hadoop.mapred.Reporter reporter)
                                                                                                                                                  throws IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>

Throws:

IOException

checkLlapSplit

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> checkLlapSplit(org.apache.hadoop.mapred.InputSplit split,
                                                                                                                                                        org.apache.hadoop.mapred.JobConf job,
                                                                                                                                                        org.apache.hadoop.mapred.Reporter reporter)
                                                                                                                                                 throws IOException

Throws:

IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job,
                                                       int numSplits)
                                                throws IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>

Throws:

IOException

shouldSkipCombine

public boolean shouldSkipCombine(org.apache.hadoop.fs.Path path,
                                 org.apache.hadoop.conf.Configuration conf)
                          throws IOException

Specified by:

shouldSkipCombine in interface CombineHiveInputFormat.AvoidSplitCombination

Throws:

IOException

getSupportedFeatures

public VectorizedSupport.Support[] getSupportedFeatures()

Specified by:

getSupportedFeatures in interface VectorizedInputFormatInterface