Package org.apache.beam.sdk.io.components.ratelimiter

Class RateLimiterOptions

java.lang.Object

org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions

All Implemented Interfaces:

java.io.Serializable

@DefaultSchema(org.apache.beam.sdk.schemas.AutoValueSchema.class)
public abstract class RateLimiterOptions
extends java.lang.Object
implements java.io.Serializable

Configuration options for RateLimiterFactory.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RateLimiterOptions.Builder

Constructor Summary

Constructors

Constructor	Description
RateLimiterOptions()

Method Summary

Modifier and Type	Method	Description
static RateLimiterOptions.Builder	builder()
abstract java.lang.String	getAddress()
abstract java.lang.Integer	getMaxRetries()
abstract java.time.Duration	getTimeout()

Methods inherited from class java.lang.Object

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

Constructor Detail

RateLimiterOptions

public RateLimiterOptions()

Method Detail

getAddress

@SchemaFieldDescription("Address of the rate limiter")
public abstract java.lang.String getAddress()

getMaxRetries

@Nullable
@SchemaFieldDescription("Maximum number of retries, defaults to infinite")
public abstract java.lang.Integer getMaxRetries()

getTimeout

@SchemaFieldDescription("Timeout for rate limiter operations, defaults to 5 seconds")
public abstract java.time.Duration getTimeout()

builder

public static RateLimiterOptions.Builder builder()