Interface AutoScaler

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    DefaultAutoscaler

    public interface AutoScaler
    extends java.io.Serializable
    Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader.getTotalBacklogBytes().
    • Method Summary

      All Methods Instance Methods Abstract 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.
    • Method Detail

      • 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.