formato (DataStreamWriter)

Especifica a fonte de dados de saída subjacente.

Sintaxe

format(source)

Parâmetros

Parâmetro	Tipo	Descrição
source	str	Nome da fonte de dados, por exemplo 'parquet' ou 'console'.

Parâmetro	Tipo	Descrição
source	str	Nome da fonte de dados, por exemplo 'parquet' ou 'console'.

Devoluções

DataStreamWriter

Exemplos

Python

df = spark.readStream.format("rate").load()
df.writeStream.format("text")
# <...streaming.readwriter.DataStreamWriter object ...>

Escreva uma transmissão de origem de taxa para CSV:

Python

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="format1") as d:
    with tempfile.TemporaryDirectory(prefix="format2") as cp:
        df = spark.readStream.format("rate").load()
        q = df.writeStream.format("csv").option("checkpointLocation", cp).start(d)
        time.sleep(5)
        q.stop()
        spark.read.schema("timestamp TIMESTAMP, value STRING").csv(d).show()