simpleStreamReader

SimpleDataSourceStreamReader Zwraca wystąpienie do odczytywania danych.

Składnia

simpleStreamReader(schema: StructType)

Parametry

Parameter	Typ	Opis
schema	Typ struktury	Schemat danych do odczytania.

Zwroty

SimpleDataSourceStreamReader

Wystąpienie czytnika dla tego źródła danych.

Notatki

Jeden z elementów simpleStreamReader() i streamReader() musi być zaimplementowany dla czytelnego źródła danych przesyłania strumieniowego. Platforma Spark sprawdza, czy streamReader() jest implementowana jako pierwsza, i tworzy element DataSourceStreamReader do odczytywania danych, jeśli tak. simpleStreamReader() jest wywoływany tylko wtedy, gdy streamReader() nie jest zaimplementowany.