Class MapControlClientPool
java.lang.Object
org.apache.beam.runners.fnexecution.control.MapControlClientPool
- All Implemented Interfaces:
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 TypeMethodDescriptionstatic MapControlClientPool
create()
Creates aMapControlClientPool
.getSink()
Sink for control clients.Source of control clients.
-
Method Details
-
create
Creates aMapControlClientPool
. -
getSource
Description copied from interface:ControlClientPool
Source of control clients.- Specified by:
getSource
in interfaceControlClientPool
-
getSink
Description copied from interface:ControlClientPool
Sink for control clients.- Specified by:
getSink
in interfaceControlClientPool
-