com.mozilla.secops

Class Stats.StatsCombiner

java.lang.Object

org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

com.mozilla.secops.Stats.StatsCombiner

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

Stats

public static class Stats.StatsCombiner
extends org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

Combine.CombineFn for performing statistics operations on a collection of values

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
com.mozilla.secops.Stats.StatsCombiner.State	addInput(com.mozilla.secops.Stats.StatsCombiner.State state, Long input)
com.mozilla.secops.Stats.StatsCombiner.State	createAccumulator()
Stats.StatsOutput	defaultValue()
Stats.StatsOutput	extractOutput(com.mozilla.secops.Stats.StatsCombiner.State state)
com.mozilla.secops.Stats.StatsCombiner.State	mergeAccumulators(Iterable<com.mozilla.secops.Stats.StatsCombiner.State> states)

Methods inherited from class org.apache.beam.sdk.transforms.Combine.CombineFn

apply, compact, getInputType, getOutputType

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createAccumulator

public com.mozilla.secops.Stats.StatsCombiner.State createAccumulator()

Specified by:

createAccumulator in class org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

addInput

public com.mozilla.secops.Stats.StatsCombiner.State addInput(com.mozilla.secops.Stats.StatsCombiner.State state,
                                                             Long input)

Specified by:

addInput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

mergeAccumulators

public com.mozilla.secops.Stats.StatsCombiner.State mergeAccumulators(Iterable<com.mozilla.secops.Stats.StatsCombiner.State> states)

Specified by:

mergeAccumulators in class org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

extractOutput

public Stats.StatsOutput extractOutput(com.mozilla.secops.Stats.StatsCombiner.State state)

Specified by:

extractOutput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

defaultValue

public Stats.StatsOutput defaultValue()

Specified by:

defaultValue in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>

Overrides:

defaultValue in class org.apache.beam.sdk.transforms.Combine.CombineFn<Long,com.mozilla.secops.Stats.StatsCombiner.State,Stats.StatsOutput>