Uses of Interface
org.apache.flink.runtime.resourcemanager.ResourceManagerGateway

Packages that use ResourceManagerGateway

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.rest
org.apache.flink.runtime.rest.handler.dataset
org.apache.flink.runtime.rest.handler.resourcemanager
org.apache.flink.runtime.rest.handler.taskmanager
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.threadinfo

Uses of ResourceManagerGateway in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type ResourceManagerGateway

Modifier and Type	Method and Description
GatewayRetriever<ResourceManagerGateway>	DispatcherServices.getResourceManagerGatewayRetriever()
GatewayRetriever<ResourceManagerGateway>	PartialDispatcherServices.getResourceManagerGatewayRetriever()

Constructor parameters in org.apache.flink.runtime.dispatcher with type arguments of type ResourceManagerGateway

Constructor and Description
DispatcherRestEndpoint(GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)
PartialDispatcherServices(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroupFactory jobManagerMetricGroupFactory, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, Executor ioExecutor, DispatcherOperationCaches operationCaches)

Uses of ResourceManagerGateway in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition with parameters of type ResourceManagerGateway

Modifier and Type	Method and Description
void	JobMasterPartitionTracker.connectToResourceManager(ResourceManagerGateway resourceManagerGateway)
void	JobMasterPartitionTrackerImpl.connectToResourceManager(ResourceManagerGateway resourceManagerGateway)

Uses of ResourceManagerGateway in org.apache.flink.runtime.jobmaster

Constructor parameters in org.apache.flink.runtime.jobmaster with type arguments of type ResourceManagerGateway

Constructor and Description

MiniDispatcherRestEndpoint(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of ResourceManagerGateway in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type ResourceManagerGateway

Modifier and Type	Method and Description
void	SlotPool.connectToResourceManager(ResourceManagerGateway resourceManagerGateway) Connects the SlotPool to the given ResourceManager.
void	SlotPoolService.connectToResourceManager(ResourceManagerGateway resourceManagerGateway) Connects the SlotPool to the given ResourceManager.
void	DeclarativeSlotPoolService.connectToResourceManager(ResourceManagerGateway resourceManagerGateway)

Uses of ResourceManagerGateway in org.apache.flink.runtime.resourcemanager

Classes in org.apache.flink.runtime.resourcemanager that implement ResourceManagerGateway

Modifier and Type	Class and Description
class	ResourceManager<WorkerType extends ResourceIDRetrievable> ResourceManager implementation.
class	StandaloneResourceManager A standalone implementation of the resource manager.

Uses of ResourceManagerGateway in org.apache.flink.runtime.resourcemanager.active

Classes in org.apache.flink.runtime.resourcemanager.active that implement ResourceManagerGateway

Modifier and Type	Class and Description
class	ActiveResourceManager<WorkerType extends ResourceIDRetrievable> An active implementation of ResourceManager.

Uses of ResourceManagerGateway in org.apache.flink.runtime.rest

Method parameters in org.apache.flink.runtime.rest with type arguments of type ResourceManagerGateway

Modifier and Type	Method and Description
WebMonitorEndpoint<DispatcherGateway>	SessionRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<T>	RestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<RestfulGateway>	JobRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)

Uses of ResourceManagerGateway in org.apache.flink.runtime.rest.handler.dataset

Methods in org.apache.flink.runtime.rest.handler.dataset with parameters of type ResourceManagerGateway

Modifier and Type	Method and Description
protected CompletableFuture<ClusterDataSetListResponseBody>	ClusterDataSetListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.dataset with type arguments of type ResourceManagerGateway

Constructor and Description
ClusterDataSetDeleteTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
ClusterDataSetListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Uses of ResourceManagerGateway in org.apache.flink.runtime.rest.handler.resourcemanager

Methods in org.apache.flink.runtime.rest.handler.resourcemanager that return ResourceManagerGateway

Modifier and Type	Method and Description
static ResourceManagerGateway	AbstractResourceManagerHandler.getResourceManagerGateway(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Methods in org.apache.flink.runtime.rest.handler.resourcemanager with parameters of type ResourceManagerGateway

Modifier and Type	Method and Description
protected abstract CompletableFuture<P>	AbstractResourceManagerHandler.handleRequest(HandlerRequest<R> request, ResourceManagerGateway gateway)

Method parameters in org.apache.flink.runtime.rest.handler.resourcemanager with type arguments of type ResourceManagerGateway

Modifier and Type	Method and Description
static ResourceManagerGateway	AbstractResourceManagerHandler.getResourceManagerGateway(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Constructor parameters in org.apache.flink.runtime.rest.handler.resourcemanager with type arguments of type ResourceManagerGateway

Constructor and Description
AbstractResourceManagerHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Uses of ResourceManagerGateway in org.apache.flink.runtime.rest.handler.taskmanager

Methods in org.apache.flink.runtime.rest.handler.taskmanager with parameters of type ResourceManagerGateway

Modifier and Type	Method and Description
protected CompletableFuture<ThreadDumpInfo>	TaskManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<LogListInfo>	TaskManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<TaskManagerDetailsInfo>	TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<TaskManagersInfo>	TaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<TransientBlobKey>	TaskManagerStdoutFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected abstract CompletableFuture<TransientBlobKey>	AbstractTaskManagerFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected CompletableFuture<TransientBlobKey>	TaskManagerCustomLogHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
protected CompletableFuture<TransientBlobKey>	TaskManagerLogFileHandler.requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)

Constructor parameters in org.apache.flink.runtime.rest.handler.taskmanager with type arguments of type ResourceManagerGateway

Constructor and Description
AbstractTaskManagerFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,M> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerFileMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagerDetailsInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, MetricFetcher metricFetcher)
TaskManagerLogFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerLogListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,LogListInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagersInfo,EmptyMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagerStdoutFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Uses of ResourceManagerGateway in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return types with arguments of type ResourceManagerGateway

Modifier and Type	Method and Description
protected RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess,TaskExecutorRegistrationRejection>	TaskExecutorToResourceManagerConnection.generateRegistration()

Uses of ResourceManagerGateway in org.apache.flink.runtime.webmonitor

Constructor parameters in org.apache.flink.runtime.webmonitor with type arguments of type ResourceManagerGateway

Constructor and Description

WebMonitorEndpoint(GatewayRetriever<? extends T> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of ResourceManagerGateway in org.apache.flink.runtime.webmonitor.threadinfo

Method parameters in org.apache.flink.runtime.webmonitor.threadinfo with type arguments of type ResourceManagerGateway

Modifier and Type	Method and Description
static <T extends Statistics> JobVertexThreadInfoTrackerBuilder<T>	JobVertexThreadInfoTrackerBuilder.newBuilder(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, java.util.function.Function<JobVertexThreadInfoStats,T> createStatsFn, ScheduledExecutorService executor, Time restTimeout) Create a new JobVertexThreadInfoTrackerBuilder.