Examples of MiniHS2

Examples of org.apache.hive.jdbc.miniHS2.MiniHS2

70
71
72
73
74
75
76
77
78
  @BeforeClass
  public static void preTests() throws Exception {
    HiveConf hiveConf = new HiveConf();
    // Set to non-zk lock manager to prevent HS2 from trying to connect
    hiveConf.setVar(HiveConf.ConfVars.HIVE_LOCK_MANAGER, "org.apache.hadoop.hive.ql.lockmgr.EmbeddedLockManager");
    miniHS2 = new MiniHS2(hiveConf);
    miniHS2.start(new HashMap<String,  String>());
    createTable();
  }
View Full Code Here

Examples of org.apache.hive.jdbc.miniHS2.MiniHS2

50
51
52
53
54
55
56
57
    conf.setVar(ConfVars.HIVE_AUTHENTICATOR_MANAGER, SessionStateUserAuthenticator.class.getName());
    conf.setBoolVar(ConfVars.HIVE_AUTHORIZATION_ENABLED, true);
    conf.setBoolVar(ConfVars.HIVE_SUPPORT_CONCURRENCY, false);
    conf.setBoolVar(ConfVars.HIVE_SERVER2_ENABLE_DOAS, false);

    miniHS2 = new MiniHS2(conf);
    miniHS2.start(new HashMap<String, String>());
  }
View Full Code Here

Examples of org.apache.hive.jdbc.miniHS2.MiniHS2

65
66
67
68
69
70
71
72
    conf.setVar(ConfVars.HIVE_AUTHENTICATOR_MANAGER, SessionStateUserAuthenticator.class.getName());
    conf.setBoolVar(ConfVars.HIVE_AUTHORIZATION_ENABLED, true);
    conf.setBoolVar(ConfVars.HIVE_SUPPORT_CONCURRENCY, false);
    conf.setBoolVar(ConfVars.HIVE_SERVER2_ENABLE_DOAS, false);

    miniHS2 = new MiniHS2(conf);
    miniHS2.start(new HashMap<String, String>());
  }
View Full Code Here

Examples of org.apache.hive.jdbc.miniHS2.MiniHS2

77
78
79
80
81
82
83
84
    conf.setVar(ConfVars.HIVE_AUTHENTICATOR_MANAGER, SessionStateUserAuthenticator.class.getName());
    conf.setBoolVar(ConfVars.HIVE_AUTHORIZATION_ENABLED, true);
    conf.setBoolVar(ConfVars.HIVE_SUPPORT_CONCURRENCY, false);
    conf.setBoolVar(ConfVars.HIVE_SERVER2_ENABLE_DOAS, false);

    miniHS2 = new MiniHS2(conf);
    miniHS2.start(new HashMap<String, String>());
  }
View Full Code Here

Examples of org.apache.hive.jdbc.miniHS2.MiniHS2

74
75
76
77
78
79
80
81
82
83
84
  }

  @Before
  public void setUp() throws Exception {
    DriverManager.setLoginTimeout(0);
    miniHS2 = new MiniHS2(conf, true);
    miniHS2.setConfProperty(HiveConf.ConfVars.HIVE_SERVER2_ENABLE_DOAS.varname, "false");
    miniHS2.setConfProperty(HiveConf.ConfVars.HIVE_SERVER2_MAP_FAIR_SCHEDULER_QUEUE.varname,
        "true");
    miniHS2.setConfProperty(YarnConfiguration.RM_SCHEDULER,
        "org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler");
View Full Code Here

Examples of org.apache.oozie.test.hive.MiniHS2

1005
1006
1007
1008
1009
1010
1011
1012
1013
            HiveConf hconf = new HiveConf();
            Configuration jobConf = createJobConf();
            for (Map.Entry<String, String> pair: jobConf) {
                hconf.set(pair.getKey(), pair.getValue());
            }
            hiveserver2 = new MiniHS2(hconf, dfsCluster.getFileSystem());
            hiveserver2.start(new HashMap<String, String>());
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.