public class CombineHiveInputFormat<K extends WritableComparable,V extends Writable> extends HiveInputFormat<K,V>
Modifier and Type | Class and Description |
---|---|
static class |
CombineHiveInputFormat.CombineHiveInputSplit
CombineHiveInputSplit encapsulates an InputSplit with its corresponding
inputFormatClassName.
|
HiveInputFormat.HiveInputSplit
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
inputFormats, pathToPartitionInfo
Constructor and Description |
---|
CombineHiveInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter)
Create a generic Hive RecordReader than can iterate over all chunks in a
CombinedFileSplit.
|
InputSplit[] |
getSplits(JobConf job,
int numSplits)
Create Hive splits based on CombineFileSplit.
|
configure, getInputFormatFromCache, getPartitionDescFromPath, init, pushFilters, pushProjectionsAndFilters, pushProjectionsAndFilters, validateInput
public InputSplit[] getSplits(JobConf job, int numSplits) throws java.io.IOException
getSplits
in class HiveInputFormat<K extends WritableComparable,V extends Writable>
java.io.IOException
public RecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws java.io.IOException
getRecordReader
in class HiveInputFormat<K extends WritableComparable,V extends Writable>
java.io.IOException
Copyright © 2012 The Apache Software Foundation