Filter 類別 - AWS Glue
範例 — methods —__call__applynamedescribeArgsdescribeReturndescribeTransformdescribeErrorsdescribe

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。