org.apache.flink.runtime.webmonitor

Class WebMonitorConfig

java.lang.Object

org.apache.flink.runtime.webmonitor.WebMonitorConfig

public class WebMonitorConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT Default port for the web dashboard (= 8081)
static long	DEFAULT_JOB_MANAGER_WEB_REFRESH_INTERVAL Default refresh interval for the web dashboard (= 3000 msecs)
static String	JOB_MANAGER_WEB_PORT_KEY The port for the runtime monitor web-frontend server.
static String	JOB_MANAGER_WEB_REFRESH_INTERVAL_KEY The initial refresh interval for the web dashboard

Constructor Summary

Constructors

Constructor and Description
WebMonitorConfig(Configuration config)

Method Summary

Modifier and Type	Method and Description
long	getRefreshInterval()
int	getWebFrontendPort()
boolean	isProgramSubmitEnabled()

Methods inherited from class java.lang.Object

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

Field Detail

JOB_MANAGER_WEB_PORT_KEY

public static final String JOB_MANAGER_WEB_PORT_KEY

The port for the runtime monitor web-frontend server.

See Also:

Constant Field Values

JOB_MANAGER_WEB_REFRESH_INTERVAL_KEY

public static final String JOB_MANAGER_WEB_REFRESH_INTERVAL_KEY

The initial refresh interval for the web dashboard

See Also:

Constant Field Values

DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT

public static final int DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT

Default port for the web dashboard (= 8081)

See Also:

Constant Field Values

DEFAULT_JOB_MANAGER_WEB_REFRESH_INTERVAL

public static final long DEFAULT_JOB_MANAGER_WEB_REFRESH_INTERVAL

Default refresh interval for the web dashboard (= 3000 msecs)

See Also:

Constant Field Values

Constructor Detail

WebMonitorConfig

public WebMonitorConfig(Configuration config)

Method Detail

getWebFrontendPort

public int getWebFrontendPort()

getRefreshInterval

public long getRefreshInterval()

isProgramSubmitEnabled

public boolean isProgramSubmitEnabled()