フィルタクラス
指定された述語関数を満たす、入力 DynamicFrame からのレコードが含まれた新しい DynamicFrame を構築します。
例
DynamicFrame.filter() メソッドを使用して、DynamicFrame のレコードをフィルタリングすることをお勧めします。コード例については、「例: フィルターを使用して、フィールドのフィルタリングされた選択内容を取得する」を参照してください。
方法
__call__(frame, f, transformation_ctx="", info="", stageThreshold=0, totalThreshold=0))
指定された述語関数を満たす入力 DynamicFrame からのレコードを選択することにより構築された新しい DynamicFrame を返します。
frame– 指定されたフィルタ関数を適用する先のソースDynamicFrame(必須)。-
f–DynamicFrameのそれぞれのDynamicRecordに適用する述語関数。この関数は、引数としてDynamicRecordを取り、DynamicRecordがフィルタリングの要件を満たす場合は True を返し、そうでない場合は False を返す必要があります (必須)。DynamicRecordはDynamicFrame内の論理レコードを表します。これは、自己記述型であり、固定スキーマに準拠しないデータに使用できる点を除いて、SparkDataFrameの行に似ています。 transformation_ctx- 状態情報を識別するために使用される一意の文字列 (オプション)。info- 変換のエラーに関連付けられた文字列 (オプション)。stageThreshold– エラーを出力する前に、変換で発生する可能性のあるエラーの最大数 (オプション)。デフォルト値は 0 です。totalThreshold– エラーの出力を処理する前に、全体で発生する可能性のあるエラーの最大数 (オプション)。デフォルト値は 0 です。
apply(cls, *args, **kwargs)
継承元は GlueTransform 適用。
name(cls)
継承元は GlueTransform 名前。
describeArgs(cls)
継承元は GlueTransform describeArgs。
describeReturn(cls)
継承元は GlueTransform describeReturn。
describeTransform(cls)
継承元は GlueTransform describeTransform。
describeErrors(cls)
継承元は GlueTransform describeErrors。
describe(cls)
継承元は GlueTransform 説明。