com.mozilla.secops.postprocessing

Class PostProcessing.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.postprocessing.PostProcessing.Parse

All Implemented Interfaces:

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

Enclosing class:

PostProcessing

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

Parse incoming events and filter to only include events of type Alert

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Parse(PostProcessing.PostProcessingOptions options) Static initializer for PostProcessing.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(PostProcessing.PostProcessingOptions options)

Static initializer for PostProcessing.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>>