JobServerDriver.ServerConfiguration (Apache Beam 2.67.0)

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 Object

Configuration for the jobServer.

Constructor Summary

Constructors

Constructor

Description

ServerConfiguration()
Method Summary

Modifier and Type

Method

Description

int

getArtifactPort()

String

getArtifactStagingPath()

int

getExpansionPort()

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 Details
- ServerConfiguration
  
  public ServerConfiguration()
Method Details
- getHost
  
  public 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 String getArtifactStagingPath()
- isCleanArtifactsPerJob
  
  public boolean isCleanArtifactsPerJob()
- getMaxInvocationHistory
  
  public int getMaxInvocationHistory()