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

Interface AutoScaler

All Superinterfaces:
Serializable
All Known Implementing Classes:
DefaultAutoscaler
public interface AutoScaler extends Serializable
Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader.getTotalBacklogBytes().

  • Method Summary

    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.

  • Method Details

    • start

      void start()
      The AutoScaler is started when the JmsIO.UnboundedJmsReader is started.

    • getTotalBacklogBytes

      long getTotalBacklogBytes()
      Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.

    • stop

      void stop()
      The AutoScaler is stopped when the JmsIO.UnboundedJmsReader is closed.