@InterfaceAudience.Public @InterfaceStability.Evolving public class HCatInputFormat extends HCatBaseInputFormat
Constructor and Description |
---|
HCatInputFormat() |
Modifier and Type | Method and Description |
---|---|
static HCatSchema |
getDataColumns(org.apache.hadoop.conf.Configuration conf)
Return data columns for this input, can only be called after setInput is called.
|
static HCatSchema |
getPartitionColumns(org.apache.hadoop.conf.Configuration conf)
Return partitioning columns for this input, can only be called after setInput is called.
|
HCatInputFormat |
setFilter(String filter)
Deprecated.
as of 0.13, slated for removal with 0.15
Use
setInput(org.apache.hadoop.conf.Configuration, String, String, String) instead,
to specify a partition filter to directly initialize the input with. |
static HCatInputFormat |
setInput(org.apache.hadoop.conf.Configuration conf,
String dbName,
String tableName)
Initializes the input with a null filter.
|
static HCatInputFormat |
setInput(org.apache.hadoop.conf.Configuration conf,
String dbName,
String tableName,
String filter)
Set inputs to use for the job.
|
static HCatInputFormat |
setInput(org.apache.hadoop.mapreduce.Job job,
String dbName,
String tableName)
Initializes the input with a null filter.
|
static HCatInputFormat |
setInput(org.apache.hadoop.mapreduce.Job job,
String dbName,
String tableName,
String filter)
Initializes the input with a provided filter.
|
HCatInputFormat |
setProperties(Properties properties)
Set properties for the input format.
|
createRecordReader, getMapRedInputFormat, getSplits, getTableSchema, setOutputSchema
public static HCatInputFormat setInput(org.apache.hadoop.mapreduce.Job job, String dbName, String tableName) throws IOException
setInput(org.apache.hadoop.conf.Configuration, String, String, String)
IOException
public static HCatInputFormat setInput(org.apache.hadoop.mapreduce.Job job, String dbName, String tableName, String filter) throws IOException
setInput(org.apache.hadoop.conf.Configuration, String, String, String)
IOException
public static HCatInputFormat setInput(org.apache.hadoop.conf.Configuration conf, String dbName, String tableName) throws IOException
setInput(org.apache.hadoop.conf.Configuration, String, String, String)
IOException
public static HCatInputFormat setInput(org.apache.hadoop.conf.Configuration conf, String dbName, String tableName, String filter) throws IOException
conf
- the job configurationdbName
- database name, which if null 'default' is usedtableName
- table namefilter
- the partition filter to use, can be null for no filterIOException
- on all errors@Deprecated public HCatInputFormat setFilter(String filter) throws IOException
setInput(org.apache.hadoop.conf.Configuration, String, String, String)
instead,
to specify a partition filter to directly initialize the input with.IOException
public HCatInputFormat setProperties(Properties properties) throws IOException
properties
- properties for the input specificationIOException
- on all errorspublic static HCatSchema getPartitionColumns(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public static HCatSchema getDataColumns(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.