com.mozilla.secops.awsbehavior

Class AwsBehavior.Matcher

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.awsbehavior.AwsBehavior.Matcher

All Implemented Interfaces:

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

Enclosing class:

AwsBehavior

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

Tranform to take a specific CloudtrailMatcher and a PCollection of cloudtrail events and emit a PCollection of Alert objects constructed for each event that matches the CloudtrailMatcher

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Matcher(CloudtrailMatcher cm) Initialize new Matcher with a CloudtrailMatcher

Method Summary

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

Matcher

public Matcher(CloudtrailMatcher cm)

Initialize new Matcher with a CloudtrailMatcher

Parameters:

cm - CloudtrailMatcher

Method Detail

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