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

Class ThrottlingSignaler

java.lang.Object

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

public class ThrottlingSignaler
extends Object

The ThrottlingSignaler is a utility class for IOs to signal to the runner that a process is being throttled, preventing autoscaling. This is primarily used when making calls to a remote service where quotas and rate limiting are reasonable considerations.

Constructor Summary

Constructors

Constructor	Description
ThrottlingSignaler()
ThrottlingSignaler(String namespace)

Method Summary

Modifier and Type	Method	Description
void	signalThrottling(long milliseconds)	Signal that a transform has been throttled for an amount of time represented in milliseconds.

Methods inherited from class java.lang.Object

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

Constructor Details

ThrottlingSignaler

public ThrottlingSignaler(String namespace)

ThrottlingSignaler

public ThrottlingSignaler()

Method Details

signalThrottling

public void signalThrottling(long milliseconds)

Signal that a transform has been throttled for an amount of time represented in milliseconds.