Uses of Interface
org.apache.flink.runtime.rpc.RpcService

Packages that use RpcService

Package	Description
org.apache.flink.client.deployment.application
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.runner
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.metrics
org.apache.flink.runtime.metrics.dump
org.apache.flink.runtime.metrics.util
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.registration
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.rpc
org.apache.flink.runtime.rpc.akka
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.webmonitor.retriever.impl

Uses of RpcService in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type RpcService

Modifier and Type	Method and Description
DispatcherLeaderProcessFactory	ApplicationDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices, FatalErrorHandler fatalErrorHandler)

Constructors in org.apache.flink.client.deployment.application with parameters of type RpcService

Constructor and Description
ApplicationDispatcherGatewayServiceFactory(Configuration configuration, DispatcherFactory dispatcherFactory, PackagedProgram application, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)

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

Methods in org.apache.flink.runtime.dispatcher with parameters of type RpcService

Modifier and Type	Method and Description
StandaloneDispatcher	SessionDispatcherFactory.createDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents)
Dispatcher	DispatcherFactory.createDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents) Create a Dispatcher.
MiniDispatcher	JobDispatcherFactory.createDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents)
JobManagerRunner	JobManagerRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)
JobManagerRunner	JobMasterServiceLeadershipRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)

Constructors in org.apache.flink.runtime.dispatcher with parameters of type RpcService

Constructor and Description
Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices)
Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory)
MiniDispatcher(RpcService rpcService, DispatcherId fencingToken, DispatcherServices dispatcherServices, JobGraph jobGraph, JobResult recoveredDirtyJob, DispatcherBootstrapFactory dispatcherBootstrapFactory, ClusterEntrypoint.ExecutionMode executionMode)
MiniDispatcher(RpcService rpcService, DispatcherId fencingToken, DispatcherServices dispatcherServices, JobGraph jobGraph, JobResult recoveredDirtyJob, DispatcherBootstrapFactory dispatcherBootstrapFactory, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory, ClusterEntrypoint.ExecutionMode executionMode)
StandaloneDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices)

Uses of RpcService in org.apache.flink.runtime.dispatcher.runner

Methods in org.apache.flink.runtime.dispatcher.runner with parameters of type RpcService

Modifier and Type	Method and Description
DispatcherRunner	DefaultDispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)
DispatcherRunner	DispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)
DispatcherLeaderProcessFactory	DispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices, FatalErrorHandler fatalErrorHandler)
JobDispatcherLeaderProcessFactory	JobDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices, FatalErrorHandler fatalErrorHandler)
DispatcherLeaderProcessFactory	SessionDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices, FatalErrorHandler fatalErrorHandler)

Uses of RpcService in org.apache.flink.runtime.entrypoint.component

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type RpcService

Modifier and Type	Method and Description
DispatcherResourceManagerComponent	DefaultDispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
DispatcherResourceManagerComponent	DispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)

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

Constructors in org.apache.flink.runtime.jobmaster with parameters of type RpcService

Constructor and Description

JobMaster(RpcService rpcService, JobMasterId jobMasterId, JobMasterConfiguration jobMasterConfiguration, ResourceID resourceId, JobGraph jobGraph, HighAvailabilityServices highAvailabilityService, SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobMetricGroupFactory, OnCompletionActions jobCompletionActions, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeLoader, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory partitionTrackerFactory, ExecutionDeploymentTracker executionDeploymentTracker, ExecutionDeploymentReconciler.Factory executionDeploymentReconcilerFactory, long initializationTimestamp)

Uses of RpcService in org.apache.flink.runtime.jobmaster.factories

Constructors in org.apache.flink.runtime.jobmaster.factories with parameters of type RpcService

Constructor and Description

DefaultJobMasterServiceFactory(Executor executor, RpcService rpcService, JobMasterConfiguration jobMasterConfiguration, JobGraph jobGraph, HighAvailabilityServices haServices, SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeClassloader, long initializationTimestamp)

Uses of RpcService in org.apache.flink.runtime.metrics

Methods in org.apache.flink.runtime.metrics that return RpcService

Modifier and Type	Method and Description
RpcService	MetricRegistryImpl.getMetricQueryServiceRpcService() Returns the rpc service that the MetricQueryService runs in.

