com.mozilla.secops.customs

Class CustomsPasswordResetAbuse

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>>,org.apache.beam.sdk.values.PCollection<Alert>>

com.mozilla.secops.customs.CustomsPasswordResetAbuse

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

public class CustomsPasswordResetAbuse
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>>,org.apache.beam.sdk.values.PCollection<Alert>>

Abuse of FxA password reset endpoints from a single source address

Assumed to operate on fixed 10 minute windows.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXPERIMENTAL_TAG

Constructor Summary

Constructors

Constructor and Description
CustomsPasswordResetAbuse(Customs.CustomsOptions options) Initialize new CustomsPasswordResetAbuse

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Alert>	expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col)
default String	getTransformDoc() Get documentation string from transform based on it's current configuration
String	getTransformDocDescription() Get documentation description from transform based on it's current configuration
boolean	isExperimental() Get whether the transform is experimental and won't be escalated

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

EXPERIMENTAL_TAG

public static final String EXPERIMENTAL_TAG

See Also:

Constant Field Values

Constructor Detail

CustomsPasswordResetAbuse

public CustomsPasswordResetAbuse(Customs.CustomsOptions options)

Initialize new CustomsPasswordResetAbuse

Parameters:

options - Pipeline options

Method Detail

getTransformDocDescription

public String getTransformDocDescription()

Get documentation description from transform based on it's current configuration

Returns:

String

expand

public org.apache.beam.sdk.values.PCollection<Alert> expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>> col)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,CustomsFeatures>>,org.apache.beam.sdk.values.PCollection<Alert>>

isExperimental

public boolean isExperimental()

Get whether the transform is experimental and won't be escalated

Returns:

String

getTransformDoc

public String getTransformDoc()

Description copied from interface: DocumentingTransform

Get documentation string from transform based on it's current configuration

Specified by:

getTransformDoc in interface DocumentingTransform

Returns:

String