org.apache.beam.sdk.io.jms

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

Modifier and Type	Method and 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.