Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Gibt eine SimpleDataSourceStreamReader Instanz zum Lesen von Daten zurück.
Syntax
simpleStreamReader(schema: StructType)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
schema |
StructType | Das Schema der zu lesenden Daten. |
Rückkehr
SimpleDataSourceStreamReader
Eine Leseinstanz für diese Datenquelle.
Hinweise
Einer von simpleStreamReader() und streamReader() muss für eine lesbare Streamingdatenquelle implementiert werden. Spark überprüft, ob streamReader() zuerst implementiert wird, und erstellt ggf. eine DataSourceStreamReader zum Lesen von Daten.
simpleStreamReader() wird nur aufgerufen, wenn streamReader() sie nicht implementiert ist.