HCatOutputFormat
insteadpublic class HCatOutputFormat extends HCatBaseOutputFormat
Constructor and Description |
---|
HCatOutputFormat()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
OutputCommitter |
getOutputCommitter(TaskAttemptContext context)
Deprecated.
Get the output committer for this output format.
|
<any> |
getRecordWriter(TaskAttemptContext context)
Deprecated.
Get the record writer for the job.
|
static void |
setOutput(Configuration conf,
Credentials credentials,
OutputJobInfo outputJobInfo)
Deprecated.
Set the information about the output to write for the job.
|
static void |
setOutput(Job job,
OutputJobInfo outputJobInfo)
Deprecated.
|
static void |
setSchema(Configuration conf,
HCatSchema schema)
Deprecated.
Set the schema for the data being written out to the partition.
|
static void |
setSchema(Job job,
HCatSchema schema)
Deprecated.
|
checkOutputSpecs, configureOutputStorageHandler, getJobInfo, getJobInfo, getOutputFormat, getTableSchema, getTableSchema, setPartDetails
public static void setOutput(Job job, OutputJobInfo outputJobInfo) throws java.io.IOException
java.io.IOException
org.apache.hcatalog.mapreduce.HCatOutputFormat#setOutput(org.apache.hadoop.conf.Configuration, Credentials, OutputJobInfo)
public static void setOutput(Configuration conf, Credentials credentials, OutputJobInfo outputJobInfo) throws java.io.IOException
conf
- the Configuration objectcredentials
- the Credentials objectoutputJobInfo
- the table output information for the jobjava.io.IOException
- the exception in communicating with the metadata serverpublic static void setSchema(Job job, HCatSchema schema) throws java.io.IOException
java.io.IOException
org.apache.hcatalog.mapreduce.HCatOutputFormat#setSchema(org.apache.hadoop.conf.Configuration, org.apache.hcatalog.data.schema.HCatSchema)
public static void setSchema(Configuration conf, HCatSchema schema) throws java.io.IOException
conf
- the job Configuration objectschema
- the schema for the datajava.io.IOException
public <any> getRecordWriter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
context
- the information about the current taskjava.io.IOException
java.lang.InterruptedException
public OutputCommitter getOutputCommitter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
context
- the task contextjava.io.IOException
java.lang.InterruptedException
Copyright © 2012 The Apache Software Foundation