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 Details

WindowedTimeThrottler

public WindowedTimeThrottler(Number windowMillis,
 Number maxAmt)

Method Details

isThrottled

public boolean isThrottled()

markEvent

public void markEvent()