Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Returnerar en SimpleDataSourceStreamReader instans för att läsa data.
Syntax
simpleStreamReader(schema: StructType)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
schema |
StructType | Schemat för de data som ska läsas. |
Retur
SimpleDataSourceStreamReader
En läsarinstans för den här datakällan.
Notes
En av simpleStreamReader() och streamReader() måste implementeras för en läsbar strömmande datakälla. Spark kontrollerar om streamReader() implementeras först och skapar en DataSourceStreamReader för att läsa data i så fall.
simpleStreamReader() anropas endast när streamReader() inte har implementerats.