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

Class MapControlClientPool

java.lang.Object

org.apache.beam.runners.fnexecution.control.MapControlClientPool

All Implemented Interfaces:

ControlClientPool

public class MapControlClientPool
extends Object
implements ControlClientPool

A ControlClientPool backed by a client map. It is expected that a given client id will be requested at most once.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.runners.fnexecution.control.ControlClientPool

ControlClientPool.Sink, ControlClientPool.Source

Method Summary

Modifier and Type	Method	Description
static MapControlClientPool	create()	Creates a MapControlClientPool.
ControlClientPool.Sink	getSink()	Sink for control clients.
ControlClientPool.Source	getSource()	Source of control clients.

Methods inherited from class java.lang.Object

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

Method Details

create

public static MapControlClientPool create()

Creates a MapControlClientPool.

getSource

public ControlClientPool.Source getSource()

Description copied from interface: ControlClientPool

Source of control clients.

Specified by:

getSource in interface ControlClientPool

getSink

public ControlClientPool.Sink getSink()

Description copied from interface: ControlClientPool

Sink for control clients.

Specified by:

getSink in interface ControlClientPool