public class BucketizedHiveInputFormat<K extends WritableComparable,V extends Writable> extends HiveInputFormat<K,V>
HiveInputFormat.HiveInputSplit
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
inputFormats, pathToPartitionInfo
Constructor and Description |
---|
BucketizedHiveInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
InputSplit[] |
getSplits(JobConf job,
int numSplits) |
protected FileStatus[] |
listStatus(JobConf job,
Path path) |
configure, getInputFormatFromCache, getPartitionDescFromPath, init, pushFilters, pushProjectionsAndFilters, pushProjectionsAndFilters, validateInput
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
protected FileStatus[] listStatus(JobConf job, Path path) throws java.io.IOException
java.io.IOException
public InputSplit[] getSplits(JobConf job, int numSplits) throws java.io.IOException
getSplits
in class HiveInputFormat<K extends WritableComparable,V extends Writable>
java.io.IOException
Copyright © 2012 The Apache Software Foundation