org.apache.beam.runners.jobsubmission

Class JobServerDriver.ServerConfiguration

java.lang.Object

org.apache.beam.runners.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()
void	setArtifactPort(int artifactPort)
void	setExpansionPort(int expansionPort)
void	setPort(int port)

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()

setPort

public void setPort(int port)

getArtifactPort

public int getArtifactPort()

setArtifactPort

public void setArtifactPort(int artifactPort)

getExpansionPort

public int getExpansionPort()

setExpansionPort

public void setExpansionPort(int expansionPort)

getArtifactStagingPath

public java.lang.String getArtifactStagingPath()

isCleanArtifactsPerJob

public boolean isCleanArtifactsPerJob()

getMaxInvocationHistory

public int getMaxInvocationHistory()