Method runImpl

solr/core/src/java/org/apache/solr/cli/StreamTool.java:139–251

(CommandLine cli)

  }

  @Override
  @SuppressWarnings({"rawtypes"})
  public void runImpl(CommandLine cli) throws Exception {

    String expressionArgument = cli.getArgs()[0];
    String execution = cli.getOptionValue(EXECUTION_OPTION, "remote");
    String arrayDelimiter = cli.getOptionValue(ARRAY_DELIMITER_OPTION, "|");
    String delimiter = cli.getOptionValue(DELIMITER_OPTION, "   ");
    boolean includeHeaders = cli.hasOption(HEADER_OPTION);
    String[] outputHeaders = getOutputFields(cli);

    LineNumberReader bufferedReader = null;
    String expr;
    try {
      Reader inputStream =
          expressionArgument.toLowerCase(Locale.ROOT).endsWith(".expr")
              ? new InputStreamReader(
                  new FileInputStream(expressionArgument), Charset.defaultCharset())
              : new StringReader(expressionArgument);

      bufferedReader = new LineNumberReader(inputStream);
      expr = StreamTool.readExpression(bufferedReader, cli.getArgs());
      echoIfVerbose("Running Expression: " + expr);
    } finally {
      if (bufferedReader != null) {
        bufferedReader.close();
      }
    }

    // Validate inputs before opening any connection to Solr.
    boolean local = execution.equalsIgnoreCase("local");
    if (!local) {
      if (!cli.hasOption(COLLECTION_OPTION)) {
        throw new IllegalStateException(
            "You must provide --name COLLECTION with --execution remote parameter.");
      }
      if (expr.toLowerCase(Locale.ROOT).contains("stdin(")) {
        throw new IllegalStateException(
            "The stdin() expression is only usable with --execution local.");
      }
    }

    // a stream needs a context
    StreamContext streamContext = createStreamContext(cli);
    // create the stream
    PushBackStream pushBackStream = null;
    try {
      if (local) {
        pushBackStream = doLocalMode(expr, streamContext.getStreamFactory());
      } else {
        pushBackStream = doRemoteMode(expr, cli);
      }
      pushBackStream.setStreamContext(streamContext);
      pushBackStream.open();

      if (outputHeaders == null) {

        Tuple tuple = pushBackStream.read();