org.apache.beam.sdk.extensions.python

Class PythonService

java.lang.Object

org.apache.beam.sdk.extensions.python.PythonService

public class PythonService
extends java.lang.Object

Utility to bootstrap and start a Beam Python service.

Constructor Summary

Constructors

Constructor and Description
PythonService(java.lang.String module, java.util.List<java.lang.String> args)
PythonService(java.lang.String module, java.lang.String... args)

Method Summary

Modifier and Type	Method and Description
static int	findAvailablePort()
java.lang.AutoCloseable	start()
static void	waitForPort(java.lang.String host, int port, int timeoutMs)

Methods inherited from class java.lang.Object

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

Constructor Detail

PythonService

public PythonService(java.lang.String module,
                     java.util.List<java.lang.String> args)

PythonService

public PythonService(java.lang.String module,
                     java.lang.String... args)

Method Detail

start

public java.lang.AutoCloseable start()
                              throws java.io.IOException,
                                     java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

findAvailablePort

public static int findAvailablePort()
                             throws java.io.IOException

Throws:

java.io.IOException

waitForPort

public static void waitForPort(java.lang.String host,
                               int port,
                               int timeoutMs)
                        throws java.util.concurrent.TimeoutException,
                               java.lang.InterruptedException

Throws:

java.util.concurrent.TimeoutException

java.lang.InterruptedException