com.mozilla.secops.input

Class Input.SimplexReaderRaw

java.lang.Object

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

com.mozilla.secops.input.Input.SimplexReaderRaw

All Implemented Interfaces:

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

Enclosing class:

Input

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SimplexReaderRaw(Input input) Create new SimplexReaderRaw

Method Summary

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

SimplexReaderRaw

public SimplexReaderRaw(Input input)

Create new SimplexReaderRaw

Parameters:

input - Prepared Input object

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<String> 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<String>>