DataStreamWriter.ForeachBatch(Action<DataFrame,Int64>) Metoda

Reference

Definice

Obor názvů:: Microsoft.Spark.Sql.Streaming

Sestavení:: Microsoft.Spark.dll

Balíček:: Microsoft.Spark v1.0.0

Důležité

Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.

Nastaví výstup dotazu streamování, který se má zpracovat pomocí poskytnuté funkce. To je podporováno pouze v režimech mikrodávkového spouštění (to znamená, když trigger není nepřetržitý). V každé mikrodávce bude zadaná funkce volána v každé mikrodávce s (i) výstupními řádky jako DataFrame a (ii) identifikátorem dávky. BatchId lze použít k odstranění duplicitních dat a transakčnímu zápisu výstupu (tj. poskytnuté datové sady) do externích systémů. U stejného batchId je zaručeno, že výstup DataFrame bude přesně stejný (za předpokladu, že všechny operace jsou v dotazu deterministické).

[Microsoft.Spark.Since("2.4.0")]
public Microsoft.Spark.Sql.Streaming.DataStreamWriter ForeachBatch(Action<Microsoft.Spark.Sql.DataFrame,long> func);

[<Microsoft.Spark.Since("2.4.0")>]
member this.ForeachBatch : Action<Microsoft.Spark.Sql.DataFrame, int64> -> Microsoft.Spark.Sql.Streaming.DataStreamWriter

Public Function ForeachBatch (func As Action(Of DataFrame, Long)) As DataStreamWriter

Parametry

func: Action<DataFrame,Int64>

Funkce, která se má použít u datového rámce

Návraty

DataStreamWriter

Tento objekt DataStreamWriter

Atributy: SinceAttribute

Platí pro