com.mozilla.secops.customs

Class CustomsFeaturesCombiner.CustomsFeaturesCombineFn

java.lang.Object

org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

com.mozilla.secops.customs.CustomsFeaturesCombiner.CustomsFeaturesCombineFn

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<Event,CustomsFeatures,CustomsFeatures>, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

CustomsFeaturesCombiner

public static class CustomsFeaturesCombiner.CustomsFeaturesCombineFn
extends org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

Combine.CombineFn for creating collections of CustomsFeatures

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CustomsFeaturesCombineFn()

Method Summary

Modifier and Type	Method and Description
CustomsFeatures	addInput(CustomsFeatures col, Event input)
CustomsFeatures	createAccumulator()
CustomsFeatures	defaultValue()
CustomsFeatures	extractOutput(CustomsFeatures col)
CustomsFeatures	mergeAccumulators(Iterable<CustomsFeatures> cols)

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

Constructor Detail

CustomsFeaturesCombineFn

public CustomsFeaturesCombineFn()

Method Detail

createAccumulator

public CustomsFeatures createAccumulator()

Specified by:

createAccumulator in class org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

addInput

public CustomsFeatures addInput(CustomsFeatures col,
                                Event input)

Specified by:

addInput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

mergeAccumulators

public CustomsFeatures mergeAccumulators(Iterable<CustomsFeatures> cols)

Specified by:

mergeAccumulators in class org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

extractOutput

public CustomsFeatures extractOutput(CustomsFeatures col)

Specified by:

extractOutput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>

defaultValue

public CustomsFeatures defaultValue()

Specified by:

defaultValue in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<Event,CustomsFeatures,CustomsFeatures>

Overrides:

defaultValue in class org.apache.beam.sdk.transforms.Combine.CombineFn<Event,CustomsFeatures,CustomsFeatures>