This is an automated email from the ASF dual-hosted git repository.
lgajowy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c02af60 [BEAM-4858] Increase tolerance on linear regression tests
(#8556)
add c9142ad2 [BEAM-6627] Generify ByteMonitor to accept any type, not just
KV<byte[], byte[]>
add d2f0631 [BEAM-6627] Add CountMonitor to IOIT metric utils
add 59e68a2 [BEAM-6627] Add byte and element counting to TextIOIT
add b8d7fe8 [BEAM-6627] Add byte and element counting to AvroIOIT
add 74c0a47 [BEAM-6627] Add byte and element counting to ParquetIOIT
add 535c7cf [BEAM-6627] Add byte and element count metric to XmlIOIT
add b022a1a [BEAM-6627] Add byte and element count metric in TFRecordIOIT
add a57c679 [BEAM-6627] Add byte and element counter metric to JdbcIOIT
add bdefbef [BEAM-6627] Add byte and item count metrics to MongoDBIOIT
add 30aa39f [BEAM-6627] Add byte and item count metrics to JdbcIOIT
new a16a5b7 Merge pull request #8400: [BEAM-6627] Added byte and item
counting metrics to integration tests
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/beam/sdk/io/avro/AvroIOIT.java | 16 ++++++
.../apache/beam/sdk/io/parquet/ParquetIOIT.java | 19 +++++++
.../java/org/apache/beam/sdk/io/text/TextIOIT.java | 19 +++++++
.../apache/beam/sdk/io/tfrecord/TFRecordIOIT.java | 60 ++++++++++++++--------
.../java/org/apache/beam/sdk/io/xml/XmlIOIT.java | 20 ++++++++
.../java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 14 +++++
.../apache/beam/sdk/io/mongodb/MongoDBIOIT.java | 14 +++++
.../beam/sdk/loadtests/CoGroupByKeyLoadTest.java | 3 +-
.../apache/beam/sdk/loadtests/CombineLoadTest.java | 2 +-
.../beam/sdk/loadtests/GroupByKeyLoadTest.java | 2 +-
.../apache/beam/sdk/loadtests/ParDoLoadTest.java | 2 +-
.../beam/sdk/testutils/metrics/ByteMonitor.java | 6 +--
.../{ByteMonitor.java => CountMonitor.java} | 24 ++++-----
13 files changed, 161 insertions(+), 40 deletions(-)
copy
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/{ByteMonitor.java
=> CountMonitor.java} (61%)
