com.mozilla.secops

Class Stats

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Long>,org.apache.beam.sdk.values.PCollection<Stats.StatsOutput>>

com.mozilla.secops.Stats

All Implemented Interfaces:

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

public class Stats
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Long>,org.apache.beam.sdk.values.PCollection<Stats.StatsOutput>>

Generic statistics class

Currently only operates on collections of Long values

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Stats.StatsCombiner Combine.CombineFn for performing statistics operations on a collection of values
static class	Stats.StatsOutput Output of statistics transform

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Stats.StatsOutput>	expand(org.apache.beam.sdk.values.PCollection<Long> input)
static org.apache.beam.sdk.values.PCollectionView<Stats.StatsOutput>	getView(org.apache.beam.sdk.values.PCollection<Long> input) Execute the transform returning a PCollectionView suitable for use as a side 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

Method Detail

getView

public static org.apache.beam.sdk.values.PCollectionView<Stats.StatsOutput> getView(org.apache.beam.sdk.values.PCollection<Long> input)

Execute the transform returning a PCollectionView suitable for use as a side input

Parameters:

input - Input data set

Returns:

PCollectionView representing results of analysis

expand

public org.apache.beam.sdk.values.PCollection<Stats.StatsOutput> expand(org.apache.beam.sdk.values.PCollection<Long> input)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Long>,org.apache.beam.sdk.values.PCollection<Stats.StatsOutput>>