This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 48d66ada923 Remove status disclaimer from pydoc root. (#26106)
add c6f8e0be1a5 Implement GetSize for ReadChangeStream to support
autoscaling (#26052)
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 23 +++-
.../bigtable/changestreams/TimestampConverter.java | 4 +
.../changestreams/action/ActionFactory.java | 11 +-
.../changestreams/action/ChangeStreamAction.java | 9 +-
.../dofn/ReadChangeStreamPartitionDoFn.java | 57 +++++++-
.../estimator/BytesThroughputEstimator.java | 74 +++++++----
.../changestreams/estimator/EncodingException.java | 5 +-
.../estimator/NullThroughputEstimator.java | 12 +-
.../changestreams/estimator/SizeEstimator.java | 6 +-
.../estimator/ThroughputEstimator.java | 12 +-
.../{encoder => estimator}/package-info.java | 7 +-
.../changestreams/TimestampConverterTest.java | 6 +
.../action/ChangeStreamActionTest.java | 8 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 143 +++++++++++++++++++++
.../estimator/BytesThroughputEstimatorTest.java | 83 ++++++------
.../estimator/NullThroughputEstimatorTest.java | 12 +-
16 files changed, 370 insertions(+), 102 deletions(-)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/BytesThroughputEstimator.java (62%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/EncodingException.java (88%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/NullThroughputEstimator.java (84%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/SizeEstimator.java (91%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/ThroughputEstimator.java (83%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/{encoder
=> estimator}/package-info.java (74%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dofn/ReadChangeStreamPartitionDoFnTest.java
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/BytesThroughputEstimatorTest.java (60%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/{spanner
=> bigtable}/changestreams/estimator/NullThroughputEstimatorTest.java (73%)
