tree df0d1fdc0eaf05ddafa6d7e8a4fee44532c2032b
parent 95c3811312ad41f98dd5ef0674ef30ce30448746
author rvballada <vincent.ballada@renault.com> 1631294948 +0200
committer GitHub <noreply@github.com> 1631294948 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJhO5XkCRBK7hj4Ov3rIwAAQBoIACk0EozOwcNI4kOfeJpu+1kf
 kgKrL/4J1G+qBZj/U0j0WlP6lnN1wUGUTMgQNJSpWYtQlqT88bcl33+SJx6O8xep
 CtsUu3rtxViBJB3dq6U/aZ8oGOI8aLMQ72etMnv6tLwSnki2v3LIJCjB75nQeVT9
 TF95qV/5UcOh6uVzgVWJpybiO+YeE2kCrfRAUNPEu5vwMVGp1OU5fi19945cS/97
 Ktbm6BkYk4dRzgf7l5w3fh9aVOrrwjt+qaCpZvOaLgqDB5Lht0+zaTD4bUrqoUuG
 u2O0igaHsWu8MFmH6E7KG4j+ZdWwMO4KLiNI7EnzjFQcZeAZlXaE7sSK2UXXgic=
 =LiSF
 -----END PGP SIGNATURE-----
 

[BEAM-12634] JmsIO auto scaling feature (#15464)

* [BEAM-12634]: Provide generic Autoscaler interface,
- Provide DefaultAutoscaler implementation
- Add new autoscaler field to JmsIO

* [BEAM-12634]: Add Unit Tests for DefaultAutoScaler and mock custom Autoscaler

* [BEAM-12634] => Apply suggestions from code review

- Delete getSplitBacklogBytes method
- Add new comments

Co-authored-by: Lukasz Cwik <lcwik@google.com>

* [BEAM-12634]: Fix tests and some JavaDoc comments consecutively to code review

* [BEAM-12634]: Add comment on Autoscaler#getTotalBacklogBytes

* Update sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/AutoScaler.java

Co-authored-by: Lukasz Cwik <lcwik@google.com>