Method save

src/main/java/org/rumbledb/api/SequenceWriter.java:249–322

(String path)

    }

    public void save(String path) {
        URI outputUri = null;
        outputUri = FileSystemUtil.resolveURIAgainstWorkingDirectory(
            path,
            this.configuration,
            ExceptionMetadata.EMPTY_METADATA
        );
        String method = this.serializationParameters.getMethod();
        // DataFrame mode: delegate to Spark's DataFrameWriter, using the serialization method
        // as the Spark output format (json/csv/parquet/other).
        if (this.dataFrameWriter != null) {
            Logger logger = LogManager.getLogger(SequenceWriter.class);
            for (Map.Entry<String, String> option : this.serializationParameters.getSparkOptions().entrySet()) {
                logger.info("Writing with option " + option.getKey() + " : " + option.getValue());
            }
            logger.info("Writing to format " + method);
            DataFrameWriter<Row> writerWithOptions = applyStoredSparkOptions(this.dataFrameWriter);
            String target = FileSystemUtil.convertURIToStringForSpark(outputUri);
            if (method.equalsIgnoreCase("json")) {
                writerWithOptions.json(target);
            } else if (method.equalsIgnoreCase("csv")) {
                writerWithOptions.csv(target);
            } else if (method.equalsIgnoreCase("parquet")) {
                writerWithOptions.parquet(target);
            } else {
                writerWithOptions.format(method).save(target);
            }
            return;
        }
        // RDD mode: serialize each item via Serializer and save as text.
        if (
            !(method.equals("json")
                || method.equals("tyson")
                || method.equals("xml-json-hybrid")
                || method.equals("yaml")
                || method.equals("delta"))
        ) {
            throw new CliException(
                    "Rumble cannot output another format than json or tyson or xml-json-hybrid or yaml if the query does not output a structured collection. You can create a structured collection from a sequence of objects by calling the function annotate(<your query here> , <a schema here>)."
            );
        }
        if (FileSystemUtil.exists(outputUri, this.configuration, ExceptionMetadata.EMPTY_METADATA)) {
            switch (this.mode) {
                case Overwrite:
                    FileSystemUtil.delete(outputUri, this.configuration, ExceptionMetadata.EMPTY_METADATA);
                    break;
                case Ignore:
                    return;
                case ErrorIfExists:
                    throw new CliException(
                            "Output path "
                                + outputUri
                                + " already exists. Please change the mode or use --overwrite yes to overwrite."
                    );
                case Append:
                    throw new CliException(
                            "Append currently not supported when the output is not a DataFrame."
                    );