com.mozilla.secops.customs

Class CustomsStatusComparator

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.CustomsStatusComparator

All Implemented Interfaces:

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

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

Customs status check comparator

Requires Datastore for state.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXPERIMENTAL_TAG

Constructor Summary

Constructors

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

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

EXPERIMENTAL_TAG

public static final String EXPERIMENTAL_TAG

See Also:

Constant Field Values

Constructor Detail

CustomsStatusComparator

public CustomsStatusComparator(Customs.CustomsOptions options)

Initialize new CustomsStatusComparator

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