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

Class DefaultAutoscaler

java.lang.Object

org.apache.beam.sdk.io.jms.DefaultAutoscaler

All Implemented Interfaces:

Serializable, AutoScaler

public class DefaultAutoscaler
extends Object
implements AutoScaler

Default implementation of AutoScaler. Returns UnboundedSource.UnboundedReader.BACKLOG_UNKNOWN as the default value.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultAutoscaler()

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.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultAutoscaler

public DefaultAutoscaler()

Method Details

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