Package org.apache.beam.sdk.io.jms
Interface AutoScaler
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
DefaultAutoscaler
Enables users to specify their own `JMS` backlog reporters enabling
JmsIO
to report
UnboundedSource.UnboundedReader.getTotalBacklogBytes()
.-
Method Summary
Modifier and TypeMethodDescriptionlong
Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.void
start()
TheAutoScaler
is started when theJmsIO.UnboundedJmsReader
is started.void
stop()
TheAutoScaler
is stopped when theJmsIO.UnboundedJmsReader
is closed.
-
Method Details
-
start
void start()TheAutoScaler
is started when theJmsIO.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()TheAutoScaler
is stopped when theJmsIO.UnboundedJmsReader
is closed.
-