DataStreamWriter.ForeachBatch(Action<DataFrame,Int64>) 方法

定義

命名空間:

Microsoft.Spark.Sql.Streaming

組件:

Microsoft.Spark.dll

套件:

Microsoft.Spark v1.0.0

使用提供的 函式，設定要處理的串流查詢輸出。 只有當觸發程式不是連續) 時，才支援微批次執行模式 (。 在每個微批次中，每個微批次中都會呼叫提供的函式， (i) 輸出資料列作為 ， DataFrame (ii) 批次識別碼。 batchId 可用來重復資料刪除，並以交易方式將輸出寫入 (，也就是提供的資料集) 外部系統。 如果查詢) 中的所有作業都具決定性，則輸出 DataFrame 保證與相同的 batchId 完全相同 (。

[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

參數

func

Action<DataFrame,Int64>

要套用至 DataFrame 的函式

傳回

DataStreamWriter

這個 DataStreamWriter 物件

屬性

SinceAttribute