simpleStreamReader

Verileri okumak için bir SimpleDataSourceStreamReader örnek döndürür.

Sözdizimi

simpleStreamReader(schema: StructType)

Parametreler

Parametre Türü Açıklama
schema YapıTürü Okunacak verilerin şeması.

İadeler

SimpleDataSourceStreamReader

Bu veri kaynağı için bir okuyucu örneği.

Notlar

simpleStreamReader() streamReader() Okunabilir bir akış veri kaynağı için ve'lerinden biri uygulanmalıdır. Spark önce uygulanıp uygulanmadığını streamReader() denetler ve varsa verileri okumak için bir DataSourceStreamReader oluşturur. simpleStreamReader() yalnızca uygulanmadığında streamReader() çağrılır.