org.apache.beam.runners.fnexecution.control

Interfaces

• BundleCheckpointHandler
• BundleFinalizationHandler
• BundleProgressHandler
• BundleSplitHandler
• ControlClientPool
• ControlClientPool.Sink
• ControlClientPool.Source
• ExecutableStageContext
• ExecutableStageContext.Factory
• InstructionRequestHandler
• JobBundleFactory
• OutputReceiverFactory
• ReferenceCountingExecutableStageContextFactory.Creator
• RemoteBundle
• StageBundleFactory

Classes

• BundleCheckpointHandlers
• BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler
• BundleFinalizationHandlers
• BundleFinalizationHandlers.InMemoryFinalizer
• DefaultExecutableStageContext
• DefaultJobBundleFactory
• DefaultJobBundleFactory.ServerInfo
• DefaultJobBundleFactory.WrappedSdkHarnessClient
• FnApiControlClient
• FnApiControlClientPoolService
• MapControlClientPool
• ProcessBundleDescriptors
• ProcessBundleDescriptors.BagUserStateSpec
• ProcessBundleDescriptors.ExecutableProcessBundleDescriptor
• ProcessBundleDescriptors.SideInputSpec
• ProcessBundleDescriptors.TimerSpec
• ReferenceCountingExecutableStageContextFactory
• RemoteOutputReceiver
• SdkHarnessClient
• SingleEnvironmentInstanceJobBundleFactory
• TimerReceiverFactory