org.apache.flink.connectors.hive.util

Class JobConfUtils

java.lang.Object

org.apache.flink.connectors.hive.util.JobConfUtils

public class JobConfUtils
extends Object

Utilities for JobConf.

Constructor Summary

Constructors

Constructor and Description
JobConfUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.mapred.JobConf	createJobConfWithCredentials(org.apache.hadoop.conf.Configuration configuration)
static String	getDefaultPartitionName(org.apache.hadoop.mapred.JobConf jobConf) Gets the HiveConf.ConfVars#DEFAULTPARTITIONNAME value from the JobConf.
static String	getDefaultPartitionName(JobConfWrapper confWrapper) Gets the HiveConf.ConfVars#DEFAULTPARTITIONNAME value from the JobConfWrapper.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobConfUtils

public JobConfUtils()

Method Detail

getDefaultPartitionName

public static String getDefaultPartitionName(JobConfWrapper confWrapper)

Gets the HiveConf.ConfVars#DEFAULTPARTITIONNAME value from the JobConfWrapper.

getDefaultPartitionName

public static String getDefaultPartitionName(org.apache.hadoop.mapred.JobConf jobConf)

Gets the HiveConf.ConfVars#DEFAULTPARTITIONNAME value from the JobConf.

createJobConfWithCredentials

public static org.apache.hadoop.mapred.JobConf createJobConfWithCredentials(org.apache.hadoop.conf.Configuration configuration)