データ接続と統合Pipeline Builder ExpressionsMax by

注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。

Max by

対応環境: ストリーミング

この式は、指定されたフィルター処理仕様を適用した後、最大列式に従って最大の行を計算します。最大の行が存在しない場合、null が返されます。

式カテゴリ: 集計

引数

  • - 最大値が計算される列式。null 値は最小値として扱われます。
    Expression<ComparableType>
  • 出力プロジェクション式 - 最大の行に適用されるプロジェクション式を定義します。
    Expression<AnyType>
  • 任意 フィルター条件 - このパラメーターは、ウィンドウ内に含まれる行に適用されるフィルター処理仕様を定義します。この式の出力は、このパラメーターでフィルター処理されない行(つまり、条件が true と評価される行)のみを参照します。トリガー時に状態に行が存在しない場合、null が出力されます。
    Expression<Boolean>

出力型: AnyType

例 1: 基本ケース

引数の値:

  • : salary
  • 出力プロジェクション式: salary
  • フィルター条件:
    lessThan(
     left: salary,
     right: 5000,
    )

入力テーブル:

dep_namesalary
develop9900
develop4000
develop3000

出力: 4000


例 2: 基本ケース

引数の値:

  • : salary
  • 出力プロジェクション式: salary
  • フィルター条件: null

入力テーブル:

dep_namesalary
develop1000
developnull
develop4000

出力: 4000