This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 95a6566107e [Avro] Use "extensions/avro" instead of avro from"core" in
Java SDK modules (#24992)
add 83cfdb829b8 PCollection data sampling for Java SDK harness #25064
(#25354)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/fn/harness/FnHarness.java | 14 +-
.../fn/harness/control/ProcessBundleHandler.java | 18 +-
.../harness/data/PCollectionConsumerRegistry.java | 59 ++++-
.../apache/beam/fn/harness/debug/DataSampler.java | 125 ++++++++++
.../beam/fn/harness/debug/OutputSampler.java | 129 ++++++++++
.../beam/fn/harness/debug}/package-info.java | 4 +-
.../harness/control/ProcessBundleHandlerTest.java | 48 ++--
.../data/PCollectionConsumerRegistryTest.java | 60 +++++
.../beam/fn/harness/debug/DataSamplerTest.java | 273 +++++++++++++++++++++
.../beam/fn/harness/debug/OutputSamplerTest.java | 188 ++++++++++++++
10 files changed, 888 insertions(+), 30 deletions(-)
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/debug/DataSampler.java
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/debug/OutputSampler.java
copy
{examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils
=>
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/debug}/package-info.java
(88%)
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/debug/DataSamplerTest.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/debug/OutputSamplerTest.java
