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

Interface ControlClientPool.Sink

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.Sink

A sink for InstructionRequestHandlers keyed by worker id.

Method Summary

Modifier and Type	Method	Description
void	put(String workerId, InstructionRequestHandler instructionHandler)	Puts an InstructionRequestHandler into a client pool.

Method Details

put

void put(String workerId,
 InstructionRequestHandler instructionHandler)
  throws Exception

Puts an InstructionRequestHandler into a client pool. Worker ids must be unique per pool.

Throws:

Exception