Examples of LocalCluster

backtype.storm.LocalCluster
com.alibaba.jstorm.local.LocalCluster
org.voltdb.regressionsuites.LocalCluster
Implementation of a VoltServerConfig for a multi-process cluster. All cluster processes run locally (keep this in mind if building memory or load intensive tests.)

Examples of backtype.storm.LocalCluster

        if(args!=null && args.length > 0) {
            conf.setNumWorkers(3);
            StormSubmitter.submitTopology(args[0], conf, builder.createTopology());
        } else {        
            conf.setMaxTaskParallelism(3);
            LocalCluster cluster = new LocalCluster();
            cluster.submitTopology("Juggaloader-dummy", conf, builder.createTopology());
            Thread.sleep(10000);
            cluster.shutdown();
        }
    }

View Full Code Here

Examples of com.alibaba.jstorm.local.LocalCluster

  }


  public static void SetLocalTopology() throws Exception {
    TopologyBuilder builder = SetBuilder();


    LocalCluster cluster = new LocalCluster();
    cluster.submitTopology(topologyName, conf, builder.createTopology());


    Thread.sleep(600000);


    cluster.shutdown();
  }

View Full Code Here

Examples of org.voltdb.regressionsuites.LocalCluster

        config.compile(project);
        builder.addServerConfig(config);
 
        // CLUSTER CONFIG #2
        // Two sites, each with two partitions running in separate JVMs
        config = new LocalCluster(PREFIX + "-twoSiteTwoPart.jar", 2, 2, 1, BackendTarget.NATIVE_EE_JNI);
        config.compile(project);
        builder.addServerConfig(config);
 
        return builder;
    }

View Full Code Here

0 1 2 3 4 5

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.