formato (DataStreamReader)

Especifica o formato da fonte de dados de entrada.

Sintaxe

format(source)

Parâmetros

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

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

Devoluções

DataStreamReader

Exemplos

Python

spark.readStream.format("text")
# <...streaming.readwriter.DataStreamReader object ...>

Escreva um arquivo de texto e leia-o de volta como uma transmissão:

Python

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="format") as d:
    spark.createDataFrame(
        [("hello",), ("this",)]).write.mode("overwrite").format("text").save(d)
    q = spark.readStream.format("text").load(d).writeStream.format("console").start()
    time.sleep(3)
    q.stop()