org.apache.beam.runners.fnexecution.control

Class FnApiControlClientPoolService

java.lang.Object

org.apache.beam.model.fnexecution.v1.BeamFnControlGrpc.BeamFnControlImplBase

org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService

All Implemented Interfaces:

io.grpc.BindableService

public class FnApiControlClientPoolService
extends org.apache.beam.model.fnexecution.v1.BeamFnControlGrpc.BeamFnControlImplBase

A Fn API control service which adds incoming SDK harness connections to a pool.

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionResponse>	control(io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionRequest> requestObserver) Called by gRPC for each incoming connection from an SDK harness, and enqueue an available SDK harness client.
static FnApiControlClientPoolService	offeringClientsToPool(java.util.concurrent.BlockingQueue<org.apache.beam.runners.fnexecution.control.FnApiControlClient> clientPool) Creates a new FnApiControlClientPoolService which will enqueue and vend new SDK harness connections.

Methods inherited from class org.apache.beam.model.fnexecution.v1.BeamFnControlGrpc.BeamFnControlImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

offeringClientsToPool

public static FnApiControlClientPoolService offeringClientsToPool(java.util.concurrent.BlockingQueue<org.apache.beam.runners.fnexecution.control.FnApiControlClient> clientPool)

Creates a new FnApiControlClientPoolService which will enqueue and vend new SDK harness connections.

control

public io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionResponse> control(io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.InstructionRequest> requestObserver)

Called by gRPC for each incoming connection from an SDK harness, and enqueue an available SDK harness client.

Note: currently does not distinguish what sort of SDK it is, so a separate instance is required for each.

Overrides:

control in class org.apache.beam.model.fnexecution.v1.BeamFnControlGrpc.BeamFnControlImplBase