Package org.apache.flink.runtime.dispatcher

Class PartialDispatcherServices

java.lang.Object

org.apache.flink.runtime.dispatcher.PartialDispatcherServices

Direct Known Subclasses:

PartialDispatcherServicesWithJobPersistenceComponents

public class PartialDispatcherServices
extends Object

Partial DispatcherServices services container which needs to be completed before being given to the Dispatcher.

Constructor Summary

Constructors

Constructor

Description

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, Collection<FailureEnricher> failureEnrichers)

Method Summary

Modifier and Type	Method	Description
ExecutionGraphInfoStore	getArchivedExecutionGraphStore()
BlobServer	getBlobServer()
Configuration	getConfiguration()
Collection<FailureEnricher>	getFailureEnrichers()
FatalErrorHandler	getFatalErrorHandler()
HeartbeatServices	getHeartbeatServices()
HighAvailabilityServices	getHighAvailabilityServices()
HistoryServerArchivist	getHistoryServerArchivist()
Executor	getIoExecutor()
JobManagerMetricGroupFactory	getJobManagerMetricGroupFactory()
String	getMetricQueryServiceAddress()
DispatcherOperationCaches	getOperationCaches()
GatewayRetriever<ResourceManagerGateway>	getResourceManagerGatewayRetriever()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartialDispatcherServices

public PartialDispatcherServices(@Nonnull
                                 Configuration configuration,
                                 @Nonnull
                                 HighAvailabilityServices highAvailabilityServices,
                                 @Nonnull
                                 GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
                                 @Nonnull
                                 BlobServer blobServer,
                                 @Nonnull
                                 HeartbeatServices heartbeatServices,
                                 @Nonnull
                                 JobManagerMetricGroupFactory jobManagerMetricGroupFactory,
                                 @Nonnull
                                 ExecutionGraphInfoStore executionGraphInfoStore,
                                 @Nonnull
                                 FatalErrorHandler fatalErrorHandler,
                                 @Nonnull
                                 HistoryServerArchivist historyServerArchivist,
                                 @Nullable
                                 String metricQueryServiceAddress,
                                 @Nonnull
                                 Executor ioExecutor,
                                 @Nonnull
                                 DispatcherOperationCaches operationCaches,
                                 @Nonnull
                                 Collection<FailureEnricher> failureEnrichers)

Method Detail

getConfiguration

@Nonnull
public Configuration getConfiguration()

getHighAvailabilityServices

@Nonnull
public HighAvailabilityServices getHighAvailabilityServices()

getResourceManagerGatewayRetriever

@Nonnull
public GatewayRetriever<ResourceManagerGateway> getResourceManagerGatewayRetriever()

getBlobServer

@Nonnull
public BlobServer getBlobServer()

getHeartbeatServices

@Nonnull
public HeartbeatServices getHeartbeatServices()

getJobManagerMetricGroupFactory

@Nonnull
public JobManagerMetricGroupFactory getJobManagerMetricGroupFactory()

getArchivedExecutionGraphStore

@Nonnull
public ExecutionGraphInfoStore getArchivedExecutionGraphStore()

getFatalErrorHandler

@Nonnull
public FatalErrorHandler getFatalErrorHandler()

getHistoryServerArchivist

@Nonnull
public HistoryServerArchivist getHistoryServerArchivist()

getMetricQueryServiceAddress

@Nullable
public String getMetricQueryServiceAddress()

getOperationCaches

@Nonnull
public DispatcherOperationCaches getOperationCaches()

getIoExecutor

@Nonnull
public Executor getIoExecutor()

getFailureEnrichers

public Collection<FailureEnricher> getFailureEnrichers()