Package | Description |
---|---|
org.apache.flink.runtime.akka | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.jobmaster |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Optional<Instance>> |
AkkaJobManagerGateway.requestTaskManagerInstance(ResourceID resourceId,
Time timeout) |
CompletableFuture<Collection<Instance>> |
AkkaJobManagerGateway.requestTaskManagerInstances(Time timeout) |
Modifier and Type | Method and Description |
---|---|
Instance |
InstanceDiedException.getInstance() |
Instance |
InstanceManager.getRegisteredInstance(ResourceID ref) |
Instance |
InstanceManager.getRegisteredInstanceById(InstanceID instanceID) |
Modifier and Type | Method and Description |
---|---|
Collection<Instance> |
InstanceManager.getAllRegisteredInstances() |
Modifier and Type | Method and Description |
---|---|
void |
InstanceListener.instanceDied(Instance instance)
Called when an instance died.
|
void |
InstanceListener.newInstanceAvailable(Instance instance)
Called when a new instance becomes available.
|
Constructor and Description |
---|
InstanceDiedException(Instance instance) |
Modifier and Type | Method and Description |
---|---|
Instance |
Scheduler.getInstance(ResourceID resourceId) |
Modifier and Type | Method and Description |
---|---|
Map<String,List<Instance>> |
Scheduler.getInstancesByHost() |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.instanceDied(Instance instance) |
void |
Scheduler.newInstanceAvailable(Instance instance) |
void |
SlotAvailabilityListener.newSlotAvailable(Instance instance) |
void |
Scheduler.newSlotAvailable(Instance instance) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Optional<Instance>> |
JobManagerGateway.requestTaskManagerInstance(ResourceID resourceId,
Time timeout)
Requests the TaskManager instance registered under the given instanceId from the JobManager.
|
CompletableFuture<Collection<Instance>> |
JobManagerGateway.requestTaskManagerInstances(Time timeout)
Requests all currently registered TaskManager instances from the JobManager.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.