public class TableStoreJobConf extends Object
JobConf
.Constructor and Description |
---|
TableStoreJobConf(org.apache.hadoop.mapred.JobConf jobConf) |
Modifier and Type | Method and Description |
---|---|
static void |
configureInputJobProperties(org.apache.hadoop.conf.Configuration configuration,
Properties properties,
Map<String,String> map) |
static org.apache.flink.configuration.Configuration |
extractCatalogConfig(org.apache.hadoop.conf.Configuration hiveConf)
Extract table store catalog conf from Hive conf.
|
org.apache.flink.configuration.Configuration |
getCatalogConfig() |
String |
getLocation() |
public TableStoreJobConf(org.apache.hadoop.mapred.JobConf jobConf)
public static void configureInputJobProperties(org.apache.hadoop.conf.Configuration configuration, Properties properties, Map<String,String> map)
public String getLocation()
public org.apache.flink.configuration.Configuration getCatalogConfig()
public static org.apache.flink.configuration.Configuration extractCatalogConfig(org.apache.hadoop.conf.Configuration hiveConf)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.