com.mozilla.secops.input

Class Input.SimplexReader

java.lang.Object

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

com.mozilla.secops.input.Input.SimplexReader

All Implemented Interfaces:

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

Enclosing class:

Input

public static class Input.SimplexReader
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<Event>>

Read raw events from configured sources, combining all events into a single output collection as Event objects

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SimplexReader(Input input) Create new SimplexReader

Method Summary

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

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

SimplexReader

public SimplexReader(Input input)

Create new SimplexReader

Parameters:

input - Prepared Input object

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<Event> expand(org.apache.beam.sdk.values.PBegin begin)

Specified by:

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