com.mozilla.secops.gatekeeper

Class GatekeeperParser.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.gatekeeper.GatekeeperParser.Parse

All Implemented Interfaces:

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

Enclosing class:

GatekeeperParser

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

Composite transform to parse a PCollection containing events as strings and emit a PCollection of Event objects.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Parse(GatekeeperPipeline.GatekeeperOptions options) Static initializer for GatekeeperParser.Parse transform

Method Summary

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

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(GatekeeperPipeline.GatekeeperOptions options)

Static initializer for GatekeeperParser.Parse transform

Parameters:

options - Pipeline options

Method Detail

expand

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

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