load (DataStreamReader)

Memuat aliran data dari sumber data dan mengembalikannya sebagai DataFrame.

Sintaksis

load(path=None, format=None, schema=None, **options)

Parameter-parameternya

Parameter	Tipe	Deskripsi
path	str, opsional	Jalur untuk sumber data yang didukung sistem file.
format	str, opsional	Format sumber data. Secara default menjadi 'parquet'.
schema	StructType atau str, opsional	Skema untuk data input sebagai string berformat StructType atau DDL (misalnya, col0 INT, col1 DOUBLE).
**options		Semua opsi string lainnya.

Pengembalian Barang

DataFrame

Examples

Muat aliran dari file JSON sementara:

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="load") as d:
    spark.createDataFrame(
        [(100, "Hyukjin Kwon"),], ["age", "name"]
    ).write.mode("overwrite").format("json").save(d)
    q = spark.readStream.schema(
        "age INT, name STRING"
    ).format("json").load(d).writeStream.format("console").start()
    time.sleep(3)
    q.stop()