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
org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannelBuilder<?>	builderFor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor) Create a ManagedChannelBuilder for the provided Endpoints.ApiServiceDescriptor.
static ManagedChannelFactory	create()

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

createDefault, createEpoll, forDescriptor, withInterceptors

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()

builderFor

public org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannelBuilder<?> builderFor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)

Description copied from class: ManagedChannelFactory

Create a ManagedChannelBuilder for the provided Endpoints.ApiServiceDescriptor.

Specified by:

builderFor in class ManagedChannelFactory