org.apache.beam.sdk.fn.test

Class InProcessManagedChannelFactory

java.lang.Object

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

org.apache.beam.sdk.fn.test.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.

Method Summary

Modifier and Type	Method and Description
static ManagedChannelFactory	create()
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

Method Detail

create

public static ManagedChannelFactory create()

forDescriptor

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

Specified by:

forDescriptor in class ManagedChannelFactory