Uses of Class
org.apache.flink.runtime.heartbeat.HeartbeatServices

Packages that use HeartbeatServices

Package	Description
org.apache.flink.mesos.entrypoint
org.apache.flink.mesos.runtime.clusterframework
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.heartbeat
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.taskexecutor
org.apache.flink.yarn
org.apache.flink.yarn.entrypoint

Uses of HeartbeatServices in org.apache.flink.mesos.entrypoint

Methods in org.apache.flink.mesos.entrypoint with parameters of type HeartbeatServices

Modifier and Type	Method and Description
protected ResourceManager<?>	MesosJobClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
protected ResourceManager<?>	MesosSessionClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)

Uses of HeartbeatServices in org.apache.flink.mesos.runtime.clusterframework

Constructors in org.apache.flink.mesos.runtime.clusterframework with parameters of type HeartbeatServices

Constructor and Description

MesosResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, ResourceManagerConfiguration resourceManagerConfiguration, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, MetricRegistry metricRegistry, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, Configuration flinkConfig, MesosServices mesosServices, MesosConfiguration mesosConfig, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec, String webUiUrl, JobManagerMetricGroup jobManagerMetricGroup)

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

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

Modifier and Type	Method and Description
JobManagerRunner	Dispatcher.JobManagerRunnerFactory.createJobManagerRunner(ResourceID resourceId, JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, BlobServer blobServer, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler)
JobManagerRunner	Dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(ResourceID resourceId, JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, BlobServer blobServer, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler)

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

Constructor and Description
Dispatcher(RpcService rpcService, String endpointId, Configuration configuration, HighAvailabilityServices highAvailabilityServices, SubmittedJobGraphStore submittedJobGraphStore, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricServiceQueryPath, ArchivedExecutionGraphStore archivedExecutionGraphStore, Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
MiniDispatcher(RpcService rpcService, String endpointId, Configuration configuration, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist, JobGraph jobGraph, ClusterEntrypoint.ExecutionMode executionMode)
StandaloneDispatcher(RpcService rpcService, String endpointId, Configuration configuration, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)

Uses of HeartbeatServices in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint that return HeartbeatServices

Modifier and Type	Method and Description
protected HeartbeatServices	ClusterEntrypoint.createHeartbeatServices(Configuration configuration)

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

Modifier and Type	Method and Description
protected Dispatcher	JobClusterEntrypoint.createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
protected Dispatcher	SessionClusterEntrypoint.createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
protected abstract Dispatcher	ClusterEntrypoint.createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
protected abstract ResourceManager<?>	ClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
protected ResourceManager<?>	StandaloneSessionClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
protected void	ClusterEntrypoint.startClusterComponents(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry)

Uses of HeartbeatServices in org.apache.flink.runtime.heartbeat

Methods in org.apache.flink.runtime.heartbeat that return HeartbeatServices

Modifier and Type	Method and Description
static HeartbeatServices	HeartbeatServices.fromConfiguration(Configuration configuration) Creates an HeartbeatServices instance from a Configuration.

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

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

Constructor and Description
JobManagerRunner(ResourceID resourceId, JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices haServices, HeartbeatServices heartbeatServices, BlobServer blobServer, JobManagerSharedServices jobManagerSharedServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler) Exceptions that occur while creating the JobManager or JobManagerRunner are directly thrown and not reported to the given FatalErrorHandler.
JobMaster(RpcService rpcService, JobMasterConfiguration jobMasterConfiguration, ResourceID resourceId, JobGraph jobGraph, HighAvailabilityServices highAvailabilityService, SlotPoolFactory slotPoolFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, BlobServer blobServer, JobManagerJobMetricGroupFactory jobMetricGroupFactory, OnCompletionActions jobCompletionActions, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeLoader)

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

Methods in org.apache.flink.runtime.minicluster with parameters of type HeartbeatServices

Modifier and Type	Method and Description
protected ResourceManagerRunner	MiniCluster.startResourceManager(Configuration configuration, HighAvailabilityServices haServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, RpcService resourceManagerRpcService, ClusterInformation clusterInformation, JobManagerMetricGroup jobManagerMetricGroup)
protected TaskExecutor[]	MiniCluster.startTaskManagers(Configuration configuration, HighAvailabilityServices haServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, int numTaskManagers, RpcService[] taskManagerRpcServices)

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

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

Constructor and Description
ResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, ResourceManagerConfiguration resourceManagerConfiguration, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, MetricRegistry metricRegistry, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, JobManagerMetricGroup jobManagerMetricGroup)
ResourceManagerRunner(ResourceID resourceId, String resourceManagerEndpointId, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ClusterInformation clusterInformation, JobManagerMetricGroup jobManagerMetricGroup)
StandaloneResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, ResourceManagerConfiguration resourceManagerConfiguration, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, MetricRegistry metricRegistry, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, JobManagerMetricGroup jobManagerMetricGroup)

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

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

Modifier and Type	Method and Description
static TaskExecutor	TaskManagerRunner.startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, FatalErrorHandler fatalErrorHandler)

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

Constructor and Description
TaskExecutor(RpcService rpcService, TaskManagerConfiguration taskManagerConfiguration, HighAvailabilityServices haServices, TaskManagerServices taskExecutorServices, HeartbeatServices heartbeatServices, TaskManagerMetricGroup taskManagerMetricGroup, BlobCacheService blobCacheService, FatalErrorHandler fatalErrorHandler)

Uses of HeartbeatServices in org.apache.flink.yarn

Constructors in org.apache.flink.yarn with parameters of type HeartbeatServices

Constructor and Description

YarnResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, Configuration flinkConfig, Map<String,String> env, ResourceManagerConfiguration resourceManagerConfiguration, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, MetricRegistry metricRegistry, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)

Uses of HeartbeatServices in org.apache.flink.yarn.entrypoint

Methods in org.apache.flink.yarn.entrypoint with parameters of type HeartbeatServices

Modifier and Type	Method and Description
protected ResourceManager<?>	YarnJobClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
protected ResourceManager<?>	YarnSessionClusterEntrypoint.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)