com.mozilla.secops.input

Class Input.MultiplexReaderRaw

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

com.mozilla.secops.input.Input.MultiplexReaderRaw

All Implemented Interfaces:

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

Enclosing class:

Input

public static class Input.MultiplexReaderRaw
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,String>>>

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultiplexReaderRaw(Input input) Create new MultiplexReaderRaw

Method Summary

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

MultiplexReaderRaw

public MultiplexReaderRaw(Input input)

Create new MultiplexReaderRaw

Parameters:

input - Prepared Input object

Method Detail

expand

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