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

Class ThrottlingSignaler

  • public class ThrottlingSignaler
extends java.lang.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.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • ThrottlingSignaler

        public ThrottlingSignaler​(java.lang.String namespace)

      • ThrottlingSignaler

        public ThrottlingSignaler()

    • Method Detail

      • signalThrottling

        public void signalThrottling​(long milliseconds)
        Signal that a transform has been throttled for an amount of time represented in milliseconds.