本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
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
中的邏輯記錄。它類似 SparkDataFrame
中的一列,除了它是自我描述的,以及可用於不符合固定結構描述的資料。 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。