Package org.apache.beam.sdk.expansion.service

Class ExpansionServer

java.lang.Object

org.apache.beam.sdk.expansion.service.ExpansionServer

All Implemented Interfaces:

AutoCloseable

public class ExpansionServer
extends Object
implements AutoCloseable

A gRPC Server for an ExpansionService.

Method Summary

Modifier and Type	Method	Description
void	close()
static ExpansionServer	create(ExpansionService service, String host, int port)	Create a ExpansionServer for the provided ExpansionService running on an arbitrary port.
String	getHost()	Get the host that this ExpansionServer is bound to.
int	getPort()	Get the port that this ExpansionServer is bound to.

Methods inherited from class java.lang.Object

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

Method Details

create

public static ExpansionServer create(ExpansionService service,
 String host,
 int port)
                              throws IOException

Create a ExpansionServer for the provided ExpansionService running on an arbitrary port.

If port is 0, a free port will be assigned.

Throws:

IOException

getHost

public String getHost()

Get the host that this ExpansionServer is bound to.

getPort

public int getPort()

Get the port that this ExpansionServer is bound to.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception