Package org.apache.beam.sdk.io.jms

Class DefaultAutoscaler

  • All Implemented Interfaces:
    java.io.Serializable, AutoScaler
    public class DefaultAutoscaler
extends java.lang.Object
implements AutoScaler
    Default implementation of AutoScaler. Returns UnboundedSource.UnboundedReader.BACKLOG_UNKNOWN as the default value.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getTotalBacklogBytes()
      Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.
      void start()
      The AutoScaler is started when the JmsIO.UnboundedJmsReader is started.
      void stop()
      The AutoScaler is stopped when the JmsIO.UnboundedJmsReader is closed.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • DefaultAutoscaler

        public DefaultAutoscaler()

    • Method Detail

      • start

        public void start()
        Description copied from interface: AutoScaler
        The AutoScaler is started when the JmsIO.UnboundedJmsReader is started.
        Specified by:
        start in interface AutoScaler

      • getTotalBacklogBytes

        public long getTotalBacklogBytes()
        Description copied from interface: AutoScaler
        Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.
        Specified by:
        getTotalBacklogBytes in interface AutoScaler

      • stop

        public void stop()
        Description copied from interface: AutoScaler
        The AutoScaler is stopped when the JmsIO.UnboundedJmsReader is closed.
        Specified by:
        stop in interface AutoScaler