Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class HiveConf extends Configuration {
- /* */ private void initialize(Class<?> cls) {
- /* 617 */ this.hiveJar = new JobConf(cls).getJar();
- /* */
- /* 620 */ this.origProp = getUnderlyingProps();
- /* */
- /* 623 */ URL hconfurl = getClassLoader().getResource("hive-default.xml");
- /* 624 */ if (hconfurl == null)
- /* 625 */ l4j.debug("hive-default.xml not found.");
- /* */ else {
- /* 627 */ addResource(hconfurl);
- /* */ }
- /* 629 */ URL hsiteurl = getClassLoader().getResource("hive-site.xml");
- /* 630 */ if (hsiteurl == null)
- /* 631 */ l4j.debug("hive-site.xml not found.");
- /* */ else {
- /* 633 */ addResource(hsiteurl);
- /* */ }
- /* */
- /* 638 */ URL hadoopconfurl = getClassLoader().getResource("hadoop-default.xml");
- /* 639 */ if (hadoopconfurl == null) {
- /* 640 */ hadoopconfurl = getClassLoader().getResource("hadoop-site.xml");
- /* */ }
- /* 642 */ if (hadoopconfurl != null) {
- /* 643 */ String conffile = hadoopconfurl.getPath();
- /* 644 */ setVar(ConfVars.HADOOPCONF, conffile.substring(0, conffile.lastIndexOf(47)));
- /* */ }
- /* */
- /* 647 */ applySystemProperties();
- /* */
- /* 651 */ if (this.hiveJar == null) {
- /* 652 */ this.hiveJar = get(ConfVars.HIVEJAR.varname);
- /* */ }
- /* */
- /* 655 */ if (this.auxJars == null)
- /* 656 */ this.auxJars = get(ConfVars.HIVEAUXJARS.varname);
- /* */ }
Add Comment
Please, Sign In to add comment