Package org.apache.storm.utils

Class WindowedTimeThrottler

java.lang.Object

org.apache.storm.utils.WindowedTimeThrottler

public class WindowedTimeThrottler
extends Object

Constructor Summary

Constructors

Constructor	Description
WindowedTimeThrottler(Number windowMillis, Number maxAmt)

Method Summary

Modifier and Type	Method	Description
boolean	isThrottled()
void	markEvent()

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowedTimeThrottler

public WindowedTimeThrottler(Number windowMillis,
                             Number maxAmt)

Method Detail

isThrottled

public boolean isThrottled()

markEvent

public void markEvent()