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

Interface ControlClientPool.Source

Enclosing interface:

ControlClientPool

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface ControlClientPool.Source

A source of InstructionRequestHandlers.

Method Summary

Modifier and Type	Method	Description
InstructionRequestHandler	take(String workerId, Duration timeout)	Retrieves the InstructionRequestHandler for the given worker id, blocking until available or the request times out.

Method Details

take

InstructionRequestHandler take(String workerId,
 Duration timeout)
                        throws Exception

Retrieves the InstructionRequestHandler for the given worker id, blocking until available or the request times out. Worker ids must be unique per pool. A given worker id must not be requested multiple times. Note that if the given worker id is never entered into the pool, this call will never return.

Throws:

TimeoutException - if the request times out

InterruptedException - if interrupted while waiting

Exception