Package | Description |
---|---|
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.entrypoint.component | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.rest | |
org.apache.flink.runtime.rest.handler.legacy.metrics | |
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.
|
Constructor and Description |
---|
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ExecutorService executor,
MetricQueryServiceRetriever metricQueryServiceRetriever,
LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
DispatcherResourceManagerComponent<T> |
DispatcherResourceManagerComponentFactory.create(Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
MetricQueryServiceRetriever metricQueryServiceRetriever,
FatalErrorHandler fatalErrorHandler) |
DispatcherResourceManagerComponent<T> |
AbstractDispatcherResourceManagerComponentFactory.create(Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
MetricQueryServiceRetriever metricQueryServiceRetriever,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
MiniDispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ExecutorService executor,
MetricQueryServiceRetriever metricQueryServiceRetriever,
LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
MetricFetcher(GatewayRetriever<T> retriever,
MetricQueryServiceRetriever queryServiceRetriever,
Executor executor,
Time timeout) |
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 |
---|
WebMonitorEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<? extends T> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ExecutorService executor,
MetricQueryServiceRetriever metricQueryServiceRetriever,
LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler) |
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
AkkaQueryServiceRetriever
MetricQueryServiceRetriever implementation for Akka based MetricQueryService . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.