Package org.apache.beam.runners.flink

Class FlinkJobServerDriver.FlinkServerConfiguration

java.lang.Object

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

org.apache.beam.runners.flink.FlinkJobServerDriver.FlinkServerConfiguration

Enclosing class:

FlinkJobServerDriver

public static class FlinkJobServerDriver.FlinkServerConfiguration
extends JobServerDriver.ServerConfiguration

Flink runner-specific Configuration for the jobServer.

Constructor Summary

Constructors

Constructor	Description
FlinkServerConfiguration()

Method Summary

Methods inherited from class org.apache.beam.runners.jobsubmission.JobServerDriver.ServerConfiguration

getArtifactPort, getArtifactStagingPath, getExpansionPort, getHost, getMaxInvocationHistory, getPort, isCleanArtifactsPerJob, setArtifactPort, setExpansionPort, setPort

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkServerConfiguration

public FlinkServerConfiguration()