com.mozilla.secops.input

Class Input.MultiplexReader

java.lang.Object

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

com.mozilla.secops.input.Input.MultiplexReader

All Implemented Interfaces:

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

Enclosing class:

Input

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

Read raw events from configured sources, returning a key value collection with the key being the element name and the value being a parsed event

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultiplexReader(Input input) Create new MultiplexReader

Method Summary

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

MultiplexReader

public MultiplexReader(Input input)

Create new MultiplexReader

Parameters:

input - Prepared Input object

Method Detail

expand

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