mulai (DataStreamWriter)

Mengalirkan konten DataFrame ke sumber data dan mengembalikan objek StreamingQuery.

Sintaksis

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

Parameter-parameternya

Parameter	Tipe	Deskripsi
path	str, opsional	Jalur dalam sistem file yang didukung Hadoop.
format	str, opsional	Format yang digunakan untuk menyimpan.
outputMode	str, opsional	Bagaimana data ditulis ke sink: append, , completeatau update.
partitionBy	str atau daftar, opsional	Nama kolom partisi.
queryName	str, opsional	Nama unik untuk kueri.
**options		Semua opsi string lainnya. Menyediakan checkpointLocation sebagian besar aliran; tidak diperlukan untuk memory streaming.

Pengembalian Barang

StreamingQuery

Examples

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

Contoh dasar:

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

Dengan pemicu dan parameter tambahan:

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