feat: implement CONDITIONAL_TRUE_EVENT and CONDITIONAL_CHANGE_EVENT window functions

[sivchari]

概要

Phase 8 の最終機能として、Snowflake 互換の Window Functions CONDITIONAL_TRUE_EVENT と CONDITIONAL_CHANGE_EVENT を実装しました。

変更内容

新規ファイル

• engine/src/functions/window.rs (392 行)
  • CONDITIONAL_TRUE_EVENT: 条件が TRUE のときカウンタをインクリメント
  • CONDITIONAL_CHANGE_EVENT: 値が前の行から変化したときカウンタをインクリメント
  • DataFusion の WindowUDFImpl および PartitionEvaluator トレイトを実装
  • 複数のデータ型に対応 (Int, Float, String, Boolean, Date/Time)

変更ファイル

• engine/src/functions/mod.rs

  • window モジュールの export 追加
  • ドキュメント更新

• engine/src/executor.rs

  • Window UDF の登録 (register_udwf)
  • 統合テスト 2 件追加

技術詳細

DataFusion API 対応

• DataFusion 45 の新しい API に対応
  • PartitionEvaluatorArgs の引数追加
  • WindowUDFFieldArgs の使用
• evaluate_all() メソッドでパーティション全体を一括処理
• supports_bounded_execution() = false で最適なパフォーマンス

機能詳細

CONDITIONAL_TRUE_EVENT

SELECT CONDITIONAL_TRUE_EVENT(active) OVER (ORDER BY id) FROM table;

• boolean 条件が TRUE になるたびにカウンタをインクリメント
• NULL は FALSE として扱う
• カウンタは 0 から開始し、各パーティション内で独立

CONDITIONAL_CHANGE_EVENT

SELECT CONDITIONAL_CHANGE_EVENT(status) OVER (ORDER BY id) FROM table;

• 値が前の行から変化したときにカウンタをインクリメント
• 最初の行は 0 (比較対象なし)
• NULL と非 NULL の間の変化も検出
• 複数のデータ型に対応

テスト結果

テスト種別	件数	結果
Rust ユニットテスト	199	✅ Pass
Server 統合テスト	7	✅ Pass
CI チェック (fmt)	-	✅ Pass
CI チェック (clippy)	-	✅ Pass

追加テスト

• window.rs: 5 ユニットテスト
  • test_conditional_true_event_basic
  • test_conditional_true_event_with_nulls
  • test_conditional_change_event_basic
  • test_conditional_change_event_with_nulls
  • test_conditional_change_event_strings
• executor.rs: 2 統合テスト
  • test_conditional_true_event
  • test_conditional_change_event

Phase 8 完了

Phase 8 の全ての Window Functions が実装完了:

• ✅ FIRST_VALUE / LAST_VALUE (Phase 5 で実装済み)
• ✅ NTH_VALUE (Phase 5 で実装済み)
• ✅ LEAD / LAG (既存実装)
• ✅ NTILE (Phase 5 で実装済み)
• ✅ PERCENT_RANK / CUME_DIST (Phase 8)
• ✅ RATIO_TO_REPORT (Phase 8)
• ✅ CONDITIONAL_TRUE_EVENT (この PR)
• ✅ CONDITIONAL_CHANGE_EVENT (この PR)

チェックリスト

• コンパイル成功
• 全テストパス
• フォーマットチェックパス
• Clippy チェックパス
• ドキュメント更新
• ユニットテスト追加
• 統合テスト追加

関連

• Phase 8 計画: .claude/plans/phase-8-snowflake-emulator.md
• 前回の Phase 8 PR: feat: add Phase 8 extended window functions #24