Examples of ClusterConfiguration

configuration.ClusterConfiguration
edu.brown.catalog.ClusterConfiguration
This is a more useful extension of VoltDB's ClusterConfig @author pavlo
net.spy.memcached.config.ClusterConfiguration
A type to capture the configuration version number and the server list contained the response for getConfig API for "cluster" configuration type.
org.apache.helix.model.ClusterConfiguration
Persisted configuration properties for a cluster
org.mule.config.ClusterConfiguration
Provides the cluster configuration attributes
tomekkup.helenos.ClusterConfiguration
nu.org/licences/gpl.html @author Tomek Kuprowski (tomekkuprowski at gmail dot com)*

Examples of configuration.ClusterConfiguration

                new DefaultMutableTreeNode("Nodes group ");




        root.add(nodesGroupRoot);


        ClusterConfiguration clusterConfig = c.getClusterConfiguration();


        int i = 1;
        for (NodeGroupConfiguration ngc :
                clusterConfig.getNodeGroupsConfigurations()) {


            DefaultMutableTreeNode currentNodeGroupConfig =
                    new DefaultMutableTreeNode("Nodes group " + i);


            for (NodeConfiguration nodec : ngc.getNodesConfigurations()) {

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

        
        // (1) Load catalog from Jar
        Catalog tmpCatalog = CatalogUtil.loadCatalogFromJar(m_jarFileName);
        
        // (2) Update catalog to include target cluster configuration
        ClusterConfiguration cc = new ClusterConfiguration();
        // Update cc with a bunch of hosts/sites/partitions
        for (int site = 0, currentPartition = 0; site < m_siteCount; ++site) {
            for (int partition = 0; partition < m_partitionPerSite; ++partition, ++currentPartition) {
                cc.addPartition("localhost", site, currentPartition);
            }
        }
        tmpCatalog = FixCatalog.cloneCatalog(tmpCatalog, cc);
        
        // (3) Write updated catalog back out to jar file

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

        // ArgumentsParser.PARAM_DESIGNER_HINTS
        );
        assert (args.workload.getTransactionCount() > 0) : "No transactions were loaded from " + args.workload;


        if (args.hasParam(ArgumentsParser.PARAM_CATALOG_HOSTS)) {
            ClusterConfiguration cc = new ClusterConfiguration(args.getParam(ArgumentsParser.PARAM_CATALOG_HOSTS));
            args.updateCatalog(FixCatalog.cloneCatalog(args.catalog, cc), null);
        }


        // If given a PartitionPlan, then update the catalog
        File pplan_path = new File(args.getParam(ArgumentsParser.PARAM_PARTITION_PLAN));

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

            this.catalog_type = type;
        }


        // Update Cluster Configuration
        if (this.params.containsKey(ArgumentsParser.PARAM_CATALOG_HOSTS) && DISABLE_UPDATE_CATALOG == false) {
            ClusterConfiguration cc = new ClusterConfiguration(this.getParam(ArgumentsParser.PARAM_CATALOG_HOSTS));
            this.updateCatalog(FixCatalog.cloneCatalog(this.catalog, cc), null);
        }


        // Check the requirements after loading the catalog, because some of the
        // above parameters will set the catalog one

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

        );
        HStoreConf.initArgumentsParser(args);
        System.err.println("TEMP DIR: " + HStoreConf.singleton().global.temp_dir);


        if (args.hasParam(ArgumentsParser.PARAM_CATALOG_HOSTS)) {
            ClusterConfiguration cc = new ClusterConfiguration(args.getParam(ArgumentsParser.PARAM_CATALOG_HOSTS));
            args.updateCatalog(FixCatalog.cloneCatalog(args.catalog, cc), null);
        }


        // Create the container object that will hold all the information that
        // the designer will need to use

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

        ArgumentsParser args = ArgumentsParser.load(vargs);
        args.require(ArgumentsParser.PARAM_CATALOG, ArgumentsParser.PARAM_WORKLOAD, ArgumentsParser.PARAM_PARTITION_PLAN);
        assert (args.workload.getTransactionCount() > 0) : "No transactions were loaded from " + args.workload_path;


        if (args.hasParam(ArgumentsParser.PARAM_CATALOG_HOSTS)) {
            ClusterConfiguration cc = new ClusterConfiguration(args.getParam(ArgumentsParser.PARAM_CATALOG_HOSTS));
            args.updateCatalog(FixCatalog.cloneCatalog(args.catalog, cc), null);
        }


        // Enable compact output
        final boolean table_output = (args.getOptParams().contains("table"));

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration

     */
    protected final void addPartitions(int num_partitions) throws Exception {
        // HACK! If we already have this many partitions in the catalog, then we won't recreate it
        // This fixes problems where we need to reference the same catalog objects in multiple test cases
        if (catalogContext.numberOfPartitions != num_partitions) {
            ClusterConfiguration cc = new ClusterConfiguration();
            for (Integer i = 0; i < num_partitions; i++) {
                cc.addPartition("localhost", 0, i);
                // System.err.println("[" + i + "] " + Arrays.toString(triplets.lastElement()));
            } // FOR
            Catalog c = FixCatalog.cloneCatalog(catalog, cc);
            this.init(this.last_type, new CatalogContext(c, catalogContext.jarPath));

View Full Code Here

Examples of net.spy.memcached.config.ClusterConfiguration

        isConfigurationProtocolSupported = false;
      }
      
      if(configResult != null && ! configResult.trim().isEmpty()){
        //Parse configuration to get the list of cache servers.
        ClusterConfiguration clusterConfiguration = AddrUtil.parseClusterTypeConfiguration(configResult);
        
        //Initialize client with the actual set of endpoints.
        mconn.notifyUpdate(clusterConfiguration);
        isConfigurationInitialized = true;
      }

View Full Code Here

Examples of net.spy.memcached.config.ClusterConfiguration

      NodeEndPoint endPoint = new NodeEndPoint(hostName, ipAddress, port);
      endPoints.add(endPoint);
    }
    assert !endPoints.isEmpty() : "No endpoints found";
    
    ClusterConfiguration config = new ClusterConfiguration(versionNumber, endPoints);
    
    return config;
  }

View Full Code Here

Examples of net.spy.memcached.config.ClusterConfiguration

  public ConfigurationPoller(final MemcachedClient client, long pollingInterval){
    this.client = client;
    
    //The explicit typed emptyList assignment avoids type warning.
    List<NodeEndPoint> emptyList = Collections.emptyList();
    this.currentClusterConfiguration = new ClusterConfiguration(-1, emptyList);
    
    //Keep the initial delay to few seconds to begin polling quickly. This is useful if the config API call timed out in Client constructor 
    //and did not initialize the set of nodes in the cluster. The poller takes over the responsibility of configuring the client with the 
    //nodes in the cluster.  
    scheduledExecutor.scheduleAtFixedRate(this, INITIAL_DELAY, pollingInterval, TimeUnit.MILLISECONDS);

View Full Code Here

0 1 2

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.