Compartilhar via

text (DataFrameWriter)

Salva o conteúdo de um arquivo de DataFrame texto no caminho especificado. Os arquivos de texto são codificados como UTF-8.

Sintaxe

text(path, compression=None, lineSep=None)

Parâmetros

Parâmetro Tipo Descrição
path str O caminho em qualquer sistema de arquivos com suporte do Hadoop.
compression str, opcional O codec de compactação a ser usado.
lineSep str, opcional O separador de linha a ser usado.

Devoluções

Nenhum

Observações

O DataFrame deve ter apenas uma coluna de tipo de cadeia de caracteres. Cada linha se torna uma nova linha no arquivo de saída.

Exemplos

Escreva um DataFrame em um arquivo de texto e leia-o novamente.

import tempfile
with tempfile.TemporaryDirectory(prefix="text") as d:
    df = spark.createDataFrame([("a",), ("b",), ("c",)], schema=["alphabets"])
    df.write.mode("overwrite").text(d)

    spark.read.schema(df.schema).format("text").load(d).sort("alphabets").show()
    # +---------+
    # |alphabets|
    # +---------+
    # |        a|
    # |        b|
    # |        c|
    # +---------+
  • Last updated on