org.apache.hcatalog.mapreduce

Class HCatBaseOutputFormat

java.lang.Object

<any>

org.apache.hcatalog.mapreduce.HCatBaseOutputFormat

Direct Known Subclasses:

HCatOutputFormat

Deprecated.

Use/modify HCatBaseOutputFormat instead

public abstract class HCatBaseOutputFormat
extends <any>

Constructor Summary

Constructors

Constructor and Description
HCatBaseOutputFormat() Deprecated.

Method Summary

Modifier and Type	Method and Description
void	checkOutputSpecs(JobContext context) Deprecated. Check for validity of the output-specification for the job.
protected static void	configureOutputStorageHandler(JobContext context, OutputJobInfo jobInfo, java.util.Map<java.lang.String,java.lang.String> fullPartSpec) Deprecated. Configure the output storage handler, with allowing specification of partvals from which it picks the dynamic partvals
static OutputJobInfo	getJobInfo(Configuration conf) Deprecated. Gets the HCatOuputJobInfo object by reading the Configuration and deserializing the string.
static OutputJobInfo	getJobInfo(JobContext jobContext) Deprecated. use #getJobInfo(org.apache.hadoop.conf.Configuration)
protected <any>	getOutputFormat(JobContext context) Deprecated. Gets the output format instance.
static HCatSchema	getTableSchema(Configuration conf) Deprecated. Gets the table schema for the table specified in the HCatOutputFormat.setOutput call on the specified job context.
static HCatSchema	getTableSchema(JobContext context) Deprecated. Use #getTableSchema(org.apache.hadoop.conf.Configuration)
protected static void	setPartDetails(OutputJobInfo jobInfo, HCatSchema schema, java.util.Map<java.lang.String,java.lang.String> partMap) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatBaseOutputFormat

public HCatBaseOutputFormat()

Deprecated.

Method Detail

getTableSchema

public static HCatSchema getTableSchema(JobContext context)
                                 throws java.io.IOException

Deprecated. Use #getTableSchema(org.apache.hadoop.conf.Configuration)

Throws:

java.io.IOException

See Also:

org.apache.hcatalog.mapreduce.HCatBaseOutputFormat#getTableSchema(org.apache.hadoop.conf.Configuration)

getTableSchema

public static HCatSchema getTableSchema(Configuration conf)
                                 throws java.io.IOException

Deprecated.

Gets the table schema for the table specified in the HCatOutputFormat.setOutput call on the specified job context.

Parameters:

conf - the Configuration object

Returns:

the table schema

Throws:

java.io.IOException - if HCatOutputFormat.setOutput has not been called for the passed context

checkOutputSpecs

public void checkOutputSpecs(JobContext context)
                      throws java.io.IOException,
                             java.lang.InterruptedException

Deprecated.

Check for validity of the output-specification for the job.

Parameters:

context - information about the job

Throws:

java.io.IOException - when output should not be attempted

java.lang.InterruptedException

getOutputFormat

protected <any> getOutputFormat(JobContext context)
                         throws java.io.IOException

Deprecated.

Gets the output format instance.

Parameters:

context - the job context

Returns:

the output format instance

Throws:

java.io.IOException

getJobInfo

public static OutputJobInfo getJobInfo(JobContext jobContext)
                                throws java.io.IOException

Deprecated. use #getJobInfo(org.apache.hadoop.conf.Configuration)

Throws:

java.io.IOException

See Also:

org.apache.hcatalog.mapreduce.HCatBaseOutputFormat#getJobInfo(org.apache.hadoop.conf.Configuration)

getJobInfo

public static OutputJobInfo getJobInfo(Configuration conf)
                                throws java.io.IOException

Deprecated.

Gets the HCatOuputJobInfo object by reading the Configuration and deserializing the string. If InputJobInfo is not present in the configuration, throws an exception since that means HCatOutputFormat.setOutput has not been called.

Parameters:

conf - the job Configuration object

Returns:

the OutputJobInfo object

Throws:

java.io.IOException - the IO exception

configureOutputStorageHandler

protected static void configureOutputStorageHandler(JobContext context,
                                                    OutputJobInfo jobInfo,
                                                    java.util.Map<java.lang.String,java.lang.String> fullPartSpec)
                                             throws java.io.IOException

Deprecated.

Configure the output storage handler, with allowing specification of partvals from which it picks the dynamic partvals

Parameters:

context - the job context

jobInfo - the output job info

fullPartSpec -

Throws:

java.io.IOException

setPartDetails

protected static void setPartDetails(OutputJobInfo jobInfo,
                                     HCatSchema schema,
                                     java.util.Map<java.lang.String,java.lang.String> partMap)
                              throws HCatException,
                                     java.io.IOException

Deprecated.

Throws:

HCatException

java.io.IOException