com.mozilla.secops.customs

Class CustomsLoginFailureForAtRiskAccount

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Alert>>

com.mozilla.secops.customs.CustomsLoginFailureForAtRiskAccount

All Implemented Interfaces:

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

public class CustomsLoginFailureForAtRiskAccount
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Alert>>

Flag failed logins to potentially at risk accounts.

Requires Datastore for state.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATASTORE_KIND Datastore kind used for state
static String	DATASTORE_NAMESPACE Datastore namespace used for state
static String	EXPERIMENTAL_TAG

Constructor Summary

Constructors

Constructor and Description
CustomsLoginFailureForAtRiskAccount(Customs.CustomsOptions options) Create new CustomsLoginFailureForAtRiskAccount

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Alert>	expand(org.apache.beam.sdk.values.PCollection<Event> 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

DATASTORE_NAMESPACE

public static final String DATASTORE_NAMESPACE

Datastore namespace used for state

See Also:

Constant Field Values

DATASTORE_KIND

public static final String DATASTORE_KIND

Datastore kind used for state

See Also:

Constant Field Values

EXPERIMENTAL_TAG

public static final String EXPERIMENTAL_TAG

See Also:

Constant Field Values

Constructor Detail

CustomsLoginFailureForAtRiskAccount

public CustomsLoginFailureForAtRiskAccount(Customs.CustomsOptions options)

Create new CustomsLoginFailureForAtRiskAccount

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<Event> col)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,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