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