com.mozilla.secops.window

Class GlobalTriggers<T>

java.lang.Object

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

com.mozilla.secops.window.GlobalTriggers<T>

All Implemented Interfaces:

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

public class GlobalTriggers<T>
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<T>,org.apache.beam.sdk.values.PCollection<T>>

Window input type into global windows, triggering at a specific interval and discarding fired panes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GlobalTriggers(int tseconds) Initialize new GlobalTriggers

Method Summary

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

GlobalTriggers

public GlobalTriggers(int tseconds)

Initialize new GlobalTriggers

Parameters:

tseconds - Trigger every specified seconds

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<T> expand(org.apache.beam.sdk.values.PCollection<T> input)

Specified by:

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