Methods in org.apache.flink.runtime.metrics with parameters of type RpcService

Modifier and Type	Method and Description
void	MetricRegistryImpl.startQueryService(RpcService rpcService, ResourceID resourceID) Initializes the MetricQueryService.

Uses of RpcService in org.apache.flink.runtime.metrics.dump

Methods in org.apache.flink.runtime.metrics.dump with parameters of type RpcService

Modifier and Type	Method and Description
static MetricQueryService	MetricQueryService.createMetricQueryService(RpcService rpcService, ResourceID resourceID, long maximumFrameSize) Starts the MetricQueryService actor in the given actor system.

Constructors in org.apache.flink.runtime.metrics.dump with parameters of type RpcService

Constructor and Description
MetricQueryService(RpcService rpcService, String endpointId, long messageSizeLimit)

Uses of RpcService in org.apache.flink.runtime.metrics.util

Methods in org.apache.flink.runtime.metrics.util that return RpcService

Modifier and Type	Method and Description
static RpcService	MetricUtils.startLocalMetricsRpcService(Configuration configuration, RpcSystem rpcSystem)
static RpcService	MetricUtils.startRemoteMetricsRpcService(Configuration configuration, String externalAddress, String bindAddress, RpcSystem rpcSystem)

Uses of RpcService in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return RpcService

Modifier and Type	Method and Description
protected RpcService	MiniCluster.createLocalRpcService(Configuration configuration, RpcSystem rpcSystem) Factory method to instantiate the local RPC service.
protected RpcService	MiniCluster.createRemoteRpcService(Configuration configuration, String bindAddress, int bindPort, RpcSystem rpcSystem) Factory method to instantiate the remote RPC service.
protected RpcService	MiniCluster.createRemoteRpcService(Configuration configuration, String externalAddress, String externalPortRange, String bindAddress, RpcSystem rpcSystem) Factory method to instantiate the remote RPC service.
RpcService	MiniCluster.RpcServiceFactory.createRpcService()
RpcService	MiniCluster.CommonRpcServiceFactory.createRpcService()
RpcService	MiniCluster.DedicatedRpcServiceFactory.createRpcService()

Uses of RpcService in org.apache.flink.runtime.registration

Constructors in org.apache.flink.runtime.registration with parameters of type RpcService

Constructor and Description
RetryingRegistration(org.slf4j.Logger log, RpcService rpcService, String targetName, Class<G> targetType, String targetAddress, F fencingToken, RetryingRegistrationConfiguration retryingRegistrationConfiguration)

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

Methods in org.apache.flink.runtime.resourcemanager that return RpcService

Modifier and Type	Method and Description
RpcService	ResourceManagerProcessContext.getRpcService()

Methods in org.apache.flink.runtime.resourcemanager with parameters of type RpcService

Modifier and Type	Method and Description
static ResourceManagerServiceImpl	ResourceManagerServiceImpl.create(ResourceManagerFactory<?> resourceManagerFactory, Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
protected abstract ResourceManager<T>	ResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected ResourceManager<ResourceID>	StandaloneResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
ResourceManagerProcessContext	ResourceManagerFactory.createResourceManagerProcessContext(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type RpcService

Constructor and Description
ResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time rpcTimeout, Executor ioExecutor)
ResourceManagerProcessContext(Configuration rmConfig, ResourceID resourceId, ResourceManagerRuntimeServicesConfiguration rmRuntimeServicesConfig, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
StandaloneResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time startupPeriodTime, Time rpcTimeout, Executor ioExecutor)

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

Methods in org.apache.flink.runtime.resourcemanager.active with parameters of type RpcService

Modifier and Type

Method and Description

ResourceManager<WorkerType>

ActiveResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)

Constructors in org.apache.flink.runtime.resourcemanager.active with parameters of type RpcService

Constructor and Description

ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver, Configuration flinkConfig, RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, ThresholdMeter startWorkerFailureRater, java.time.Duration retryInterval, java.time.Duration workerRegistrationTimeout, Executor ioExecutor)

Uses of RpcService in org.apache.flink.runtime.rpc

Methods in org.apache.flink.runtime.rpc that return RpcService

