Package org.apache.beam.runners.fnexecution.control
-
Class Summary Class Description DefaultJobBundleFactory AJobBundleFactory
for which the implementation can specify a customEnvironmentFactory
for environment management.DefaultJobBundleFactory.ServerInfo A container for EnvironmentFactory and its corresponding Grpc servers.DefaultJobBundleFactory.WrappedSdkHarnessClient Holder for anSdkHarnessClient
along with its associated state and data servers.