start (DataStreamWriter)

DataFrame'in içeriğini bir veri kaynağına akışla aktarıp bir StreamingQuery nesnesi döndürür.

Sözdizimi

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

Parametreler

Parametre	Türü	Açıklama
path	str, isteğe bağlı	Hadoop tarafından desteklenen bir dosya sisteminde yol.
format	str, isteğe bağlı	Kaydetmek için kullanılan biçim.
outputMode	str, isteğe bağlı	Verilerin havuza nasıl yazıldı: append, completeveya update.
partitionBy	str veya list, isteğe bağlı	Bölümleme sütunlarının adları.
queryName	str, isteğe bağlı	Sorgunun benzersiz adı.
**options		Diğer tüm dize seçenekleri. Çoğu akışı sağlayın checkpointLocation ; akış memory için gerekli değildir.

İadeler

StreamingQuery

Örnekler

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

Temel örnek:

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

Tetikleyici ve ek parametrelerle:

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