org.apache.beam.sdk.util.construction

Class DefaultExpansionServiceClientFactory

java.lang.Object

org.apache.beam.sdk.util.construction.DefaultExpansionServiceClientFactory

All Implemented Interfaces:

java.lang.AutoCloseable, ExpansionServiceClientFactory

public class DefaultExpansionServiceClientFactory
extends java.lang.Object
implements ExpansionServiceClientFactory

Default factory for ExpansionServiceClient used by External transform.

Method Summary

Modifier and Type	Method and Description
void	close()
static DefaultExpansionServiceClientFactory	create(java.util.function.Function<org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor,org.apache.beam.vendor.grpc.v1p60p1.io.grpc.ManagedChannel> channelFactory)
ExpansionServiceClient	getExpansionServiceClient(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor endpoint)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static DefaultExpansionServiceClientFactory create(java.util.function.Function<org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor,org.apache.beam.vendor.grpc.v1p60p1.io.grpc.ManagedChannel> channelFactory)

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

getExpansionServiceClient

public ExpansionServiceClient getExpansionServiceClient(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor endpoint)

Specified by:

getExpansionServiceClient in interface ExpansionServiceClientFactory