Filter 類別 - AWS Glue

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

Filter 類別

建立新的 DynamicFrame,其中包含來自輸入 DynamicFrame 的符合指定述詞函數的記錄。

範例

建議您使用 DynamicFrame.filter() 方法篩選 DynamicFrame 中的記錄。若要檢視程式碼範例,請參閱 範例:使用篩選條件取得已篩選的欄位選取

方法

__call__(frame, f, transformation_ctx="", info="", stageThreshold=0, totalThreshold=0))

傳回新 DynamicFrame,其藉由從符合指定述詞函數的輸入 DynamicFrame 選擇記錄所建置。

  • frame – 要套用指定篩選條件函數的來源 DynamicFrame (必要)。

  • f – 要套用到 DynamicFrame 中各個 DynamicRecord 的述詞函數。此函數必須以 DynamicRecord 做為引數並傳回 True,如果 DynamicRecord 符合篩選條件要求,否則將傳回 False (必要)。

    DynamicRecord 代表 DynamicFrame 中的邏輯記錄。它類似 Spark DataFrame 中的一列,除了它是自我描述的,以及可用於不符合固定結構描述的資料。

  • transformation_ctx – 用於識別狀態資訊的唯一字串 (選用)。

  • info – 與轉換中的錯誤相關的字串 (選用)。

  • stageThreshold – 在錯誤輸出之前,轉換作業中可發生錯誤的次數上限 (選用)。預設為零。

  • totalThreshold – 在處理錯誤輸出之前,整體作業可發生錯誤的次數上限 (選用)。預設為零。

apply(cls, *args, **kwargs)

繼承自 GlueTransform apply

name(cls)

繼承自 GlueTransform name

describeArgs(cls)

繼承自 GlueTransform describeArgs

describeReturn(cls)

繼承自 GlueTransform describeReturn

describeTransform(cls)

繼承自 GlueTransform describeTransform

describeErrors(cls)

繼承自 GlueTransform describeErrors

describe(cls)

繼承自 GlueTransform describe