com.mozilla.secops.authprofile

Class AuthProfile.Parse

java.lang.Object

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

com.mozilla.secops.authprofile.AuthProfile.Parse

All Implemented Interfaces:

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

Enclosing class:

AuthProfile

public static class AuthProfile.Parse
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PCollection<Event>>

Parse input strings returning applicable authentication events.

Events which are not of type Normalized.Type.AUTH or Normalized.Type.AUTH_SESSION are not returned in the resulting PCollection.

This transform also filters events associated with ignored or inapplicable users from the result set.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Parse(AuthProfile.AuthProfileOptions options) Static initializer for AuthProfile.Parse using specified pipeline options

Method Summary

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

Parse

public Parse(AuthProfile.AuthProfileOptions options)

Static initializer for AuthProfile.Parse using specified pipeline options

Parameters:

options - Pipeline options

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<Event> expand(org.apache.beam.sdk.values.PCollection<String> col)

Specified by:

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