フィルタクラス

指定された述語関数を満たす、入力 DynamicFrame からのレコードが含まれた新しい DynamicFrame を構築します。

例

DynamicFrame.filter() メソッドを使用して、DynamicFrame のレコードをフィルタリングすることをお勧めします。コード例については、「例: フィルターを使用して、フィールドのフィルタリングされた選択内容を取得する」を参照してください。

方法

• __call__

• apply

• 名前

• describeArgs

• describeReturn

• describeTransform

• describeErrors

• 説明

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

指定された述語関数を満たす入力 DynamicFrame からのレコードを選択することにより構築された新しい DynamicFrame を返します。

• frame – 指定されたフィルタ関数を適用する先のソース DynamicFrame (必須)。

• f – DynamicFrame のそれぞれの DynamicRecord に適用する述語関数。この関数は、引数として DynamicRecord を取り、DynamicRecord がフィルタリングの要件を満たす場合は True を返し、そうでない場合は False を返す必要があります (必須)。

  DynamicRecord は DynamicFrame 内の論理レコードを表します。これは、自己記述型であり、固定スキーマに準拠しないデータに使用できる点を除いて、Spark DataFrame の行に似ています。

• transformation_ctx - 状態情報を識別するために使用される一意の文字列 (オプション)。

• info - 変換のエラーに関連付けられた文字列 (オプション)。

• stageThreshold – エラーを出力する前に、変換で発生する可能性のあるエラーの最大数 (オプション)。デフォルト値は 0 です。

• totalThreshold – エラーの出力を処理する前に、全体で発生する可能性のあるエラーの最大数 (オプション)。デフォルト値は 0 です。

apply(cls, *args, **kwargs)

継承元は GlueTransform apply。

name(cls)

継承元は GlueTransform 名前。

describeArgs(cls)

継承元は GlueTransform describeArgs。

describeReturn(cls)

継承元は GlueTransform describeReturn。

describeTransform(cls)

継承元は GlueTransform describeTransform。

describeErrors(cls)

継承元は GlueTransform describeErrors。

describe(cls)

継承元は GlueTransform 説明。