Modifier and Type	Method and Description
RpcService	RpcSystem.RpcServiceBuilder.createAndStart()
static RpcService	RpcUtils.createRemoteRpcService(RpcSystem rpcSystem, Configuration configuration, String externalAddress, String externalPortRange, String bindAddress, Optional<Integer> bindPort) Convenient shortcut for constructing a remote RPC Service that takes care of checking for null and empty optionals.
RpcService	RpcEndpoint.getRpcService() Gets the endpoint's RPC service.

Methods in org.apache.flink.runtime.rpc with parameters of type RpcService

Modifier and Type	Method and Description
static String	RpcUtils.getHostname(RpcService rpcService) Returns the hostname onto which the given RpcService has been bound.
static void	RpcUtils.terminateRpcService(RpcService rpcService, Time timeout) Shuts the given rpc service down and waits for its termination.
static void	RpcUtils.terminateRpcServices(Time timeout, RpcService... rpcServices) Shuts the given rpc services down and waits for their termination.

Constructors in org.apache.flink.runtime.rpc with parameters of type RpcService

Constructor and Description
FencedRpcEndpoint(RpcService rpcService, F fencingToken)
FencedRpcEndpoint(RpcService rpcService, String endpointId, F fencingToken)
PermanentlyFencedRpcEndpoint(RpcService rpcService, F fencingToken)
PermanentlyFencedRpcEndpoint(RpcService rpcService, String endpointId, F fencingToken)
RpcEndpoint(RpcService rpcService) Initializes the RPC endpoint with a random endpoint id.
RpcEndpoint(RpcService rpcService, String endpointId) Initializes the RPC endpoint.

Uses of RpcService in org.apache.flink.runtime.rpc.akka

Classes in org.apache.flink.runtime.rpc.akka that implement RpcService

Modifier and Type	Class and Description
class	AkkaRpcService Akka based RpcService implementation.

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

Methods in org.apache.flink.runtime.taskexecutor with parameters of type RpcService

Modifier and Type	Method and Description
TaskManagerRunner.TaskExecutorService	TaskManagerRunner.TaskExecutorServiceFactory.createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
static TaskManagerRunner.TaskExecutorService	TaskManagerRunner.createTaskExecutorService(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)
void	JobLeaderService.start(String initialOwnerAddress, RpcService initialRpcService, HighAvailabilityServices initialHighAvailabilityServices, JobLeaderListener initialJobLeaderListener) Start the job leader service with the given services.
void	DefaultJobLeaderService.start(String initialOwnerAddress, RpcService initialRpcService, HighAvailabilityServices initialHighAvailabilityServices, JobLeaderListener initialJobLeaderListener)
static TaskExecutor	TaskManagerRunner.startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, TaskExecutorBlobService taskExecutorBlobService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, WorkingDirectory workingDirectory, FatalErrorHandler fatalErrorHandler)

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type RpcService

Constructor and Description
TaskExecutor(RpcService rpcService, TaskManagerConfiguration taskManagerConfiguration, HighAvailabilityServices haServices, TaskManagerServices taskExecutorServices, ExternalResourceInfoProvider externalResourceInfoProvider, HeartbeatServices heartbeatServices, TaskManagerMetricGroup taskManagerMetricGroup, String metricQueryServiceAddress, TaskExecutorBlobService taskExecutorBlobService, FatalErrorHandler fatalErrorHandler, TaskExecutorPartitionTracker partitionTracker)
TaskExecutorToResourceManagerConnection(org.slf4j.Logger log, RpcService rpcService, RetryingRegistrationConfiguration retryingRegistrationConfiguration, String resourceManagerAddress, ResourceManagerId resourceManagerId, Executor executor, RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess,TaskExecutorRegistrationRejection> registrationListener, TaskExecutorRegistration taskExecutorRegistration)

Uses of RpcService in org.apache.flink.runtime.webmonitor.retriever.impl

Constructors in org.apache.flink.runtime.webmonitor.retriever.impl with parameters of type RpcService

Constructor and Description
RpcGatewayRetriever(RpcService rpcService, Class<T> gatewayType, java.util.function.Function<UUID,F> fencingTokenMapper, RetryStrategy retryStrategy)
RpcMetricQueryServiceRetriever(RpcService rpcService)