Hierarchy For Package org.apache.beam.runners.fnexecution.control

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.model.fnexecution.v1.BeamFnControlGrpc.BeamFnControlImplBase (implements org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService)
    • org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService (implements org.apache.beam.runners.fnexecution.FnService)
  • org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory (implements org.apache.beam.runners.fnexecution.control.JobBundleFactory)
  • org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.SimpleStageBundleFactory (implements org.apache.beam.runners.fnexecution.control.StageBundleFactory)
  • org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.WrappedSdkHarnessClient (implements java.lang.AutoCloseable)
  • org.apache.beam.runners.fnexecution.control.FnApiControlClient (implements java.io.Closeable, org.apache.beam.runners.fnexecution.control.InstructionRequestHandler)
  • org.apache.beam.runners.fnexecution.control.MapControlClientPool (implements org.apache.beam.runners.fnexecution.control.ControlClientPool)
  • org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors
  • org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.BagUserStateSpec<K,V,W>
  • org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.ExecutableProcessBundleDescriptor
  • org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.SideInputSpec<K,T,W>
  • org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.TimerSpec<K,V,W>
  • org.apache.beam.runners.fnexecution.control.RemoteOutputReceiver<T>
  • org.apache.beam.runners.fnexecution.control.SdkHarnessClient (implements java.lang.AutoCloseable)
  • org.apache.beam.runners.fnexecution.control.SdkHarnessClient.ActiveBundle (implements org.apache.beam.runners.fnexecution.control.RemoteBundle)
  • org.apache.beam.runners.fnexecution.control.SdkHarnessClient.BundleProcessor
  • org.apache.beam.runners.fnexecution.control.SingleEnvironmentInstanceJobBundleFactory (implements org.apache.beam.runners.fnexecution.control.JobBundleFactory)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.beam.runners.fnexecution.control.InstructionRequestHandler
  • org.apache.beam.runners.fnexecution.control.JobBundleFactory
  • org.apache.beam.runners.fnexecution.control.RemoteBundle
  • org.apache.beam.runners.fnexecution.control.StageBundleFactory
• org.apache.beam.runners.fnexecution.control.BundleProgressHandler
• org.apache.beam.runners.fnexecution.control.ControlClientPool
• org.apache.beam.runners.fnexecution.control.ControlClientPool.Sink
• org.apache.beam.runners.fnexecution.control.ControlClientPool.Source
• org.apache.beam.runners.fnexecution.control.OutputReceiverFactory