This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9f34aab [BEAM-11833] Minor code clarity improvements.
add 5fb31eb [BEAM-8137] Refactor External Worker Service to be part of
sdks-java-harness (#14988)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/runners/flink/FlinkJobServerDriver.java | 2 +-
.../runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java | 2 +-
.../runners/dataflow/worker/DataflowMapTaskExecutorFactory.java | 2 +-
.../beam/runners/dataflow/worker/DataflowRunnerHarness.java | 4 ++--
.../runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java | 2 +-
.../beam/runners/dataflow/worker/SdkHarnessRegistries.java | 2 +-
.../apache/beam/runners/dataflow/worker/SdkHarnessRegistry.java | 2 +-
.../beam/runners/dataflow/worker/fn/BeamFnControlService.java | 2 +-
.../runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java | 2 +-
.../runners/dataflow/worker/fn/logging/BeamFnLoggingService.java | 2 +-
.../runners/dataflow/worker/fn/BeamFnControlServiceTest.java | 4 ++--
.../dataflow/worker/fn/data/BeamFnDataGrpcServiceTest.java | 2 +-
.../dataflow/worker/fn/logging/BeamFnLoggingServiceTest.java | 2 +-
.../runners/fnexecution/artifact/ArtifactRetrievalService.java | 2 +-
.../runners/fnexecution/artifact/ArtifactStagingService.java | 2 +-
.../runners/fnexecution/control/DefaultJobBundleFactory.java | 6 +++---
.../fnexecution/control/FnApiControlClientPoolService.java | 4 ++--
.../control/SingleEnvironmentInstanceJobBundleFactory.java | 2 +-
.../apache/beam/runners/fnexecution/data/GrpcDataService.java | 2 +-
.../fnexecution/environment/DockerEnvironmentFactory.java | 4 ++--
.../fnexecution/environment/EmbeddedEnvironmentFactory.java | 6 +++---
.../beam/runners/fnexecution/environment/EnvironmentFactory.java | 4 ++--
.../fnexecution/environment/ExternalEnvironmentFactory.java | 4 ++--
.../fnexecution/environment/ProcessEnvironmentFactory.java | 2 +-
.../fnexecution/environment/StaticRemoteEnvironmentFactory.java | 2 +-
.../beam/runners/fnexecution/logging/GrpcLoggingService.java | 2 +-
.../fnexecution/provisioning/StaticGrpcProvisionService.java | 4 ++--
.../apache/beam/runners/fnexecution/state/GrpcStateService.java | 2 +-
.../runners/fnexecution/status/BeamWorkerStatusGrpcService.java | 4 ++--
.../org/apache/beam/runners/fnexecution/EmbeddedSdkHarness.java | 3 +++
.../fnexecution/GrpcContextHeaderAccessorProviderTest.java | 2 ++
.../org/apache/beam/runners/fnexecution/ServerFactoryTest.java | 1 +
.../fnexecution/artifact/ArtifactRetrievalServiceTest.java | 2 +-
.../runners/fnexecution/control/DefaultJobBundleFactoryTest.java | 4 ++--
.../fnexecution/control/FnApiControlClientPoolServiceTest.java | 6 +++---
.../beam/runners/fnexecution/control/RemoteExecutionTest.java | 6 +++---
.../control/SingleEnvironmentInstanceJobBundleFactoryTest.java | 4 ++--
.../beam/runners/fnexecution/data/GrpcDataServiceTest.java | 4 ++--
.../fnexecution/environment/DockerEnvironmentFactoryTest.java | 2 +-
.../fnexecution/environment/ProcessEnvironmentFactoryTest.java | 2 +-
.../beam/runners/fnexecution/logging/GrpcLoggingServiceTest.java | 4 ++--
.../fnexecution/provisioning/StaticGrpcProvisionServiceTest.java | 6 +++---
.../fnexecution/status/BeamWorkerStatusGrpcServiceTest.java | 6 +++---
.../apache/beam/runners/jobsubmission/InMemoryJobService.java | 4 ++--
.../org/apache/beam/runners/jobsubmission/JobServerDriver.java | 4 ++--
.../beam/runners/jobsubmission/InMemoryJobServiceTest.java | 2 +-
runners/portability/java/build.gradle | 1 -
.../java/org/apache/beam/runners/portability/PortableRunner.java | 3 ++-
.../java/org/apache/beam/runners/samza/SamzaJobServerDriver.java | 2 +-
.../java/org/apache/beam/runners/spark/SparkJobServerDriver.java | 2 +-
.../src/main/java/org/apache/beam/sdk/fn/server}/FnService.java | 2 +-
.../beam/sdk/fn/server}/GrpcContextHeaderAccessorProvider.java | 2 +-
.../main/java/org/apache/beam/sdk/fn/server}/GrpcFnServer.java | 2 +-
.../main/java/org/apache/beam/sdk/fn/server}/HeaderAccessor.java | 2 +-
.../org/apache/beam/sdk/fn/server}/InProcessServerFactory.java | 2 +-
.../main/java/org/apache/beam/sdk/fn/server}/ServerFactory.java | 2 +-
.../main/java/org/apache/beam/sdk/fn/server}/package-info.java | 4 ++--
.../java/org/apache/beam/fn/harness}/ExternalWorkerService.java | 9 ++++-----
.../org/apache/beam/fn/harness}/ExternalWorkerServiceTest.java | 2 +-
59 files changed, 92 insertions(+), 87 deletions(-)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/FnService.java
(97%)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/GrpcContextHeaderAccessorProvider.java
(98%)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/GrpcFnServer.java
(99%)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/HeaderAccessor.java
(95%)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/InProcessServerFactory.java
(98%)
rename
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution =>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/ServerFactory.java
(99%)
copy sdks/java/{testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds =>
fn-execution/src/main/java/org/apache/beam/sdk/fn/server}/package-info.java
(92%)
rename
{runners/portability/java/src/main/java/org/apache/beam/runners/portability =>
sdks/java/harness/src/main/java/org/apache/beam/fn/harness}/ExternalWorkerService.java
(95%)
rename
{runners/portability/java/src/test/java/org/apache/beam/runners/portability =>
sdks/java/harness/src/test/java/org/apache/beam/fn/harness}/ExternalWorkerServiceTest.java
(98%)
