[AnomalyDetection] Add main and auxiliary transforms.

[shunping]

• Add transforms for anomaly detection

Depends on #34232

[github-actions]

Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment assign set of reviewers

[shunping]

r: @damccorm

[github-actions]

Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control. If you'd like to restart, comment assign set of reviewers

[codecov]

Codecov Report

Attention: Patch coverage is 95.68966% with 5 lines in your changes missing coverage. Please review.

Project coverage is 56.35%. Comparing base (dfc45f0) to head (2ee0393).
Report is 18 commits behind head on master.

Files with missing lines	Patch %	Lines
sdks/python/apache_beam/ml/anomaly/transforms.py	95.68%	5 Missing ⚠️

Additional details and impacted files

@@             Coverage Diff              @@
##             master   #34234      +/-   ##
============================================
+ Coverage     56.28%   56.35%   +0.06%     
  Complexity     3286     3286              
============================================
  Files          1166     1173       +7     
  Lines        178678   179057     +379     
  Branches       3398     3398              
============================================
+ Hits         100575   100910     +335     
- Misses        74850    74894      +44     
  Partials       3253     3253              

Flag	Coverage Δ
python	81.32% <95.68%> (+0.03%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
• 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

[damccorm]

Not a suggestion for this PR, but this would likely benefit from batching so that we don't have to do state reads/writes for every element (we could just do one per batch)

[shunping]

Right, though I think in the implementation states will be cached and they are not committed to the backend per element.

[damccorm]

That's true - IIRC they are written when we commit, though (when we finish a bundle), which in streaming could be relatively frequently - a group into batches across bundles might help.

Regardless, that is something we can try/tune down the line and not something which needs to come right now

[shunping]

Run Python_Coverage PreCommit

[shunping]

Run Prism_Python PreCommit 3.12

[damccorm]

Thanks

[damccorm]

I'll merge once checks pass