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 cb10019 [BEAM-8169] DataCatalogTableProvider to use GCP credentials
from PipelineOptions
add 7e91a7f [BEAM-7947] Improves the interfaces of classes such as
FnDataService, BundleProcessor, ActiveBundle, etc to change the parameter type
from WindowedValue<T> to T
add be2cfec fix code style
add 6b3f7d6 [BEAM-7947] Improves the interfaces of classes such as
FnDataService,…
No new revisions were added by this update.
Summary of changes:
.../FlinkExecutableStageFunctionTest.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../worker/fn/data/BeamFnDataGrpcService.java | 12 +++----
.../dataflow/worker/FnApiWindowMappingFnTest.java | 15 ++++-----
.../worker/fn/control/TimerReceiverTest.java | 2 +-
.../control/DefaultJobBundleFactory.java | 10 +++---
.../control/ProcessBundleDescriptors.java | 18 +++++------
.../runners/fnexecution/control/RemoteBundle.java | 3 +-
.../fnexecution/control/SdkHarnessClient.java | 27 +++++++---------
.../SingleEnvironmentInstanceJobBundleFactory.java | 8 ++---
.../runners/fnexecution/data/FnDataService.java | 8 ++---
.../runners/fnexecution/data/GrpcDataService.java | 8 ++---
.../fnexecution/control/RemoteExecutionTest.java | 36 +++++++++++----------
.../fnexecution/control/SdkHarnessClientTest.java | 4 +--
.../SparkExecutableStageFunctionTest.java | 4 +--
.../data/BeamFnDataBufferingOutboundObserver.java | 14 ++++----
.../sdk/fn/data/BeamFnDataInboundObserver.java | 13 +++-----
.../beam/fn/harness/data/BeamFnDataClient.java | 9 +++---
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 9 +++---
.../fn/harness/data/QueueingBeamFnDataClient.java | 37 +++++++++++-----------
.../data/BeamFnDataInboundObserverTest.java | 4 +--
21 files changed, 108 insertions(+), 137 deletions(-)
