apache_beam.ml.anomaly package

Subpackages

• apache_beam.ml.anomaly.detectors package
  • Submodules
    • apache_beam.ml.anomaly.detectors.iqr module
      • IQR
    • apache_beam.ml.anomaly.detectors.offline module
      • OfflineDetector
    • apache_beam.ml.anomaly.detectors.pyod_adapter module
    • apache_beam.ml.anomaly.detectors.robust_zscore module
      • RobustZScore
    • apache_beam.ml.anomaly.detectors.zscore module
      • ZScore
• apache_beam.ml.anomaly.univariate package
  • Submodules
    • apache_beam.ml.anomaly.univariate.base module
      • BaseTracker
      • WindowMode
      • WindowedTracker
    • apache_beam.ml.anomaly.univariate.mad module
      • MadTracker
    • apache_beam.ml.anomaly.univariate.mean module
      • MeanTracker
      • SimpleSlidingMeanTracker
      • IncMeanTracker
      • IncLandmarkMeanTracker
      • IncSlidingMeanTracker
    • apache_beam.ml.anomaly.univariate.median module
      • MedianTracker
    • apache_beam.ml.anomaly.univariate.quantile module
      • QuantileTracker
      • SimpleSlidingQuantileTracker
      • BufferedQuantileTracker
      • SecondaryBufferedQuantileTracker
      • BufferedLandmarkQuantileTracker
      • BufferedSlidingQuantileTracker
    • apache_beam.ml.anomaly.univariate.stdev module
      • StdevTracker
      • SimpleSlidingStdevTracker
      • IncStdevTracker
      • IncLandmarkStdevTracker
      • IncSlidingStdevTracker

Submodules

• apache_beam.ml.anomaly.aggregations module
  • LabelAggregation
    • LabelAggregation.apply()
  • ScoreAggregation
    • ScoreAggregation.apply()
  • MajorityVote
    • MajorityVote.MajorityVote__spec_type
    • MajorityVote.from_spec()
    • MajorityVote.run_original_init()
    • MajorityVote.spec_type()
    • MajorityVote.to_spec()
    • MajorityVote.unspecifiable()
  • AllVote
    • AllVote.AllVote__spec_type
    • AllVote.from_spec()
    • AllVote.run_original_init()
    • AllVote.spec_type()
    • AllVote.to_spec()
    • AllVote.unspecifiable()
  • AnyVote
    • AnyVote.AnyVote__spec_type
    • AnyVote.from_spec()
    • AnyVote.run_original_init()
    • AnyVote.spec_type()
    • AnyVote.to_spec()
    • AnyVote.unspecifiable()
  • AverageScore
    • AverageScore.AverageScore__spec_type
    • AverageScore.from_spec()
    • AverageScore.run_original_init()
    • AverageScore.spec_type()
    • AverageScore.to_spec()
    • AverageScore.unspecifiable()
  • MaxScore
    • MaxScore.MaxScore__spec_type
    • MaxScore.from_spec()
    • MaxScore.run_original_init()
    • MaxScore.spec_type()
    • MaxScore.to_spec()
    • MaxScore.unspecifiable()
• apache_beam.ml.anomaly.base module
  • AnomalyPrediction
    • AnomalyPrediction.model_id
    • AnomalyPrediction.score
    • AnomalyPrediction.label
    • AnomalyPrediction.threshold
    • AnomalyPrediction.info
    • AnomalyPrediction.source_predictions
  • AnomalyResult
    • AnomalyResult.example
    • AnomalyResult.predictions
  • ThresholdFn
    • ThresholdFn.is_stateful
    • ThresholdFn.threshold
    • ThresholdFn.apply()
  • AggregationFn
    • AggregationFn.apply()
  • AnomalyDetector
    • AnomalyDetector.learn_one()
    • AnomalyDetector.score_one()
  • EnsembleAnomalyDetector
    • EnsembleAnomalyDetector.learn_one()
    • EnsembleAnomalyDetector.score_one()
• apache_beam.ml.anomaly.specifiable module
  • Spec
    • Spec.type
    • Spec.config
  • Specifiable
    • Specifiable.spec_type()
    • Specifiable.from_spec()
    • Specifiable.to_spec()
    • Specifiable.run_original_init()
    • Specifiable.unspecifiable()
  • specifiable()
• apache_beam.ml.anomaly.thresholds module
  • FixedThreshold
    • FixedThreshold.is_stateful
    • FixedThreshold.threshold
    • FixedThreshold.apply()
    • FixedThreshold.FixedThreshold__spec_type
    • FixedThreshold.from_spec()
    • FixedThreshold.run_original_init()
    • FixedThreshold.spec_type()
    • FixedThreshold.to_spec()
    • FixedThreshold.unspecifiable()
  • QuantileThreshold
    • QuantileThreshold.is_stateful
    • QuantileThreshold.threshold
    • QuantileThreshold.QuantileThreshold__spec_type
    • QuantileThreshold.apply()
    • QuantileThreshold.from_spec()
    • QuantileThreshold.run_original_init()
    • QuantileThreshold.spec_type()
    • QuantileThreshold.to_spec()
    • QuantileThreshold.unspecifiable()
• apache_beam.ml.anomaly.transforms module
  • RunScoreAndLearn
    • RunScoreAndLearn.expand()
  • RunThresholdCriterion
    • RunThresholdCriterion.expand()
  • RunAggregationStrategy
    • RunAggregationStrategy.expand()
  • RunOneDetector
    • RunOneDetector.expand()
  • RunOfflineDetector
    • RunOfflineDetector.expand()
  • RunEnsembleDetector
    • RunEnsembleDetector.expand()
  • AnomalyDetection
    • AnomalyDetection.expand()