public class DefaultDispatcherResourceManagerComponentFactory extends Object implements DispatcherResourceManagerComponentFactory
DispatcherResourceManagerComponent
components.Constructor and Description |
---|
DefaultDispatcherResourceManagerComponentFactory(DispatcherRunnerFactory dispatcherRunnerFactory,
ResourceManagerFactory<?> resourceManagerFactory,
RestEndpointFactory<?> restEndpointFactory) |
Modifier and Type | Method and Description |
---|---|
DispatcherResourceManagerComponent |
create(Configuration configuration,
ResourceID resourceId,
Executor ioExecutor,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
DelegationTokenManager delegationTokenManager,
MetricRegistry metricRegistry,
ExecutionGraphInfoStore executionGraphInfoStore,
MetricQueryServiceRetriever metricQueryServiceRetriever,
Collection<FailureEnricher> failureEnrichers,
FatalErrorHandler fatalErrorHandler) |
static DefaultDispatcherResourceManagerComponentFactory |
createJobComponentFactory(ResourceManagerFactory<?> resourceManagerFactory,
JobGraphRetriever jobGraphRetriever) |
static DefaultDispatcherResourceManagerComponentFactory |
createSessionComponentFactory(ResourceManagerFactory<?> resourceManagerFactory) |
public DefaultDispatcherResourceManagerComponentFactory(@Nonnull DispatcherRunnerFactory dispatcherRunnerFactory, @Nonnull ResourceManagerFactory<?> resourceManagerFactory, @Nonnull RestEndpointFactory<?> restEndpointFactory)
public DispatcherResourceManagerComponent create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, Collection<FailureEnricher> failureEnrichers, FatalErrorHandler fatalErrorHandler) throws Exception
create
in interface DispatcherResourceManagerComponentFactory
Exception
public static DefaultDispatcherResourceManagerComponentFactory createSessionComponentFactory(ResourceManagerFactory<?> resourceManagerFactory)
public static DefaultDispatcherResourceManagerComponentFactory createJobComponentFactory(ResourceManagerFactory<?> resourceManagerFactory, JobGraphRetriever jobGraphRetriever)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.