This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0ef6d4b Merge pull request #16316 Benchmark and optimize Python
RowCoder
add 9e87d11 [BEAM-13494] Avoid draining Kinesis API limits & CPU when
reading from empty or low throughput shard
add 0d0278f Merge pull request #16288: [BEAM-13494] Avoid draining
Kinesis API limits & CPU when reading from empty or low throughput shard
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 2 +-
.../io/aws2/kinesis/RateLimitPolicyFactory.java | 76 ++++++++++++++++++++
.../aws2/kinesis/RateLimitPolicyFactoryTest.java | 81 ++++++++++++++++++++++
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 2 +-
.../sdk/io/kinesis/RateLimitPolicyFactory.java | 76 ++++++++++++++++++++
.../sdk/io/kinesis/RateLimitPolicyFactoryTest.java | 64 +++++++++++++++--
6 files changed, 295 insertions(+), 6 deletions(-)
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/kinesis/RateLimitPolicyFactoryTest.java
