public class OutputJobInfo
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Method and Description |
---|---|
static OutputJobInfo |
create(java.lang.String databaseName,
java.lang.String tableName,
java.util.Map<java.lang.String,java.lang.String> partitionValues)
Initializes a new OutputJobInfo instance
for writing data from a table.
|
java.lang.String |
getDatabaseName() |
java.util.List<java.lang.String> |
getDynamicPartitioningKeys() |
boolean |
getHarRequested()
Returns whether or not hadoop archiving has been requested for this job
|
java.lang.String |
getLocation() |
int |
getMaxDynamicPartitions()
Returns maximum number of allowable dynamic partitions
|
HCatSchema |
getOutputSchema() |
java.util.Map<java.lang.String,java.lang.String> |
getPartitionValues()
Gets the value of partitionValues
|
protected java.util.List<java.lang.Integer> |
getPosOfDynPartCols() |
protected java.util.List<java.lang.Integer> |
getPosOfPartCols() |
java.util.Properties |
getProperties()
Set/Get Property information to be passed down to *StorageHandler implementation
put implementation specific storage handler configurations here
|
HCatTableInfo |
getTableInfo() |
java.lang.String |
getTableName() |
boolean |
isDynamicPartitioningUsed()
Returns whether or not Dynamic Partitioning is used
|
void |
setDynamicPartitioningKeys(java.util.List<java.lang.String> dynamicPartitioningKeys)
Sets the list of dynamic partitioning keys used for outputting without specifying all the keys
|
void |
setHarRequested(boolean harRequested)
Sets whether or not hadoop archiving has been requested for this job
|
void |
setLocation(java.lang.String location) |
void |
setMaximumDynamicPartitions(int maxDynamicPartitions)
Set maximum number of allowable dynamic partitions
|
void |
setOutputSchema(HCatSchema schema) |
protected void |
setPosOfDynPartCols(java.util.List<java.lang.Integer> posOfDynPartCols) |
protected void |
setPosOfPartCols(java.util.List<java.lang.Integer> posOfPartCols) |
public static OutputJobInfo create(java.lang.String databaseName, java.lang.String tableName, java.util.Map<java.lang.String,java.lang.String> partitionValues)
databaseName
- the db nametableName
- the table namepartitionValues
- The partition values to publish to, can be null or empty Map to
work with hadoop security, the kerberos principal name of the server - else null
The principal name should be of the form:
protected java.util.List<java.lang.Integer> getPosOfPartCols()
protected java.util.List<java.lang.Integer> getPosOfDynPartCols()
protected void setPosOfPartCols(java.util.List<java.lang.Integer> posOfPartCols)
posOfPartCols
- the posOfPartCols to setprotected void setPosOfDynPartCols(java.util.List<java.lang.Integer> posOfDynPartCols)
posOfDynPartCols
- the posOfDynPartCols to setpublic HCatTableInfo getTableInfo()
public HCatSchema getOutputSchema()
public void setOutputSchema(HCatSchema schema)
schema
- the outputSchema to setpublic java.lang.String getLocation()
public void setLocation(java.lang.String location)
location
- location to write topublic java.util.Map<java.lang.String,java.lang.String> getPartitionValues()
public java.lang.String getDatabaseName()
public java.lang.String getTableName()
public java.util.Properties getProperties()
public void setMaximumDynamicPartitions(int maxDynamicPartitions)
maxDynamicPartitions
- public int getMaxDynamicPartitions()
public void setHarRequested(boolean harRequested)
harRequested
- public boolean getHarRequested()
public boolean isDynamicPartitioningUsed()
public void setDynamicPartitioningKeys(java.util.List<java.lang.String> dynamicPartitioningKeys)
dynamicPartitioningKeys
- public java.util.List<java.lang.String> getDynamicPartitioningKeys()
Copyright © 2012 The Apache Software Foundation