com.mozilla.secops.httprequest

Class HTTPRequest.KeyAndWindowForSessionsFireEarly

java.lang.Object

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

com.mozilla.secops.httprequest.HTTPRequest.KeyAndWindowForSessionsFireEarly

All Implemented Interfaces:

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

Enclosing class:

HTTPRequest

public static class HTTPRequest.KeyAndWindowForSessionsFireEarly
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>>>

Key requests for session analysis and window into sessions

Windows are configured to fire early every 10 seconds, and accumulate panes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyAndWindowForSessionsFireEarly(Long gapDurationMinutes)

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>>	expand(org.apache.beam.sdk.values.PCollection<Event> input)

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

KeyAndWindowForSessionsFireEarly

public KeyAndWindowForSessionsFireEarly(Long gapDurationMinutes)

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>> expand(org.apache.beam.sdk.values.PCollection<Event> input)

Specified by:

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