This is an automated email from the ASF dual-hosted git repository.
yichi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b14010d [BEAM-13321] Initial BigQueryIO externalization. (#16489)
add f2c36cf [BEAM-13193] Enable process bundle response elements
embedding in Java SDK Harness (#16769)
No new revisions were added by this update.
Summary of changes:
.../sdk/fn/data/BeamFnDataOutboundAggregator.java | 40 +++++++--
.../sdk/fn/data/BeamFnDataOutboundObserver.java | 6 +-
.../fn/data/BeamFnDataOutboundAggregatorTest.java | 43 ++++++----
.../beam/fn/harness/PTransformRunnerFactory.java | 4 +
.../fn/harness/control/ProcessBundleHandler.java | 94 +++++++++++++++++----
.../beam/fn/harness/data/BeamFnDataClient.java | 11 ++-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 7 +-
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 3 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 2 +-
.../PTransformRunnerFactoryTestContext.java | 10 ++-
.../harness/control/ProcessBundleHandlerTest.java | 95 ++++++++++++++++++++--
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 5 +-
12 files changed, 258 insertions(+), 62 deletions(-)
