Package org.apache.beam.sdk.io.jms
Interface AutoScaler
-
- All Superinterfaces:
java.io.Serializable
- All Known Implementing Classes:
DefaultAutoscaler
public interface AutoScaler extends java.io.SerializableEnables users to specify their own `JMS` backlog reporters enablingJmsIOto reportUnboundedSource.UnboundedReader.getTotalBacklogBytes().
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longgetTotalBacklogBytes()Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.voidstart()TheAutoScaleris started when theJmsIO.UnboundedJmsReaderis started.voidstop()TheAutoScaleris stopped when theJmsIO.UnboundedJmsReaderis closed.
-
-
-
Method Detail
-
start
void start()
TheAutoScaleris started when theJmsIO.UnboundedJmsReaderis 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()
TheAutoScaleris stopped when theJmsIO.UnboundedJmsReaderis closed.
-
-