Package | Description |
---|---|
com.mozilla.secops.customs |
Customs FxA analysis pipeline
|
Modifier and Type | Method and Description |
---|---|
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.addInput(CustomsFeatures col,
Event input) |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.createAccumulator() |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.defaultValue() |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.extractOutput(CustomsFeatures col) |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.mergeAccumulators(Iterable<CustomsFeatures> cols) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> |
CustomsFeaturesCombiner.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,Event>> input) |
Modifier and Type | Method and Description |
---|---|
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.addInput(CustomsFeatures col,
Event input) |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.extractOutput(CustomsFeatures col) |
void |
CustomsFeatures.merge(CustomsFeatures cf)
Merge this feature set with another one
|
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<Alert> |
CustomsAccountCreation.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
org.apache.beam.sdk.values.PCollection<Alert> |
CustomsAccountEnumeration.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
org.apache.beam.sdk.values.PCollection<Alert> |
CustomsAccountCreationDist.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
org.apache.beam.sdk.values.PCollection<Alert> |
SourceLoginFailure.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
org.apache.beam.sdk.values.PCollection<Alert> |
CustomsPasswordResetAbuse.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
org.apache.beam.sdk.values.PCollection<Alert> |
SourceLoginFailureDist.expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col) |
CustomsFeatures |
CustomsFeaturesCombiner.CustomsFeaturesCombineFn.mergeAccumulators(Iterable<CustomsFeatures> cols) |
Copyright © 2022. All rights reserved.