org.apache.hcatalog.mapreduce

Class HCatOutputFormat

java.lang.Object

<any>

org.apache.hcatalog.mapreduce.HCatBaseOutputFormat

org.apache.hcatalog.mapreduce.HCatOutputFormat

Deprecated.

Use/modify HCatOutputFormat instead

public class HCatOutputFormat
extends HCatBaseOutputFormat

The OutputFormat to use to write data to HCatalog. The key value is ignored and should be given as null. The value is the HCatRecord to write.

Constructor Summary

Constructors

Constructor and Description
HCatOutputFormat() Deprecated.

Method Summary

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.

Methods inherited from class org.apache.hcatalog.mapreduce.HCatBaseOutputFormat

checkOutputSpecs, configureOutputStorageHandler, getJobInfo, getJobInfo, getOutputFormat, getTableSchema, getTableSchema, setPartDetails

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatOutputFormat

public HCatOutputFormat()

Deprecated.

Method Detail

setOutput

public static void setOutput(Job job,
                             OutputJobInfo outputJobInfo)
                      throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

See Also:

org.apache.hcatalog.mapreduce.HCatOutputFormat#setOutput(org.apache.hadoop.conf.Configuration, Credentials, OutputJobInfo)

setOutput

public static void setOutput(Configuration conf,
                             Credentials credentials,
                             OutputJobInfo outputJobInfo)
                      throws java.io.IOException

Deprecated.

Set the information about the output to write for the job. This queries the metadata server to find the StorageHandler to use for the table. It throws an error if the partition is already published.

Parameters:

conf - the Configuration object

credentials - the Credentials object

outputJobInfo - the table output information for the job

Throws:

java.io.IOException - the exception in communicating with the metadata server

setSchema

public static void setSchema(Job job,
                             HCatSchema schema)
                      throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

See Also:

org.apache.hcatalog.mapreduce.HCatOutputFormat#setSchema(org.apache.hadoop.conf.Configuration, org.apache.hcatalog.data.schema.HCatSchema)

setSchema

public static void setSchema(Configuration conf,
                             HCatSchema schema)
                      throws java.io.IOException

Deprecated.

Set the schema for the data being written out to the partition. The table schema is used by default for the partition if this is not called.

Parameters:

conf - the job Configuration object

schema - the schema for the data

Throws:

java.io.IOException

getRecordWriter

public <any> getRecordWriter(TaskAttemptContext context)
                      throws java.io.IOException,
                             java.lang.InterruptedException

Deprecated.

Get the record writer for the job. This uses the StorageHandler's default OutputFormat to get the record writer.

Parameters:

context - the information about the current task

Returns:

a RecordWriter to write the output for the job

Throws:

java.io.IOException

java.lang.InterruptedException

getOutputCommitter

public OutputCommitter getOutputCommitter(TaskAttemptContext context)
                                   throws java.io.IOException,
                                          java.lang.InterruptedException

Deprecated.

Get the output committer for this output format. This is responsible for ensuring the output is committed correctly.

Parameters:

context - the task context

Returns:

an output committer

Throws:

java.io.IOException

java.lang.InterruptedException