org.apache.beam.sdk.fn.channel

Class ManagedChannelFactory

java.lang.Object

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

public class ManagedChannelFactory
extends java.lang.Object

A Factory which creates ManagedChannel instances.

Method Summary

Modifier and Type	Method and Description
static ManagedChannelFactory	createDefault() Creates a ManagedChannel relying on the ManagedChannelBuilder to choose the channel type.
static ManagedChannelFactory	createEpoll() Creates a ManagedChannelFactory backed by an EpollDomainSocketChannel if the address is a DomainSocketAddress.
static ManagedChannelFactory	createInProcess() Creates a ManagedChannel using an in-process channel.
org.apache.beam.vendor.grpc.v1p60p1.io.grpc.ManagedChannel	forDescriptor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)
ManagedChannelFactory	withDirectExecutor() Returns a ManagedChannelFactory like this one, but will construct the channel to use the direct executor.
ManagedChannelFactory	withInterceptors(java.util.List<org.apache.beam.vendor.grpc.v1p60p1.io.grpc.ClientInterceptor> interceptors) Returns a ManagedChannelFactory like this one, but which will apply the provided ClientInterceptors to any channel it creates.

Methods inherited from class java.lang.Object

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

Method Detail

createDefault

public static ManagedChannelFactory createDefault()

Creates a ManagedChannel relying on the ManagedChannelBuilder to choose the channel type.

createEpoll

public static ManagedChannelFactory createEpoll()

Creates a ManagedChannelFactory backed by an EpollDomainSocketChannel if the address is a DomainSocketAddress. Otherwise creates a ManagedChannel backed by an EpollSocketChannel.

createInProcess

public static ManagedChannelFactory createInProcess()

Creates a ManagedChannel using an in-process channel.

forDescriptor

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

withInterceptors

public ManagedChannelFactory withInterceptors(java.util.List<org.apache.beam.vendor.grpc.v1p60p1.io.grpc.ClientInterceptor> interceptors)

Returns a ManagedChannelFactory like this one, but which will apply the provided ClientInterceptors to any channel it creates.

withDirectExecutor

public ManagedChannelFactory withDirectExecutor()

Returns a ManagedChannelFactory like this one, but will construct the channel to use the direct executor.