com.mozilla.secops.metrics

Class CfgTickGenerator

java.lang.Object

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

com.mozilla.secops.metrics.CfgTickGenerator

All Implemented Interfaces:

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

public class CfgTickGenerator
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<String>>

Generate periodic configuration ticks

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CfgTickGenerator(String message, Integer interval, long maxNumRecords) Initialize new CfgTickGenerator

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<String>	expand(org.apache.beam.sdk.values.PBegin begin)

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

CfgTickGenerator

public CfgTickGenerator(String message,
                        Integer interval,
                        long maxNumRecords)

Initialize new CfgTickGenerator

The source for this transform is unbounded. The maxNumRecords parameter is intended to place an upper limit on the number of records generated for testing purposes; under normal circumstances this parameter should be set to -1.

Parameters:

message - Message to emit

interval - Seconds between emissions

maxNumRecords - Only generate specified number of records and stop

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<String> expand(org.apache.beam.sdk.values.PBegin begin)

Specified by:

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