public abstract class HCatBaseInputFormat
extends <any>
Constructor and Description |
---|
HCatBaseInputFormat() |
Modifier and Type | Method and Description |
---|---|
<any> |
createRecordReader(InputSplit split,
TaskAttemptContext taskContext)
Create the RecordReader for the given InputSplit.
|
protected static <any> |
getMapRedInputFormat(JobConf job,
java.lang.Class inputFormatClass) |
java.util.List<InputSplit> |
getSplits(JobContext jobContext)
Logically split the set of input files for the job.
|
static HCatSchema |
getTableSchema(Configuration conf)
Gets the HCatTable schema for the table specified in the HCatInputFormat.setInput call
on the specified job context.
|
static HCatSchema |
getTableSchema(JobContext context)
Deprecated.
Use
#getTableSchema(org.apache.hadoop.conf.Configuration) |
static void |
setOutputSchema(Job job,
HCatSchema hcatSchema)
Set the schema for the HCatRecord data returned by HCatInputFormat.
|
public static void setOutputSchema(Job job, HCatSchema hcatSchema) throws java.io.IOException
job
- the job objecthcatSchema
- the schema to use as the consolidated schemajava.io.IOException
protected static <any> getMapRedInputFormat(JobConf job, java.lang.Class inputFormatClass) throws java.io.IOException
java.io.IOException
public java.util.List<InputSplit> getSplits(JobContext jobContext) throws java.io.IOException, java.lang.InterruptedException
jobContext
- the job context objectjava.io.IOException
- or InterruptedExceptionjava.lang.InterruptedException
public <any> createRecordReader(InputSplit split, TaskAttemptContext taskContext) throws java.io.IOException, java.lang.InterruptedException
split
- the splittaskContext
- the task attempt contextjava.io.IOException
- or InterruptedExceptionjava.lang.InterruptedException
public static HCatSchema getTableSchema(JobContext context) throws java.io.IOException
#getTableSchema(org.apache.hadoop.conf.Configuration)
java.io.IOException
org.apache.hive.hcatalog.mapreduce.HCatBaseInputFormat#getTableSchema(org.apache.hadoop.conf.Configuration)
public static HCatSchema getTableSchema(Configuration conf) throws java.io.IOException
conf
- the Configuration objectjava.io.IOException
- if HCatInputFormat.setInput has not been called
for the current contextCopyright © 2012 The Apache Software Foundation