Examples of addServiceComponentHost()

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

2078
2079
2080
2081
2082
2083
2084
2085
2086
2087
2088
    sc1.addServiceComponentHost(sch1);
    sc1.addServiceComponentHost(sch2);
    sc1.addServiceComponentHost(sch3);
    sc2.addServiceComponentHost(sch4);
    sc2.addServiceComponentHost(sch5);
    sc3.addServiceComponentHost(sch6);

    sch1.setDesiredState(State.INSTALLED);
    sch2.setDesiredState(State.INIT);
    sch4.setDesiredState(State.INSTALLED);
    sch5.setDesiredState(State.UNINSTALLED);
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

1865
1866
1867
1868
1869
1870
1871
1872
1873
1874
1875
    s1.addServiceComponent(sc1);
    sc1.setDesiredState(State.UNINSTALLED);
    sc1.persist();
    ServiceComponentHost sch1 = serviceComponentHostFactory.createNew(sc1, "h1",
        false);
    sc1.addServiceComponentHost(sch1);
    sch1.setDesiredState(State.INSTALLED);
    sch1.setState(State.INSTALLING);
    sch1.setDesiredStackVersion(new StackId("HDP-1.1.0"));
    sch1.setStackVersion(new StackId("HDP-0.1"));
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

818
819
820
821
822
823
824
825
826
827
828
      Map<String, Config> configs = new HashMap<String, Config>();
      if (request.getConfigVersions() != null) {
      }

      sch.updateDesiredConfigs(configs);
      sc.addServiceComponentHost(sch);
      sch.persist();
    }

  }
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

1963
1964
1965
1966
1967
1968
1969
1970
1971
1972
1973
    sc1.addServiceComponentHost(sch1);
    sc1.addServiceComponentHost(sch2);
    sc1.addServiceComponentHost(sch3);
    sc2.addServiceComponentHost(sch4);
    sc2.addServiceComponentHost(sch5);
    sc3.addServiceComponentHost(sch6);

    sch1.setDesiredState(State.INSTALLED);
    sch2.setDesiredState(State.INIT);
    sch4.setDesiredState(State.INSTALLED);
    sch5.setDesiredState(State.UNINSTALLED);
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

522
523
524
525
526
527
528
529
530
531
532
        sch.setDesiredState(state);
      }

      sch.setDesiredStackVersion(sc.getDesiredStackVersion());

      sc.addServiceComponentHost(sch);
      sch.persist();
    }
  }

  private void setMonitoringServicesRestartRequired(
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

2072
2073
2074
2075
2076
2077
2078
2079
2080
2081
2082
    ServiceComponent sc1 = serviceComponentFactory.createNew(s1, "DATANODE");
    s1.addServiceComponent(sc1);
    sc1.setDesiredState(State.UNINSTALLED);
    sc1.persist();
    ServiceComponentHost sch1 = serviceComponentHostFactory.createNew(sc1, "h1");
    sc1.addServiceComponentHost(sch1);
    sch1.setDesiredState(State.INSTALLED);
    sch1.setState(State.INSTALLING);
    sch1.setDesiredStackVersion(new StackId("HDP-1.1.0"));
    sch1.setStackVersion(new StackId("HDP-0.1"));
View Full Code Here

Examples of org.apache.ambari.server.state.ServiceComponent.addServiceComponentHost()

2507
2508
2509
2510
2511
2512
2513
2514
2515
2516
2517
    sc1.addServiceComponentHost(sch1);
    sc1.addServiceComponentHost(sch2);
    sc1.addServiceComponentHost(sch3);
    sc2.addServiceComponentHost(sch4);
    sc2.addServiceComponentHost(sch5);
    sc3.addServiceComponentHost(sch6);

    sch1.setDesiredState(State.INSTALLED);
    sch2.setDesiredState(State.INIT);
    sch4.setDesiredState(State.INSTALLED);
    sch5.setDesiredState(State.UNINSTALLED);
View Full Code Here

Examples of org.apache.ambari.server.state.cluster.ClusterImpl.addServiceComponentHost()

286
287
288
289
290
291
292
293
294
295
296
              + ", serviceComponentName=" + getName()
              + ", hostname=" + hostComponent.getHostName());
        }
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);
        this.hostComponents.put(hostComponent.getHostName(), hostComponent);
      } finally {
        readWriteLock.writeLock().unlock();
      }
    } finally {
View Full Code Here

Examples of org.apache.ambari.server.state.cluster.ClusterImpl.addServiceComponentHost()

327
328
329
330
331
332
333
334
335
336
337
        }
        ServiceComponentHost hostComponent =
            serviceComponentHostFactory.createNew(this, hostName, this.isClientComponent());
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);

        this.hostComponents.put(hostComponent.getHostName(), hostComponent);

        return hostComponent;
      } finally {
View Full Code Here

Examples of org.apache.ambari.server.state.cluster.ClusterImpl.addServiceComponentHost()

214
215
216
217
218
219
220
221
222
223
224
          + ", serviceComponentName=" + getName()
          + ", hostname=" + hostComponent.getHostName());
    }
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);
    this.hostComponents.put(hostComponent.getHostName(), hostComponent);
  }

  @Override
  public synchronized ServiceComponentHost addServiceComponentHost(
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.