json (DataStreamReader)

JSON dosya akışını yükler ve sonuçları DataFrame olarak döndürür. JSON Satırları (yeni satırla ayrılmış JSON) varsayılan olarak desteklenir. Dosya başına bir kaydı olan JSON için seçeneğini olarak multiLineayarlayıntrue. Belirtilmezse schema , giriş şeması verilerden çıkarılır.

Sözdizimi

json(path, schema=None, **options)

Parametreler

Parametre Türü Açıklama
path str JSON veri kümesinin yolu.
schema StructType veya str, isteğe bağlı StructType veya DDL biçimli dize olarak şema (örneğin, col0 INT, col1 DOUBLE).

İadeler

DataFrame

Örnekler

Geçici bir JSON dosyasından akış yükleyin:

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