Modifier and Type | Method and Description |
---|---|
ResourceID |
RegisteredMesosWorkerNode.getResourceID() |
protected static ResourceID |
MesosTaskManager.resourceID() |
Modifier and Type | Method and Description |
---|---|
protected void |
MesosFlinkResourceManager.releasePendingWorker(ResourceID id)
Release the given pending worker.
|
protected RegisteredMesosWorkerNode |
MesosFlinkResourceManager.workerStarted(ResourceID resourceID)
Accept the given started worker into the internal state.
|
Modifier and Type | Method and Description |
---|---|
protected Collection<RegisteredMesosWorkerNode> |
MesosFlinkResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate)
Accept the given registered workers into the internal state.
|
Constructor and Description |
---|
MesosTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
boolean |
FlinkResourceManager.isStarted(ResourceID resourceId)
Gets the started worker for a given resource ID, if one is available.
|
void |
FlinkResourceManager.notifyWorkerFailed(ResourceID resourceID,
String message)
This method should be called by the framework once it detects that a currently registered
worker has failed.
|
protected abstract void |
FlinkResourceManager.releasePendingWorker(ResourceID resourceID)
Trigger a release of a pending worker.
|
protected abstract WorkerType |
FlinkResourceManager.workerStarted(ResourceID resourceID)
Callback when a worker was started.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Collection<WorkerType> |
FlinkResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> registered)
This method is called when the resource manager starts after a failure and reconnects to
the leader JobManager, who still has some workers registered.
|
Modifier and Type | Method and Description |
---|---|
ResourceID |
NotifyResourceStarted.getResourceID() |
ResourceID |
ResourceRemoved.resourceId()
Gets the ID under which the resource is registered (for example container ID).
|
ResourceID |
RemoveResource.resourceId()
Gets the ID under which the resource is registered (for example container ID).
|
Modifier and Type | Method and Description |
---|---|
Collection<ResourceID> |
RegisterResourceManagerSuccessful.currentlyRegisteredTaskManagers() |
Constructor and Description |
---|
NotifyResourceStarted(ResourceID resourceID) |
RemoveResource(ResourceID resourceId)
Constructor for a shutdown of a registered resource.
|
ResourceRemoved(ResourceID resourceId,
String message)
Constructor for a shutdown of a registered resource.
|
Constructor and Description |
---|
RegisterResourceManagerSuccessful(akka.actor.ActorRef jobManager,
Collection<ResourceID> currentlyRegisteredTaskManagers)
Creates a new message with a list of existing known TaskManagers.
|
Modifier and Type | Method and Description |
---|---|
protected ResourceID |
StandaloneResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected Collection<ResourceID> |
StandaloneResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) |
Modifier and Type | Method and Description |
---|---|
protected void |
StandaloneResourceManager.releasePendingWorker(ResourceID resourceID) |
protected void |
StandaloneResourceManager.releaseStartedWorker(ResourceID resourceID) |
protected ResourceID |
StandaloneResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected Collection<ResourceID> |
StandaloneResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) |
Modifier and Type | Method and Description |
---|---|
static ResourceID |
ResourceID.generate()
Generate a random resource id.
|
ResourceID |
SlotID.getResourceID() |
ResourceID |
ResourceIDRetrievable.getResourceID()
Gets the ResourceID of the object.
|
ResourceID |
ResourceID.getResourceID()
A ResourceID can always retrieve a ResourceID.
|
Constructor and Description |
---|
SlotID(ResourceID resourceId,
int slotNumber) |
Modifier and Type | Method and Description |
---|---|
<I,O> HeartbeatManager<I,O> |
HeartbeatServices.createHeartbeatManager(ResourceID resourceId,
HeartbeatListener<I,O> heartbeatListener,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger log)
Creates a heartbeat manager which does not actively send heartbeats.
|
<I,O> HeartbeatManager<I,O> |
HeartbeatServices.createHeartbeatManagerSender(ResourceID resourceId,
HeartbeatListener<I,O> heartbeatListener,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger log)
Creates a heartbeat manager which actively sends heartbeats to monitoring targets.
|
void |
HeartbeatManagerImpl.monitorTarget(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget) |
void |
HeartbeatManager.monitorTarget(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget)
Start monitoring a
HeartbeatTarget . |
void |
HeartbeatListener.notifyHeartbeatTimeout(ResourceID resourceID)
Callback which is called if a heartbeat for the machine identified by the given resource
ID times out.
|
void |
HeartbeatTarget.receiveHeartbeat(ResourceID heartbeatOrigin,
I heartbeatPayload)
Sends a heartbeat response to the target.
|
void |
HeartbeatManagerImpl.receiveHeartbeat(ResourceID heartbeatOrigin,
I heartbeatPayload) |
void |
HeartbeatListener.reportPayload(ResourceID resourceID,
I payload)
Callback which is called whenever a heartbeat with an associated payload is received.
|
void |
HeartbeatTarget.requestHeartbeat(ResourceID requestOrigin,
I heartbeatPayload)
Requests a heartbeat from the target.
|
void |
HeartbeatManagerImpl.requestHeartbeat(ResourceID requestOrigin,
I heartbeatPayload) |
void |
HeartbeatManagerImpl.unmonitorTarget(ResourceID resourceID) |
void |
HeartbeatManager.unmonitorTarget(ResourceID resourceID)
Stops monitoring the heartbeat target with the associated resource ID.
|
Constructor and Description |
---|
HeartbeatManagerImpl(long heartbeatTimeoutIntervalMs,
ResourceID ownResourceID,
HeartbeatListener<I,O> heartbeatListener,
Executor executor,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger log) |
HeartbeatManagerSenderImpl(long heartbeatPeriod,
long heartbeatTimeout,
ResourceID ownResourceID,
HeartbeatListener<I,O> heartbeatListener,
Executor executor,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger log) |
Modifier and Type | Method and Description |
---|---|
ResourceID |
Slot.getTaskManagerID()
Gets the ID of the TaskManager that offers this slot.
|
ResourceID |
Instance.getTaskManagerID() |
Modifier and Type | Method and Description |
---|---|
Instance |
InstanceManager.getRegisteredInstance(ResourceID ref) |
boolean |
InstanceManager.isRegistered(ResourceID resourceId) |
void |
SlotPoolGateway.registerTaskManager(ResourceID resourceID) |
void |
SlotPool.registerTaskManager(ResourceID resourceID)
Register TaskManager to this pool, only those slots come from registered TaskManager will be considered valid.
|
void |
SlotPoolGateway.releaseTaskManager(ResourceID resourceID) |
void |
SlotPool.releaseTaskManager(ResourceID resourceID)
Unregister TaskManager from this pool, all the related slots will be released and tasks be canceled.
|
Modifier and Type | Method and Description |
---|---|
ResourceID |
AllocatedSlot.getTaskManagerId()
Gets the ID of the TaskManager on which this slot was allocated.
|
Modifier and Type | Method and Description |
---|---|
ResourceID |
JMTMRegistrationSuccess.getResourceID() |
ResourceID |
JobMasterRegistrationSuccess.getResourceManagerResourceId() |
Modifier and Type | Method and Description |
---|---|
void |
JobMasterGateway.disconnectTaskManager(ResourceID resourceID,
Exception cause)
Disconnects the given
TaskExecutor from the
JobMaster . |
void |
JobMaster.disconnectTaskManager(ResourceID resourceID,
Exception cause) |
void |
JobMasterGateway.failSlot(ResourceID taskManagerId,
AllocationID allocationId,
UUID leaderId,
Exception cause)
Fail the slot with the given allocation id and cause.
|
void |
JobMaster.failSlot(ResourceID taskManagerId,
AllocationID allocationId,
UUID leaderId,
Exception cause) |
void |
JobMasterGateway.heartbeatFromResourceManager(ResourceID resourceID)
Heartbeat request from the resource manager
|
void |
JobMaster.heartbeatFromResourceManager(ResourceID resourceID) |
void |
JobMasterGateway.heartbeatFromTaskManager(ResourceID resourceID)
Send the heartbeat to job manager from task manager
|
void |
JobMaster.heartbeatFromTaskManager(ResourceID resourceID) |
Future<Iterable<SlotOffer>> |
JobMaster.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId) |
Future<Iterable<SlotOffer>> |
JobMasterGateway.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId,
Time timeout)
Offer the given slots to the job manager.
|
Constructor and Description |
---|
JMTMRegistrationSuccess(ResourceID resourceID,
int blobPort) |
JobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
JobManagerServices jobManagerServices,
MetricRegistry metricRegistry,
OnCompletionActions toNotifyOnComplete,
FatalErrorHandler errorHandler)
Exceptions that occur while creating the JobManager or JobManagerRunner are directly
thrown and not reported to the given
FatalErrorHandler . |
JobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
OnCompletionActions toNotifyOnComplete,
FatalErrorHandler errorHandler) |
JobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
OnCompletionActions toNotifyOnComplete,
FatalErrorHandler errorHandler) |
JobMaster(RpcService rpcService,
ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
HighAvailabilityServices highAvailabilityService,
HeartbeatServices heartbeatServices,
ScheduledExecutorService executor,
BlobLibraryCacheManager libraryCacheManager,
RestartStrategyFactory restartStrategyFactory,
Time rpcAskTimeout,
JobManagerMetricGroup jobManagerMetricGroup,
OnCompletionActions jobCompletionActions,
FatalErrorHandler errorHandler,
ClassLoader userCodeLoader) |
JobMasterRegistrationSuccess(long heartbeatInterval,
UUID resourceManagerLeaderId,
ResourceID resourceManagerResourceId) |
Modifier and Type | Method and Description |
---|---|
ResourceID |
RegistrationMessages.RegisterTaskManager.resourceId() |
Constructor and Description |
---|
RegisterTaskManager(ResourceID resourceId,
TaskManagerLocation connectionInfo,
HardwareDescription resources,
int numberOfSlots) |
Modifier and Type | Method and Description |
---|---|
void |
MetricRegistry.startQueryService(akka.actor.ActorSystem actorSystem,
ResourceID resourceID)
Initializes the MetricQueryService.
|
Modifier and Type | Method and Description |
---|---|
static akka.actor.ActorRef |
MetricQueryService.startMetricQueryService(akka.actor.ActorSystem actorSystem,
ResourceID resourceID)
Starts the MetricQueryService actor in the given actor system.
|
Modifier and Type | Method and Description |
---|---|
akka.actor.Props |
LocalFlinkMiniCluster.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
MetricRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
protected ResourceID |
StandaloneResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected void |
ResourceManager.closeTaskManagerConnection(ResourceID resourceID,
Exception cause)
This method should be called by the framework once it detects that a currently registered
task executor has failed.
|
void |
ResourceManagerGateway.disconnectTaskManager(ResourceID resourceID,
Exception cause)
Disconnects a TaskManager specified by the given resourceID from the
ResourceManager . |
void |
ResourceManager.disconnectTaskManager(ResourceID resourceId,
Exception cause) |
void |
ResourceManagerGateway.heartbeatFromJobManager(ResourceID heartbeatOrigin)
Sends the heartbeat to resource manager from job manager
|
void |
ResourceManager.heartbeatFromJobManager(ResourceID resourceID) |
void |
ResourceManagerGateway.heartbeatFromTaskManager(ResourceID heartbeatOrigin)
Sends the heartbeat to resource manager from task manager
|
void |
ResourceManager.heartbeatFromTaskManager(ResourceID resourceID) |
Future<RegistrationResponse> |
ResourceManager.registerJobManager(UUID resourceManagerLeaderId,
UUID jobManagerLeaderId,
ResourceID jobManagerResourceId,
String jobManagerAddress,
JobID jobId) |
Future<RegistrationResponse> |
ResourceManagerGateway.registerJobManager(UUID resourceManagerLeaderId,
UUID jobMasterLeaderId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobID,
Time timeout)
Register a
JobMaster at the resource manager. |
Future<RegistrationResponse> |
ResourceManager.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID taskExecutorResourceId,
SlotReport slotReport)
Register a
TaskExecutor at the resource manager |
Future<RegistrationResponse> |
ResourceManagerGateway.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID resourceID,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
protected ResourceID |
StandaloneResourceManager.workerStarted(ResourceID resourceID) |
protected abstract WorkerType |
ResourceManager.workerStarted(ResourceID resourceID)
Callback when a worker was started.
|
Constructor and Description |
---|
ResourceManager(RpcService rpcService,
String resourceManagerEndpointId,
ResourceID resourceId,
ResourceManagerConfiguration resourceManagerConfiguration,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
MetricRegistry metricRegistry,
JobLeaderIdService jobLeaderIdService,
FatalErrorHandler fatalErrorHandler) |
ResourceManagerRunner(ResourceID resourceId,
String resourceManagerEndpointId,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry) |
StandaloneResourceManager(RpcService rpcService,
String resourceManagerEndpointId,
ResourceID resourceId,
ResourceManagerConfiguration resourceManagerConfiguration,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
MetricRegistry metricRegistry,
JobLeaderIdService jobLeaderIdService,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
ResourceID |
JobManagerRegistration.getJobManagerResourceID() |
Constructor and Description |
---|
JobManagerRegistration(JobID jobID,
ResourceID jobManagerResourceID,
UUID leaderID,
JobMasterGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
ResourceID |
TaskExecutor.getResourceID() |
ResourceID |
JobManagerConnection.getResourceID() |
ResourceID |
TaskExecutorToResourceManagerConnection.getResourceManagerId()
Gets the unique id of ResourceManager, that is returned when registration success.
|
ResourceID |
TaskExecutorRegistrationSuccess.getResourceManagerId()
Gets the unique ID that identifies the ResourceManager.
|
Modifier and Type | Method and Description |
---|---|
static TaskManagerServices |
TaskManagerServices.fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration,
ResourceID resourceID)
Creates and returns the task manager services.
|
void |
TaskExecutorGateway.heartbeatFromJobManager(ResourceID heartbeatOrigin)
Heartbeat request from the job manager
|
void |
TaskExecutor.heartbeatFromJobManager(ResourceID resourceID) |
void |
TaskExecutorGateway.heartbeatFromResourceManager(ResourceID heartbeatOrigin)
Heartbeat request from the resource manager
|
void |
TaskExecutor.heartbeatFromResourceManager(ResourceID resourceID) |
Constructor and Description |
---|
JobManagerConnection(JobID jobID,
ResourceID resourceID,
JobMasterGateway jobMasterGateway,
UUID leaderId,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
LibraryCacheManager libraryCacheManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker) |
TaskExecutorRegistrationSuccess(InstanceID registrationId,
ResourceID resourceManagerResourceId,
long heartbeatInterval)
Create a new
TaskExecutorRegistrationSuccess message. |
TaskExecutorToResourceManagerConnection(org.slf4j.Logger log,
RpcService rpcService,
String taskManagerAddress,
ResourceID taskManagerResourceId,
SlotReport slotReport,
String resourceManagerAddress,
UUID resourceManagerLeaderId,
Executor executor,
RegistrationConnectionListener<TaskExecutorRegistrationSuccess> registrationListener) |
TaskManagerRunner(Configuration configuration,
ResourceID resourceID,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry) |
TaskManagerRunner(Configuration configuration,
ResourceID resourceID,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
boolean localCommunicationOnly) |
Modifier and Type | Method and Description |
---|---|
SlotReport |
TaskSlotTable.createSlotReport(ResourceID resourceId) |
Modifier and Type | Method and Description |
---|---|
ResourceID |
TaskManagerLocation.getResourceID()
Gets the ID of the resource in which the TaskManager is started.
|
protected ResourceID |
TaskManager.resourceID() |
Modifier and Type | Method and Description |
---|---|
akka.actor.Props |
TaskManager$.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
static akka.actor.Props |
TaskManager.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
void |
TaskManager$.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices)
Starts and runs the TaskManager.
|
static void |
TaskManager.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices)
Starts and runs the TaskManager.
|
void |
TaskManager$.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
static void |
TaskManager.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
void |
TaskManager$.selectNetworkInterfaceAndRunTaskManager(Configuration configuration,
ResourceID resourceID,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
static void |
TaskManager.selectNetworkInterfaceAndRunTaskManager(Configuration configuration,
ResourceID resourceID,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
akka.actor.ActorRef |
TaskManager$.startTaskManagerComponentsAndActor(Configuration configuration,
ResourceID resourceID,
akka.actor.ActorSystem actorSystem,
HighAvailabilityServices highAvailabilityServices,
String taskManagerHostname,
scala.Option<String> taskManagerActorName,
boolean localTaskManagerCommunication,
Class<? extends TaskManager> taskManagerClass)
Starts the task manager actor.
|
static akka.actor.ActorRef |
TaskManager.startTaskManagerComponentsAndActor(Configuration configuration,
ResourceID resourceID,
akka.actor.ActorSystem actorSystem,
HighAvailabilityServices highAvailabilityServices,
String taskManagerHostname,
scala.Option<String> taskManagerActorName,
boolean localTaskManagerCommunication,
Class<? extends TaskManager> taskManagerClass)
Starts the task manager actor.
|
Constructor and Description |
---|
TaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation location,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
TaskManagerLocation(ResourceID resourceID,
InetAddress inetAddress,
int dataPort)
Constructs a new instance connection info object.
|
Modifier and Type | Method and Description |
---|---|
ResourceID |
YarnContainerInLaunch.getResourceID() |
ResourceID |
RegisteredYarnWorkerNode.getResourceID() |
protected static ResourceID |
YarnTaskManager.resourceID() |
protected ResourceID |
YarnResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected void |
YarnFlinkResourceManager.releasePendingWorker(ResourceID id) |
protected ResourceID |
YarnResourceManager.workerStarted(ResourceID resourceID) |
protected RegisteredYarnWorkerNode |
YarnFlinkResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected Collection<RegisteredYarnWorkerNode> |
YarnFlinkResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) |
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,
FatalErrorHandler fatalErrorHandler) |
YarnTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricRegistry) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.