本文整理了Java中org.jclouds.scriptbuilder.domain.Statements.call()
方法的一些代码示例,展示了Statements.call()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Statements.call()
方法的具体详情如下:
包路径:org.jclouds.scriptbuilder.domain.Statements
类名称:Statements
方法名:call
暂无
代码示例来源:origin: jclouds/legacy-jclouds
public FromURL(URI jdk7Url) {
super(call("setupPublicCurl"), call("installJDKFromURL", jdk7Url.toASCIIString()));
}
}
代码示例来源:origin: org.apache.whirr/whirr-chef
private void addInstallChefStatements(ClusterActionEvent event) {
// install ruby and ruby-gems in the nodes
addStatement(event, call("install_ruby"));
// install git
addStatement(event, call("install_git"));
// install chef-solo
addStatement(event, call("install_chef"));
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeCleanup(ClusterActionEvent event) {
addStatement(event, call("remove_service"));
addStatement(event, call("cleanup_cassandra"));
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeCleanup(ClusterActionEvent event) throws IOException {
addStatement(event, call("cleanup_elasticsearch"));
}
}
代码示例来源:origin: org.apache.jclouds/jclouds-scriptbuilder
public InstallChefUsingOmnibus(String chefVersion) {
super(call("setupPublicCurl"), saveHttpResponseTo(URI.create(OMNIBUS_INSTALLER), "/tmp", "install-chef.sh"),
exec("sh /tmp/install-chef.sh -v " + chefVersion));
}
}
代码示例来源:origin: com.amysta.jclouds/jclouds-scriptbuilder
public InstallChefUsingOmnibus(String chefVersion) {
super(call("setupPublicCurl"), saveHttpResponseTo(URI.create(OMNIBUS_INSTALLER), "/tmp", "install-chef.sh"),
exec("sh /tmp/install-chef.sh -v " + chefVersion));
}
}
代码示例来源:origin: org.apache.whirr/whirr-druid
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration conf = getConfiguration(clusterSpec);
addStatement(event, call("configure_hostnames"));
addStatement(event, call("install_mysql")); // installed/run via apt-get
}
protected void beforeConfigure(ClusterActionEvent event) throws IOException {
代码示例来源:origin: org.apache.whirr/whirr-kerberos
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
super.beforeBootstrap(event);
addStatement(event, call("install_kerberos_server"));
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration conf = getConfiguration(clusterSpec);
addStatement(event, call("configure_hostnames"));
addStatement(event, call("install_mysql")); // installed/run via apt-get
}
protected void beforeConfigure(ClusterActionEvent event) throws IOException {
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
super.beforeBootstrap(event);
addStatement(event, call("install_kerberos_server"));
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException, InterruptedException {
Configuration conf = getConfiguration(event.getClusterSpec(), MAHOUT_DEFAULT_PROPERTIES);
String mahoutTarball = prepareRemoteFileUrl(event, conf.getString(MAHOUT_TAR_URL));
addStatement(event, call("retry_helpers"));
addStatement(event, call(MAHOUT_CLIENT_SCRIPT, URL_FLAG, mahoutTarball));
}
代码示例来源:origin: org.apache.whirr/whirr-ganglia
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration config = getConfiguration(clusterSpec);
addStatement(event, call("retry_helpers"));
addStatement(event, call(getInstallFunction(config),
"-r", GANGLIA_MONITOR_ROLE)
);
}
代码示例来源:origin: org.apache.whirr/whirr-ganglia
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration config = getConfiguration(clusterSpec);
addStatement(event, call("retry_helpers"));
addStatement(event, call(getInstallFunction(config),
"-r", GANGLIA_METAD_ROLE)
);
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration config = getConfiguration(clusterSpec);
addStatement(event, call("retry_helpers"));
addStatement(event, call(getInstallFunction(config),
"-r", GANGLIA_METAD_ROLE)
);
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration config = getConfiguration(clusterSpec);
addStatement(event, call("retry_helpers"));
addStatement(event, call(getInstallFunction(config),
"-r", GANGLIA_MONITOR_ROLE)
);
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeBootstrap(ClusterActionEvent event) throws IOException {
addStatement(event, call("configure_hostnames"));
addStatement(event, call("retry_helpers"));
if (!(event.getClusterSpec().getConfiguration().containsKey("whirr.env.jdk_installed")
&& event.getClusterSpec()
.getConfiguration().getBoolean("whirr.env.jdk_installed"))) {
addStatement(event,
call(getInstallFunction(event.getClusterSpec().getConfiguration(), "java", "install_openjdk")));
}
addStatement(event, call("install_kerberos_client"));
}
代码示例来源:origin: org.apache.whirr/whirr-druid
@Override
protected void beforeStart(ClusterActionEvent event) throws IOException {
Configuration config = getConfiguration(event.getClusterSpec());
String configureFunction = getConfigureFunction(config);
if (configureFunction.equals("configure_druid")) {
addStatement(event, call(getStartFunction(config), getRole()));
} else {
}
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeStart(ClusterActionEvent event) throws IOException {
Configuration config = getConfiguration(event.getClusterSpec());
String configureFunction = getConfigureFunction(config);
if (configureFunction.equals("configure_druid")) {
addStatement(event, call(getStartFunction(config), getRole()));
} else {
}
}
代码示例来源:origin: org.apache.whirr/whirr-kerberos
@Override
protected void beforeConfigure(ClusterActionEvent event) throws IOException {
super.beforeConfigure(event);
addStatement(event, call("configure_kerberos_server"));
for (Object port : getConfiguration(event.getClusterSpec()).getList(PROPERTY_PORTS)) {
if (port != null && !"".equals(port))
event.getFirewallManager().addRule(
Rule.create().destination(role(ROLE)).port(Integer.parseInt(port.toString())));
}
}
代码示例来源:origin: apache/attic-whirr
@Override
protected void beforeConfigure(ClusterActionEvent event) throws IOException,
InterruptedException {
ClusterSpec clusterSpec = event.getClusterSpec();
Configuration conf = getConfiguration(clusterSpec);
handleFirewallRules(event);
addStatement(event, call(getStartFunction(conf, "mr_jobhistory", "start_mr_jobhistory"), "historyserver"));
}
内容来源于网络,如有侵权,请联系作者删除!