org.apache.hive.hcatalog.mapreduce

Class HCatInputFormat

java.lang.Object

<any>

org.apache.hive.hcatalog.mapreduce.HCatBaseInputFormat

org.apache.hive.hcatalog.mapreduce.HCatInputFormat

public class HCatInputFormat
extends HCatBaseInputFormat

The InputFormat to use to read data from HCatalog.

Constructor Summary

Constructors

Constructor and Description
HCatInputFormat()

Method Summary

Modifier and Type	Method and Description
HCatInputFormat	setFilter(java.lang.String filter) Set a filter on the input table.
static void	setInput(Configuration conf, InputJobInfo inputJobInfo) Deprecated. as of release 0.5, and will be removed in a future release
static HCatInputFormat	setInput(Configuration conf, java.lang.String dbName, java.lang.String tableName) Set inputs to use for the job.
static void	setInput(Job job, InputJobInfo inputJobInfo) Deprecated. as of release 0.5, and will be removed in a future release
static HCatInputFormat	setInput(Job job, java.lang.String dbName, java.lang.String tableName) See #setInput(org.apache.hadoop.conf.Configuration, String, String)
HCatInputFormat	setProperties(java.util.Properties properties) Set properties for the input format.

Methods inherited from class org.apache.hive.hcatalog.mapreduce.HCatBaseInputFormat

createRecordReader, getMapRedInputFormat, getSplits, getTableSchema, getTableSchema, setOutputSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatInputFormat

public HCatInputFormat()

Method Detail

setInput

@Deprecated
public static void setInput(Job job,
                                        InputJobInfo inputJobInfo)
                                 throws java.io.IOException

Deprecated. as of release 0.5, and will be removed in a future release

Throws:

java.io.IOException

setInput

@Deprecated
public static void setInput(Configuration conf,
                                        InputJobInfo inputJobInfo)
                                 throws java.io.IOException

Deprecated. as of release 0.5, and will be removed in a future release

Throws:

java.io.IOException

setInput

public static HCatInputFormat setInput(Job job,
                                       java.lang.String dbName,
                                       java.lang.String tableName)
                                throws java.io.IOException

See #setInput(org.apache.hadoop.conf.Configuration, String, String)

Throws:

java.io.IOException

setInput

public static HCatInputFormat setInput(Configuration conf,
                                       java.lang.String dbName,
                                       java.lang.String tableName)
                                throws java.io.IOException

Set inputs to use for the job. This queries the metastore with the given input specification and serializes matching partitions into the job conf for use by MR tasks.

Parameters:

conf - the job configuration

dbName - database name, which if null 'default' is used

tableName - table name

Throws:

java.io.IOException - on all errors

setFilter

public HCatInputFormat setFilter(java.lang.String filter)
                          throws java.io.IOException

Set a filter on the input table.

Parameters:

filter - the filter specification, which may be null

Returns:

this

Throws:

java.io.IOException - on all errors

setProperties

public HCatInputFormat setProperties(java.util.Properties properties)
                              throws java.io.IOException

Set properties for the input format.

Parameters:

properties - properties for the input specification

Returns:

this

Throws:

java.io.IOException - on all errors