DataFrame.WithWatermark(String, String) メソッド

定義

名前空間:

Microsoft.Spark.Sql

アセンブリ:

Microsoft.Spark.dll

パッケージ:

Microsoft.Spark v1.0.0

この DataFrame のイベント時間の基準値を定義します。 ウォーターマークは、それ以上遅延データが到着しないと仮定する前の時点を追跡します。

public Microsoft.Spark.Sql.DataFrame WithWatermark (string eventTime, string delayThreshold);

member this.WithWatermark : string * string -> Microsoft.Spark.Sql.DataFrame

Public Function WithWatermark (eventTime As String, delayThreshold As String) As DataFrame

パラメーター

eventTime

String

行のイベント時刻を含む列の名前。

delayThreshold

String

データが遅れて到着するまで待機する最小遅延 。間隔 ("1 分" や "5 時間" など) の形式で処理された最新のレコードに対して相対的です。

戻り値

DataFrame

DataFrame オブジェクト