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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MovingAvg()

Method Summary

Modifier and Type	Method and 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 Detail

MovingAvg

public MovingAvg()

Method Detail

update

public void update(double quantity)

get

public double get()