Index (components 2.74.0 API)

A

addDescriptor(String, String) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
allow(int) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiter
allow(int) - Method in interface org.apache.beam.sdk.io.components.ratelimiter.RateLimiter: Blocks until the specified number of permits are acquired and returns true if the request was allowed or false if the request was rejected.
allow(RateLimiterContext, int) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterFactory
allow(RateLimiterContext, int) - Method in interface org.apache.beam.sdk.io.components.ratelimiter.RateLimiterFactory: Blocks until the specified number of permits are acquired and returns true if the request was allowed or false if the request was rejected.

build() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
build() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions.Builder
builder() - Static method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext
builder() - Static method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions
Builder() - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions.Builder

close() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiter
close() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterFactory

descriptorsBuilder() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
DLQRouter<T,K> - Class in org.apache.beam.sdk.io.components.deadletterqueue
DLQRouter(TupleTag<T>, TupleTag<K>, PTransform<PCollection<K>, ?>) - Constructor for class org.apache.beam.sdk.io.components.deadletterqueue.DLQRouter

EnvoyRateLimiter - Class in org.apache.beam.sdk.io.components.ratelimiter: A lightweight handle for an Envoy-based rate limiter.
EnvoyRateLimiter(EnvoyRateLimiterFactory, EnvoyRateLimiterContext) - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiter
EnvoyRateLimiterContext - Class in org.apache.beam.sdk.io.components.ratelimiter: Context for an Envoy Rate Limiter call.
EnvoyRateLimiterContext() - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext
EnvoyRateLimiterContext.Builder - Class in org.apache.beam.sdk.io.components.ratelimiter
EnvoyRateLimiterFactory - Class in org.apache.beam.sdk.io.components.ratelimiter: A RateLimiterFactory for Envoy Rate Limit Service.
EnvoyRateLimiterFactory(RateLimiterOptions) - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterFactory
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink
expand(PCollectionTuple) - Method in class org.apache.beam.sdk.io.components.deadletterqueue.DLQRouter

getAddress() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions
getChannel() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterClientCache
getDescriptors() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext
getDomain() - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext
getLimiter(RateLimiterContext) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterFactory
getLimiter(RateLimiterContext) - Method in interface org.apache.beam.sdk.io.components.ratelimiter.RateLimiterFactory: Creates a lightweight ratelimiter handle bound to a specific context.
getMaxRetries() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions
getOrCreate(String) - Static method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterClientCache: Gets or creates a cached client for the given address.
getTimeout() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions

org.apache.beam.sdk.io.components.deadletterqueue - package org.apache.beam.sdk.io.components.deadletterqueue: Defines Dead Letter Queue (DLQ) routers for Beam IO components.
org.apache.beam.sdk.io.components.deadletterqueue.sinks - package org.apache.beam.sdk.io.components.deadletterqueue.sinks: Defines sinks for Dead Letter Queue (DLQ) implementations.
org.apache.beam.sdk.io.components.ratelimiter - package org.apache.beam.sdk.io.components.ratelimiter: Defines ratelimiter utilities for Beam DoFn and IO components.
org.apache.beam.sdk.io.components.throttling - package org.apache.beam.sdk.io.components.throttling: Defines Throttling utilities for Beam IO components.

processElement(T) - Method in class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink.ThrowingDoFn

RateLimiter - Interface in org.apache.beam.sdk.io.components.ratelimiter: A RateLimiter allows to fetch permits from a rate limiter service and blocks execution when the rate limit is exceeded.
RateLimiterClientCache - Class in org.apache.beam.sdk.io.components.ratelimiter: A static cache for ManagedChannels to Rate Limit Service.
RateLimiterContext - Interface in org.apache.beam.sdk.io.components.ratelimiter: A marker interface for context data required to check ratelimit.
RateLimiterFactory - Interface in org.apache.beam.sdk.io.components.ratelimiter: A factory that manages connections to rate limit service and creates lightweight handles.
RateLimiterOptions - Class in org.apache.beam.sdk.io.components.ratelimiter: Configuration options for RateLimiterFactory.
RateLimiterOptions() - Constructor for class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions
RateLimiterOptions.Builder - Class in org.apache.beam.sdk.io.components.ratelimiter
release() - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterClientCache: Releases the client.

setAddress(String) - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions.Builder
setDescriptors(Map<String, String>) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
setDomain(String) - Method in class org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiterContext.Builder
setMaxRetries(Integer) - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions.Builder
setTimeout(Duration) - Method in class org.apache.beam.sdk.io.components.ratelimiter.RateLimiterOptions.Builder
signalThrottling(long) - Method in class org.apache.beam.sdk.io.components.throttling.ThrottlingSignaler: Signal that a transform has been throttled for an amount of time represented in milliseconds.

ThrottlingSignaler - Class in org.apache.beam.sdk.io.components.throttling: The ThrottlingSignaler is a utility class for IOs to signal to the runner that a process is being throttled, preventing autoscaling.
ThrottlingSignaler() - Constructor for class org.apache.beam.sdk.io.components.throttling.ThrottlingSignaler
ThrottlingSignaler(String) - Constructor for class org.apache.beam.sdk.io.components.throttling.ThrottlingSignaler
ThrowingDoFn() - Constructor for class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink.ThrowingDoFn
ThrowingSink<T> - Class in org.apache.beam.sdk.io.components.deadletterqueue.sinks
ThrowingSink() - Constructor for class org.apache.beam.sdk.io.components.deadletterqueue.sinks.ThrowingSink
ThrowingSink.ThrowingDoFn - Class in org.apache.beam.sdk.io.components.deadletterqueue.sinks