org.apache.brooklyn.util.text.Strings.join()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(108)

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

Strings.join介绍

[英]convenience for com.google.common.base.Joiner
[中]为com提供便利。谷歌。常见的基础细木工

代码示例

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

/** As {@link #chain(Collection)}, but explicitly using ( ) grouping characters
 * to ensure exits are caught. */
public static String chainSubshell(Collection<String> commands) {
  // the spaces are not required, but it might be possible that a (( expr )) is interpreted differently
  // (won't hurt to have the spaces in any case!) 
  return "( " + Strings.join(commands, " && ") + " )";
}

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

/** As {@link #alternatives(Collection)} */
public static String alternatives(String ...commands) {
  return "( " + Strings.join(commands, " || ") + " )";
}

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

/**
 * Returns a sequence of chained commands that runs until one of them fails (i.e. joined by '&&')
 * This currently runs as a subshell (so exits are swallowed) but behaviour may be changed imminently. 
 * (Use {@link #chainGroup(Collection)} or {@link #chainSubshell(Collection)} to be clear.)
 */
public static String chain(Collection<String> commands) {
  return "( " + Strings.join(commands, " && ") + " )";
}

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

/**
 * Returns a sequence of chained commands that runs until one of them succeeds (i.e. joined by '||').
 * This currently runs as a subshell (so exits are swallowed) but behaviour may be changed imminently. 
 * (Use {@link #alternativesGroup(Collection)} or {@link #alternativesSubshell(Collection)} to be clear.)
 */
public static String alternatives(Collection<String> commands) {
  return "( " + Strings.join(commands, " || ") + " )";
}

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

/** As {@link #alternatives(Collection)}, but explicitly using ( ) grouping characters
 * to ensure exits are caught. */
public static String alternativesSubshell(Collection<String> commands) {
  // the spaces are not required, but it might be possible that a (( expr )) is interpreted differently
  // (won't hurt to have the spaces in any case!) 
  return "( " + Strings.join(commands, " || ") + " )";
}

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

@Override
  public String apply(@Nullable Iterable<?> input) {
    return Strings.join(input, separator);
  }
};

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

@Override
  public String apply(@Nullable Object[] input) {
    if (input == null) return Strings.EMPTY;
    return Strings.join(input, separator);
  }
};

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

private String makeAsIndentedList(String yaml) {
  String[] lines = yaml.split("\n");
  lines[0] = "- "+lines[0];
  for (int i=1; i<lines.length; i++)
    lines[i] = "  " + lines[i];
  return Strings.join(lines, "\n");
}

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

private String makeAsIndentedObject(String yaml) {
  String[] lines = yaml.split("\n");
  for (int i=0; i<lines.length; i++)
    lines[i] = "  " + lines[i];
  return Strings.join(lines, "\n");
}

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

/** @return true iff there are arguments; it also sys.errs a warning in that case  */
protected boolean warnIfArguments() {
  if (arguments.isEmpty()) return false;
  stderr.println("Invalid subcommand arguments: "+Strings.join(arguments, " "));
  return true;
}

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

@Override
  public int run() {
    String scriptContents = toScript(props, commands, env);
    if (LOG.isTraceEnabled()) LOG.trace("Running shell command at {} as script: {}", host, scriptContents);
    copyTempFileToServer(ImmutableMap.of("permissions", "0700"), writeTempFile(scriptContents), scriptPath);
    String cmd = Strings.join(buildRunScriptCommand(), separator);
    return asInt(sshExec(props, cmd), -1);
  }
}.run();

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

@Override
 public String apply(@Nullable ProcessTaskWrapper<?> input) {
  if (logger!=null) logger.info(input+" COMMANDS:\n"+Strings.join(input.getCommands(),"\n"));
  if (logger!=null) logger.info(input+" STDOUT:\n"+input.getStdout());
  if (logger!=null) logger.info(input+" STDERR:\n"+input.getStderr());
  if (requireZero && input.getExitCode()!=0) 
    throw new IllegalStateException("non-zero exit code in "+input.getSummary()+": see log for more details!");
  return input.getStdout();
 }
};

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

