start (DataStreamWriter)

Streamuje obsah datového rámce do zdroje dat a vrátí objekt StreamingQuery.

Syntaxe

start(path=None, format=None, outputMode=None, partitionBy=None, queryName=None, **options)

Parametry

Parameter	Typ	Description
path	str, volitelné	Cesta v systému souborů podporovaných systémem Hadoop.
format	str, volitelné	Formát použitý k uložení.
outputMode	str, volitelné	Způsob zápisu dat do jímky: append, completenebo update.
partitionBy	str nebo list, volitelné	Názvy sloupců dělení
queryName	str, volitelné	Jedinečný název dotazu.
**options		Všechny ostatní možnosti řetězce. Poskytovat checkpointLocation pro většinu datových proudů, nevyžaduje se memory pro datový proud.

Návraty

StreamingQuery

Příklady

df = spark.readStream.format("rate").load()

Základní příklad:

q = df.writeStream.format('memory').queryName('this_query').start()
q.isActive
# True
q.name
# 'this_query'
q.stop()
q.isActive
# False

S triggerem a dalšími parametry:

q = df.writeStream.trigger(processingTime='5 seconds').start(
    queryName='that_query', outputMode="append", format='memory')
q.name
# 'that_query'
q.isActive
# True
q.stop()