format (DataStreamWriter)

Temel alınan çıkış veri kaynağını belirtir.

Sözdizimi

format(source)

Parametreler

Parametre	Türü	Açıklama
source	str	Veri kaynağının adı, örneğin 'parquet' veya 'console'.

İadeler

DataStreamWriter

Örnekler

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

CSV'ye Hız kaynağı akışı yazın:

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()