simpleStreamReader

SimpleDataSourceStreamReader Vrátí instanci pro čtení dat.

Syntaxe

simpleStreamReader(schema: StructType)

Parametry

Parameter	Typ	Description
schema	Typ struktury	Schéma dat, která se mají číst.

Návraty

SimpleDataSourceStreamReader

Příklad čtenáře pro tento zdroj dat.

Poznámky

Jeden z simpleStreamReader() nich a streamReader() musí být implementován pro čitelný streamovaný zdroj dat. Spark zkontroluje, jestli streamReader() je implementovaný jako první, a pokud ano, vytvoří DataSourceStreamReader pro čtení dat. simpleStreamReader() je vyvolána pouze v případech, kdy streamReader() není implementováno.