org.apache.beam.runners.reference.testing

Class InProcessManagedChannelFactory

java.lang.Object

org.apache.beam.sdk.fn.channel.ManagedChannelFactory

org.apache.beam.runners.reference.testing.InProcessManagedChannelFactory

public class InProcessManagedChannelFactory
extends ManagedChannelFactory

A ManagedChannelFactory that uses in-process channels.

The channel builder uses Endpoints.ApiServiceDescriptor.getUrl() as the unique in-process name.

Constructor Summary

Constructors

Constructor and Description
InProcessManagedChannelFactory()

Method Summary

Modifier and Type	Method and Description
io.grpc.ManagedChannel	forDescriptor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)

Methods inherited from class org.apache.beam.sdk.fn.channel.ManagedChannelFactory

createDefault, createEpoll

Methods inherited from class java.lang.Object

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

Constructor Detail

InProcessManagedChannelFactory

public InProcessManagedChannelFactory()

Method Detail

forDescriptor

public io.grpc.ManagedChannel forDescriptor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)

Specified by:

forDescriptor in class ManagedChannelFactory