simpleStreamReader

Retourneert een SimpleDataSourceStreamReader exemplaar voor het lezen van gegevens.

Syntaxis

simpleStreamReader(schema: StructType)

Parameterwaarden

Kenmerk Typ Beschrijving
schema StructuurType Het schema van de gegevens die moeten worden gelezen.

Retouren

SimpleDataSourceStreamReader

Een lezerexemplaren voor deze gegevensbron.

Aantekeningen

Een van simpleStreamReader() en streamReader() moet worden geïmplementeerd voor een leesbare streaminggegevensbron. Spark controleert of streamReader() het eerst wordt geïmplementeerd en er wordt een DataSourceStreamReader bestand gemaakt om gegevens te lezen als dat zo is. simpleStreamReader() wordt alleen aangeroepen wanneer streamReader() deze niet is geïmplementeerd.