org.apache.beam.runners.fnexecution.jobsubmission

Class JobServerDriver.ServerConfiguration

java.lang.Object

org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver.ServerConfiguration

Direct Known Subclasses:

FlinkJobServerDriver.FlinkServerConfiguration, SparkJobServerDriver.SparkServerConfiguration

Enclosing class:

JobServerDriver

public static class JobServerDriver.ServerConfiguration
extends java.lang.Object

Configuration for the jobServer.

Constructor Summary

Constructors

Constructor and Description
ServerConfiguration()

Method Summary

Modifier and Type	Method and Description
int	getArtifactPort()
java.lang.String	getArtifactStagingPath()
int	getExpansionPort()
java.lang.String	getHost()
int	getMaxInvocationHistory()
int	getPort()
boolean	isCleanArtifactsPerJob()

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConfiguration

public ServerConfiguration()

Method Detail

getHost

public java.lang.String getHost()

getPort

public int getPort()

getArtifactPort

public int getArtifactPort()

getExpansionPort

public int getExpansionPort()

getArtifactStagingPath

public java.lang.String getArtifactStagingPath()

isCleanArtifactsPerJob

public boolean isCleanArtifactsPerJob()

getMaxInvocationHistory

public int getMaxInvocationHistory()