Examples of com.alibaba.wasp.WaspTestingUtility.startMiniCluster()

Class com.alibaba.wasp.WaspTestingUtility

Examples of com.alibaba.wasp.WaspTestingUtility.startMiniCluster()

com.alibaba.wasp.WaspTestingUtility.startMiniCluster()
Start up a minicluster of wasp, optionally hbase, dfs, and zookeeper. Modifies Configuration. Homes the cluster data directory under a random subdirectory in a directory under System property test.build.data. Directory is cleaned up on exit. @param numSlaves Number of slaves to start up. We'll start this many fservers, datanodes and regionservers. If numSlaves is > 1, then make sure wasp.fserver.info.port is -1 (i.e. no ui per fserver) otherwise bind errors. @throws Exception @see {@link #shutdownMiniCluster()} @return Mini wasp cluster instance created.

    final int NUM_MASTERS = 3;
    final int NUM_RS = 3;


    // Start the cluster
    WaspTestingUtility TEST_UTIL = new WaspTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniWaspCluster cluster = TEST_UTIL.getWaspCluster();


    // get all the master threads
    List<MasterThread> masterThreads = cluster.getMasterThreads();

View Full Code Here

TOP

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.