simpleStreamReader

Mengembalikan instans SimpleDataSourceStreamReader untuk membaca data.

Sintaksis

simpleStreamReader(schema: StructType)

Parameter-parameternya

Parameter	Tipe	Deskripsi
schema	StructType	Skema data yang akan dibaca.

Pengembalian Barang

SimpleDataSourceStreamReader

Instans pembaca untuk sumber data ini.

Catatan

Salah satu dan simpleStreamReader()streamReader() harus diimplementasikan untuk sumber data streaming yang dapat dibaca. Spark memeriksa apakah streamReader() diimplementasikan terlebih dahulu dan membuat DataSourceStreamReader untuk membaca data jika demikian. simpleStreamReader() hanya dipanggil ketika streamReader() tidak diimplementasikan.