public class OutputJobInfo extends Object implements Serializable
Modifier and Type | Method and Description |
---|---|
static OutputJobInfo |
create(String databaseName,
String tableName,
Map<String,String> partitionValues)
Initializes a new OutputJobInfo instance
for writing data from a table.
|
String |
getDatabaseName() |
List<String> |
getDynamicPartitioningKeys() |
boolean |
getHarRequested()
Returns whether or not hadoop archiving has been requested for this job
|
String |
getLocation() |
int |
getMaxDynamicPartitions()
Returns maximum number of allowable dynamic partitions
|
HCatSchema |
getOutputSchema() |
Map<String,String> |
getPartitionValues()
Gets the value of partitionValues
|
protected List<Integer> |
getPosOfDynPartCols() |
protected List<Integer> |
getPosOfPartCols() |
Properties |
getProperties()
Set/Get Property information to be passed down to *StorageHandler implementation
put implementation specific storage handler configurations here
|
HCatTableInfo |
getTableInfo() |
String |
getTableName() |
boolean |
isDynamicPartitioningUsed()
Returns whether or not Dynamic Partitioning is used
|
void |
setDynamicPartitioningKeys(List<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(String location) |
void |
setMaximumDynamicPartitions(int maxDynamicPartitions)
Set maximum number of allowable dynamic partitions
|
void |
setOutputSchema(HCatSchema schema) |
protected void |
setPosOfDynPartCols(List<Integer> posOfDynPartCols) |
protected void |
setPosOfPartCols(List<Integer> posOfPartCols) |
public static OutputJobInfo create(String databaseName, String tableName, Map<String,String> partitionValues)
databaseName
- the db nametableName
- the table namepartitionValues
- The partition values to publish to, can be null or empty Map to
indicate write to a unpartitioned table. For partitioned tables, this map should
contain keys for all partition columns with corresponding values.protected void setPosOfPartCols(List<Integer> posOfPartCols)
posOfPartCols
- the posOfPartCols to setprotected void setPosOfDynPartCols(List<Integer> posOfDynPartCols)
posOfDynPartCols
- the posOfDynPartCols to setpublic HCatTableInfo getTableInfo()
public HCatSchema getOutputSchema()
public void setOutputSchema(HCatSchema schema)
schema
- the outputSchema to setpublic String getLocation()
public void setLocation(String location)
location
- location to write topublic Map<String,String> getPartitionValues()
public String getDatabaseName()
public String getTableName()
public 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(List<String> dynamicPartitioningKeys)
dynamicPartitioningKeys
- Copyright © 2021 The Apache Software Foundation. All rights reserved.