Package org.apache.beam.sdk.io.kafka

Class KafkaIOUtils.MovingAvg

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaIOUtils.MovingAvg

Enclosing class:

KafkaIOUtils

public static final class KafkaIOUtils.MovingAvg
extends Object

Constructor Summary

Constructors

Constructor	Description
MovingAvg()

Method Summary

Modifier and Type	Method	Description
double	get()
void	update(double quantity)

Methods inherited from class java.lang.Object

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

Constructor Details

MovingAvg

public MovingAvg()

Method Details

update

public void update(double quantity)

get

public double get()