org.apache.brooklyn.core.entity.Entities.ancestors()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(105)

本文整理了Java中org.apache.brooklyn.core.entity.Entities.ancestors()方法的一些代码示例,展示了Entities.ancestors()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Entities.ancestors()方法的具体详情如下:
包路径:org.apache.brooklyn.core.entity.Entities
类名称:Entities
方法名:ancestors

Entities.ancestors介绍

暂无

代码示例

代码示例来源:origin: io.brooklyn.ambari/brooklyn-ambari

private AmbariCluster getAmbariCluster() {
    return Iterables.getFirst(Iterables.filter(Entities.ancestors(this), AmbariCluster.class), null);
  }
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

@Test
public void testAncestors() throws Exception {
  Asserts.assertEqualsIgnoringOrder(Entities.ancestorsAndSelf(app), ImmutableList.of(app));
  Asserts.assertEqualsIgnoringOrder(Entities.ancestors(app), ImmutableList.of(app));
  Asserts.assertEqualsIgnoringOrder(Entities.ancestorsAndSelf(entity), ImmutableList.of(entity, app));
  Asserts.assertEqualsIgnoringOrder(Entities.ancestors(entity), ImmutableList.of(entity, app));
}

代码示例来源:origin: io.brooklyn.ambari/brooklyn-ambari

private AmbariCluster getParentAmbariCluster() {
  Iterable<AmbariCluster> ancestors = Iterables.filter(Entities.ancestors(entity), AmbariCluster.class);
  return Iterables.getFirst(ancestors, null);
}

代码示例来源:origin: io.brooklyn.ambari/brooklyn-ambari

protected AmbariCluster getParentAmbariCluster() {
    Iterable<AmbariCluster> ancestors = Iterables.filter(
        Entities.ancestors(entity), AmbariCluster.class);
    return Iterables.getFirst(ancestors, null);
  }
}

代码示例来源:origin: io.brooklyn.ambari/brooklyn-ambari

@Override
public boolean agentOnServer() {
  Iterable<AmbariCluster> ambariClusters = Iterables.filter(Entities.ancestors(this), AmbariCluster.class);
  for (Entity parent : ambariClusters) {
    return !parent.getConfig(AmbariCluster.SERVER_COMPONENTS).isEmpty();
  }
  return false;
}

代码示例来源:origin: io.brooklyn.ambari/brooklyn-ambari

@Override
public void install() {
  String parentFQDN =
  entity.getParent() instanceof AmbariServer
      ? ((AmbariServer) entity.getParent()).getFqdn()
      : "";
  Entity parentHostGroup =
      Iterables.getFirst(
          Iterables.filter(Entities.ancestors(entity), AmbariHostGroup.class),
          entity);
  String fqdn =
      parentFQDN.isEmpty()
      ? String.format("%s-%s.%s", parentHostGroup.getDisplayName().toLowerCase(), entity.getId().toLowerCase(), entity.getConfig(AmbariCluster.DOMAIN_NAME))
      : parentFQDN;
  getEntity().setFqdn(fqdn);
  ImmutableList<String> commands =
      ImmutableList.<String>builder()
          .add(defaultAmbariInstallHelper.installAmbariRequirements(getMachine()))
          .addAll(BashCommands.setHostname(fqdn))
          .add(installPackage("ambari-agent"))
          .add(BashCommands.appendToEtcHosts(
              getParentAmbariCluster().getMasterAmbariServer().sensors().get(Attributes.SUBNET_ADDRESS),
              getEntity().getAmbariServerFQDN()))
          .build();
  newScript(INSTALLING).body
      .append(commands)
      .failOnNonZeroResultCode()
      .execute();
}

相关文章