本文整理了Java中org.springframework.yarn.boot.app.YarnInfoApplication.appProperties()
方法的一些代码示例,展示了YarnInfoApplication.appProperties()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YarnInfoApplication.appProperties()
方法的具体详情如下:
包路径:org.springframework.yarn.boot.app.YarnInfoApplication
类名称:YarnInfoApplication
方法名:appProperties
暂无
代码示例来源:origin: org.springframework.data/spring-yarn-boot-cli
@Override
protected void runApplication(OptionSet options) throws Exception {
YarnInfoApplication app = new YarnInfoApplication();
Properties appProperties = new Properties();
appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.operation", "PUSHED");
app.appProperties(appProperties);
handleApplicationRun(app);
}
代码示例来源:origin: org.springframework.data/spring-yarn-boot-cli
@Override
protected void runApplication(OptionSet options) throws Exception {
YarnInfoApplication app = new YarnInfoApplication();
Properties appProperties = new Properties();
appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.operation", "SUBMITTED");
if (isFlagOn(options, verboseOption)) {
appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.verbose", "true");
}
appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.type", options.valueOf(typeOption));
app.appProperties(appProperties);
handleApplicationRun(app);
}
代码示例来源:origin: org.springframework.cloud/spring-cloud-dataflow-module-deployer-yarn
@Override
public Collection<CloudAppInfo> getApplications() {
ArrayList<CloudAppInfo> infos = new ArrayList<CloudAppInfo>();
YarnInfoApplication app = new YarnInfoApplication();
Properties appProperties = new Properties();
appProperties.setProperty(PREFIX_YIA + "operation", "PUSHED");
app.appProperties(appProperties);
String info = runApp(app);
logger.debug("Full response for PUSHED: {}", info);
String[] lines = info.split("\\r?\\n");
if (lines.length > 2) {
for (int i = 2; i < lines.length; i++) {
String[] fields = lines[i].trim().split("\\s+");
if (fields.length > 1) {
infos.add(new CloudAppInfo(fields[0].trim()));
}
}
}
return infos;
}
代码示例来源:origin: org.springframework.cloud/spring-cloud-dataflow-module-deployer-yarn
@Override
public Collection<CloudAppInstanceInfo> getInstances() {
ArrayList<CloudAppInstanceInfo> infos = new ArrayList<CloudAppInstanceInfo>();
YarnInfoApplication app = new YarnInfoApplication();
Properties appProperties = new Properties();
appProperties.setProperty(PREFIX_YIA + "operation", "SUBMITTED");
appProperties.setProperty(PREFIX_YIA + "verbose", "false");
appProperties.setProperty(PREFIX_YIA + "type", "DATAFLOW");
app.appProperties(appProperties);
String info = runApp(app);
logger.debug("Full response for SUBMITTED: {}", info);
String[] lines = info.split("\\r?\\n");
if (lines.length > 2) {
for (int i = 2; i < lines.length; i++) {
String[] fields = lines[i].trim().split("\\s+");
if (fields.length > 10) {
infos.add(new CloudAppInstanceInfo(fields[0].trim(), fields[2].trim(), fields[fields.length - 1]
.trim()));
}
}
}
return infos;
}
内容来源于网络,如有侵权,请联系作者删除!