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

Interface InstructionRequestHandler

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
FnApiControlClient
public interface InstructionRequestHandler extends AutoCloseable
Interface for any function that can handle a Fn API BeamFnApi.InstructionRequest. Any error responses will be converted to exceptionally completed futures.

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionResponse>
    handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionRequest request)
     
    void
    registerProcessBundleDescriptor(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor processBundleDescriptor)
     

    Methods inherited from interface java.lang.AutoCloseable

    close

  • Method Details

    • registerProcessBundleDescriptor

      void registerProcessBundleDescriptor(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor processBundleDescriptor)

    • handle

      CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionResponse> handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionRequest request)