Package | Description |
---|---|
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.entrypoint | |
org.apache.flink.runtime.webmonitor | |
org.apache.flink.runtime.webmonitor.retriever.impl |
Modifier and Type | Method and Description |
---|---|
static WebMonitor |
BootstrapTools.startWebMonitorIfConfigured(Configuration config,
HighAvailabilityServices highAvailabilityServices,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger logger)
Starts the web frontend.
|
Modifier and Type | Method and Description |
---|---|
protected DispatcherRestEndpoint |
SessionClusterEntrypoint.createDispatcherRestEndpoint(Configuration configuration,
LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
static WebMonitor |
WebMonitorUtils.startWebRuntimeMonitor(Configuration config,
HighAvailabilityServices highAvailabilityServices,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor)
Starts the web runtime monitor.
|
Constructor and Description |
---|
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
AkkaJobManagerRetriever
LeaderGatewayRetriever implementation for Akka based JobManagers. |
class |
RpcGatewayRetriever<F extends Serializable,T extends FencedRpcGateway<F>>
LeaderGatewayRetriever implementation using the RpcService . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.