protected Builder xsltTransformerRecursiveCopyWithExtraRules(String ...rules) {
  String xsltTemplate = ResourceUtils.create(this).getResourceAsString("classpath://org/apache/brooklyn/core/mgmt/rebind/transformer/recursiveCopyWithExtraRules.xslt");
  String xslt = TemplateProcessor.processTemplateContents(xsltTemplate, ImmutableMap.of("extra_rules", Strings.join(rules, "\n")));
  return xsltTransformer(xslt);
}

代码示例来源:origin: io.cloudsoft.brooklyn.tosca/brooklyn-tosca-transformer

public void upload(Path zip) throws ParsingException, CSARVersionAlreadyExistsException {
  LOG.debug("Uploading type: " + zip);
  ParsingResult<Csar> types = archiveUploadService.upload(zip);
  if (ArchiveUploadService.hasError(types, ParsingErrorLevel.ERROR)) {
    throw new UserFacingException("Errors parsing types:\n" + Strings.join(types.getContext().getParsingErrors(), "\n  "));
  }
}

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

/** returns a "groupId:artifactId:version:(classifier:)packaging" string
 * which maven refers to as the co-ordinate */
public String getCoordinate() {
  return Strings.join(MutableList.<String>of().append(groupId, artifactId, packaging).
    appendIfNotNull(classifier).append(version), ":");
}

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

protected RuntimeException logWithDetailsAndThrow(String message, Throwable optionalCause) {
  log.warn(message+" (throwing)");
  Streams.logStreamTail(log, "STDERR of problem in "+Tasks.current(), stderr, 1024);
  Streams.logStreamTail(log, "STDOUT of problem in "+Tasks.current(), stdout, 1024);
  Streams.logStreamTail(log, "STDIN of problem in "+Tasks.current(), Streams.byteArrayOfString(Strings.join(getLines(),"\n")), 4096);
  if (optionalCause!=null) throw new IllegalStateException(message, optionalCause);
  throw new IllegalStateException(message);
}

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

@Test
public void testListCurrentCatalogItems() {
  LocalManagementContext mgmt = newManagementContext(BrooklynProperties.Factory.newDefault());
  log.info("ITEMS\n"+Strings.join(mgmt.getCatalog().getCatalogItems(), "\n"));
}

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

/** creates the TaskBuilder which can be further customized; typically invoked by the initial {@link #newTask()} */
public TaskBuilder<Object> constructCustomizedTaskBuilder() {
  TaskBuilder<Object> tb = TaskBuilder.builder().dynamic(false).displayName("ssh: "+getSummary());
  
  tb.tag(BrooklynTaskTags.tagForStream(BrooklynTaskTags.STREAM_STDIN, 
      Streams.byteArrayOfString(Strings.join(commands, "\n"))));
  tb.tag(BrooklynTaskTags.tagForEnvStream(BrooklynTaskTags.STREAM_ENV, shellEnvironment));
  
  return tb;
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-software-cm-chef

/** creates the command for running knife.
 * in some cases knife may be added multiple times,
 * and in that case the parameter here tells which time it is being added, 
 * on a single run. */
protected String buildKnifeCommand(int knifeCommandIndex) {
  MutableList<String> words = new MutableList<String>();
  words.add(knifeExecutable());
  words.addAll(initialKnifeParameters());
  words.addAll(knifeParameters());
  String x = knifeConfigFileOption();
  if (Strings.isNonBlank(x)) words.add(knifeConfigFileOption());
  return Strings.join(words, " ");
}

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

/** creates the command for running knife.
 * in some cases knife may be added multiple times,
 * and in that case the parameter here tells which time it is being added, 
 * on a single run. */
protected String buildKnifeCommand(int knifeCommandIndex) {
  MutableList<String> words = new MutableList<String>();
  words.add(knifeExecutable());
  words.addAll(initialKnifeParameters());
  words.addAll(knifeParameters());
  String x = knifeConfigFileOption();
  if (Strings.isNonBlank(x)) words.add(knifeConfigFileOption());
  return Strings.join(words, " ");
}

相关文章