@Test public void testHiveConf() { Properties properties = SourceConfigurationUtil.loadHiveJDBCProperties(); assertTrue(properties.containsKey("hiveconf:hive.auto.convert.join.noconditionaltask.size")); }
public static Properties loadHiveJDBCProperties() { Map<String, String> hiveConfiguration = loadHiveConfiguration(); Properties ret = new Properties(); for (Map.Entry<String, String> entry : hiveConfiguration.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } Map<String, String> overrideConf = KylinConfig.getInstanceFromEnv().getHiveConfigOverride(); for (Map.Entry<String, String> entry : overrideConf.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } return ret; }
SourceConfigurationUtil { public static Properties loadHiveJDBCProperties() { Map<String, String> hiveConfiguration = loadHiveConfiguration(); Properties ret = new Properties(); for (Map.Entry<String, String> entry : hiveConfiguration.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } Map<String, String> overrideConf = KylinConfig.getInstanceFromEnv().getHiveConfigOverride(); for (Map.Entry<String, String> entry : overrideConf.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } return ret; } }
SourceConfigurationUtil { public static Properties loadHiveJDBCProperties() { Map<String, String> hiveConfiguration = loadHiveConfiguration(); Properties ret = new Properties(); for (Map.Entry<String, String> entry : hiveConfiguration.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } Map<String, String> overrideConf = KylinConfig.getInstanceFromEnv().getHiveConfigOverride(); for (Map.Entry<String, String> entry : overrideConf.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } return ret; } private  SourceConfigurationUtil(); }
SourceConfigurationUtil { public static Properties loadHiveJDBCProperties() { Map<String, String> hiveConfiguration = loadHiveConfiguration(); Properties ret = new Properties(); for (Map.Entry<String, String> entry : hiveConfiguration.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } Map<String, String> overrideConf = KylinConfig.getInstanceFromEnv().getHiveConfigOverride(); for (Map.Entry<String, String> entry : overrideConf.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } return ret; } private  SourceConfigurationUtil(); static Properties loadHiveJDBCProperties(); static Map<String, String> loadHiveConfiguration(); static Map<String, String> loadSqoopConfiguration(); }
SourceConfigurationUtil { public static Properties loadHiveJDBCProperties() { Map<String, String> hiveConfiguration = loadHiveConfiguration(); Properties ret = new Properties(); for (Map.Entry<String, String> entry : hiveConfiguration.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } Map<String, String> overrideConf = KylinConfig.getInstanceFromEnv().getHiveConfigOverride(); for (Map.Entry<String, String> entry : overrideConf.entrySet()) { ret.put(HIVE_CONF_PREFIX + entry.getKey(), entry.getValue()); } return ret; } private  SourceConfigurationUtil(); static Properties loadHiveJDBCProperties(); static Map<String, String> loadHiveConfiguration(); static Map<String, String> loadSqoopConfiguration(); static final String HIVE_CONF_FILENAME; static final String SQOOP_CONF_FILENAME; }