com.mozilla.secops.httprequest

Class HTTPRequestElementFilter

java.lang.Object

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

com.mozilla.secops.httprequest.HTTPRequestElementFilter

All Implemented Interfaces:

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

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

Post-input filter for per-element analysis

The primary intent of this transform is perform any pre-analysis filtering of events for a given resource. Currently only network address/cidr filtering is performed here.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HTTPRequestElementFilter(HTTPRequestToggles toggles) Initialize new element filter

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Event>	expand(org.apache.beam.sdk.values.PCollection<Event> col)

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

Constructor Detail

HTTPRequestElementFilter

public HTTPRequestElementFilter(HTTPRequestToggles toggles)

Initialize new element filter

Parameters:

toggles - Per-element toggles

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<Event> 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<Event>>