org.apache.beam.sdk.fn.channel

Class ManagedChannelFactory

java.lang.Object

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

public abstract class ManagedChannelFactory
extends java.lang.Object

A Factory which creates an underlying ManagedChannel implementation.

Constructor Summary

Constructors

Constructor and Description
ManagedChannelFactory()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagedChannelFactory

public ManagedChannelFactory()

Method Detail

createDefault

public static ManagedChannelFactory createDefault()

createEpoll

public static ManagedChannelFactory createEpoll()

forDescriptor

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