org.apache.beam.sdk.io.kinesis

Interface RateLimitPolicyFactory

All Superinterfaces:

java.io.Serializable

public interface RateLimitPolicyFactory
extends java.io.Serializable

Implement this interface to create a RateLimitPolicy. Used to create a rate limiter for each shard. The factory will be called from multiple threads, so if it returns a singleton instance of RateLimitPolicy then that instance should be thread-safe, otherwise it should return separate RateLimitPolicy instances.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	RateLimitPolicyFactory.DelayIntervalRateLimiter

Method Summary

Modifier and Type	Method and Description
RateLimitPolicy	getRateLimitPolicy()
static RateLimitPolicyFactory	withDelay(java.util.function.Supplier<Duration> delay)
static RateLimitPolicyFactory	withFixedDelay()
static RateLimitPolicyFactory	withFixedDelay(Duration delay)
static RateLimitPolicyFactory	withoutLimiter()

Method Detail

getRateLimitPolicy

RateLimitPolicy getRateLimitPolicy()

withoutLimiter

static RateLimitPolicyFactory withoutLimiter()

withFixedDelay

static RateLimitPolicyFactory withFixedDelay()

withFixedDelay

static RateLimitPolicyFactory withFixedDelay(Duration delay)

withDelay

static RateLimitPolicyFactory withDelay(java.util.function.Supplier<Duration> delay)