org.apache.beam.runners.fnexecution.control

Interface InstructionRequestHandler

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

FnApiControlClient

public interface InstructionRequestHandler
extends java.lang.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 and Description
java.util.concurrent.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 Detail

registerProcessBundleDescriptor

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

handle

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