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

package org.apache.beam.sdk.io.components.throttling

Defines Throttling utilities for Beam IO components.

Classes

Class	Description
AdaptiveThrottler	Implements adaptive throttling.
ReactiveThrottler	A wrapper around the AdaptiveThrottler that also handles logging and signaling throttling to the SDK harness using the provided namespace.
ThrottlingSignaler	The ThrottlingSignaler is a utility class for IOs to signal to the runner that a process is being throttled, preventing autoscaling.