Package org.voltdb.stream.api.util

Class RateLimitedSourceConfigurator<T>

java.lang.Object

org.voltdb.stream.api.util.RateLimitedSourceConfigurator<T>

All Implemented Interfaces:

OperatorConfigurator, VoltStreamSourceConfigurator<T>

public class RateLimitedSourceConfigurator<T>
extends Object
implements VoltStreamSourceConfigurator<T>

Constructor Summary

Constructors

Constructor	Description
RateLimitedSourceConfigurator()

Method Summary

Modifier and Type	Method	Description
RateLimitedSourceConfigurator<T>	atRate(double tps)
Supplier<T>	getSupplier()
double	getTps()
RateLimitedSourceConfigurator<T>	supplying(Supplier<T> supplier)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.voltdb.stream.api.extension.OperatorConfigurator

configure, getConfiguration

Constructor Details

RateLimitedSourceConfigurator

public RateLimitedSourceConfigurator()

Method Details

supplying

public RateLimitedSourceConfigurator<T> supplying(Supplier<T> supplier)

atRate

public RateLimitedSourceConfigurator<T> atRate(double tps)

getSupplier

public Supplier<T> getSupplier()

getTps

public double getTps()