Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
Future<Iterable<SlotOffer>> |
SlotPoolGateway.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Iterable<SlotOffer> |
SlotPool.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Modifier and Type | Method and Description |
---|---|
Future<Iterable<SlotOffer>> |
SlotPoolGateway.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Iterable<SlotOffer> |
SlotPool.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
SlotOffer |
TaskSlot.generateSlotOffer()
Generate the slot offer from this TaskSlot.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.