Package org.apache.ambari.server.state

Examples of org.apache.ambari.server.state.Cluster.addConfig()

3508
3509
3510
3511
3512
3513
3514
3515
3516
3517
3518
    Config config2 = cf.createNew(cluster, "core-site",
        new HashMap<String, String>(){{ put("key1", "value1"); }});
    config2.setVersionTag("version1");
   
    cluster.addConfig(config1);
    cluster.addConfig(config2);
    cluster.addDesiredConfig("_test", config1);
    cluster.addDesiredConfig("_test", config2);
   
    Service hdfs = cluster.addService("HDFS");
    Service mapReduce = cluster.addService("MAPREDUCE");
View Full Code Here
1445
1446
1447
1448
1449
1450
1451
1452
1453
1454
1455
    c1.setVersionTag("v1");
    c2.setVersionTag("v1");
    c3.setVersionTag("v1");

    cluster.addConfig(c1);
    cluster.addConfig(c2);
    cluster.addConfig(c3);
    c1.persist();
    c2.persist();
    c3.persist();
View Full Code Here
1446
1447
1448
1449
1450
1451
1452
1453
1454
1455
1456
    c1.setVersionTag("v1");
    c2.setVersionTag("v1");
    c3.setVersionTag("v1");

    cluster.addConfig(c1);
    cluster.addConfig(c2);
    cluster.addConfig(c3);
    c1.persist();
    c2.persist();
    c3.persist();
View Full Code Here
1447
1448
1449
1450
1451
1452
1453
1454
1455
1456
1457
    c2.setVersionTag("v1");
    c3.setVersionTag("v1");

    cluster.addConfig(c1);
    cluster.addConfig(c2);
    cluster.addConfig(c3);
    c1.persist();
    c2.persist();
    c3.persist();

    configs.put(c1.getType(), c1);
View Full Code Here
899
900
901
902
903
904
905
906
907
908
909
        request.getProperties());
    config.setVersionTag(request.getVersionTag());

    config.persist();

    cluster.addConfig(config);
  }

  @Override
  public void createUsers(Set<UserRequest> requests) throws AmbariException {
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
    GLOBAL_CLUSTER.put(GLOBAL_NAME2, GLOBAL_CLUSTER_VAL2);
   
    //Cluster level global config
    Config globalConfig = configFactory.createNew(cluster1, GLOBAL_CONFIG, GLOBAL_CLUSTER);
    globalConfig.setVersionTag(CLUSTER_VERSION_TAG);
    cluster1.addConfig(globalConfig);

    //Cluster level service config
    Config serviceSiteConfigCluster = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_CLUSTER);
    serviceSiteConfigCluster.setVersionTag(CLUSTER_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigCluster);
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
    cluster1.addConfig(globalConfig);

    //Cluster level service config
    Config serviceSiteConfigCluster = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_CLUSTER);
    serviceSiteConfigCluster.setVersionTag(CLUSTER_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigCluster);
   
    //Service level service config
    Config serviceSiteConfigService = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_SERVICE);
    serviceSiteConfigService.setVersionTag(SERVICE_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigService);
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
    cluster1.addConfig(serviceSiteConfigCluster);
   
    //Service level service config
    Config serviceSiteConfigService = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_SERVICE);
    serviceSiteConfigService.setVersionTag(SERVICE_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigService);
   
    //Host level service config
    Config serviceSiteConfigHost = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_HOST);
    serviceSiteConfigHost.setVersionTag(HOST_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigHost);
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
    cluster1.addConfig(serviceSiteConfigService);
   
    //Host level service config
    Config serviceSiteConfigHost = configFactory.createNew(cluster1, SERVICE_SITE_CONFIG, SERVICE_SITE_HOST);
    serviceSiteConfigHost.setVersionTag(HOST_VERSION_TAG);
    cluster1.addConfig(serviceSiteConfigHost);
   
    ActionDBAccessor db = injector.getInstance(ActionDBAccessorImpl.class);
   
    createTask(db, 1, 1, HOST1, CLUSTER1);
   
View Full Code Here
3789
3790
3791
3792
3793
3794
3795
3796
3797
3798
3799
        new HashMap<String, String>() {{
          put("key1", "value1");
        }});
    config2.setVersionTag("version1");

    cluster.addConfig(config1);
    cluster.addConfig(config2);

    Service hdfs = cluster.addService("HDFS");
    hdfs.persist();
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.