Uses of Interface
org.apache.flink.runtime.scheduler.adaptive.allocator.JobInformation

Packages that use JobInformation

Package	Description
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptive.allocator

Uses of JobInformation in org.apache.flink.runtime.scheduler.adaptive

Classes in org.apache.flink.runtime.scheduler.adaptive that implement JobInformation

Modifier and Type	Class	Description
class	JobGraphJobInformation	JobInformation created from a JobGraph.

Uses of JobInformation in org.apache.flink.runtime.scheduler.adaptive.allocator

Methods in org.apache.flink.runtime.scheduler.adaptive.allocator with parameters of type JobInformation

Modifier and Type	Method	Description
Collection<JobSchedulingPlan.SlotAssignment>	DefaultSlotAssigner.assignSlots(JobInformation jobInformation, Collection<PhysicalSlot> freeSlots, VertexParallelism vertexParallelism, JobAllocationsInformation previousAllocations)
Collection<JobSchedulingPlan.SlotAssignment>	SlotAssigner.assignSlots(JobInformation jobInformation, Collection<PhysicalSlot> freeSlots, VertexParallelism vertexParallelism, JobAllocationsInformation previousAllocations)
Collection<JobSchedulingPlan.SlotAssignment>	StateLocalitySlotAssigner.assignSlots(JobInformation jobInformation, Collection<PhysicalSlot> freeSlots, VertexParallelism vertexParallelism, JobAllocationsInformation previousAllocations)
Collection<org.apache.flink.runtime.scheduler.adaptive.allocator.StateLocalitySlotAssigner.AllocationScore>	StateLocalitySlotAssigner.calculateScore(SlotSharingSlotAllocator.ExecutionSlotSharingGroup group, Map<JobVertexID,Integer> parallelism, JobInformation jobInformation, JobAllocationsInformation previousAllocations)
Optional<VertexParallelism>	SlotAllocator.determineParallelism(JobInformation jobInformation, Collection<? extends SlotInfo> slots)	Determines the parallelism at which the vertices could be scheduled given the collection of slots.
Optional<VertexParallelism>	SlotSharingSlotAllocator.determineParallelism(JobInformation jobInformation, Collection<? extends SlotInfo> freeSlots)
Optional<JobSchedulingPlan>	SlotAllocator.determineParallelismAndCalculateAssignment(JobInformation jobInformation, Collection<PhysicalSlot> slots, JobAllocationsInformation jobAllocationsInformation)	Same as SlotAllocator.determineParallelism(JobInformation, Collection) but additionally determine assignment of slots to execution slot sharing groups.
Optional<JobSchedulingPlan>	SlotSharingSlotAllocator.determineParallelismAndCalculateAssignment(JobInformation jobInformation, Collection<PhysicalSlot> slots, JobAllocationsInformation jobAllocationsInformation)
Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	DefaultSlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)
Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	SlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)	Get the execution slot sharing groups for the job information based on the vertices parallelisms.
List<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	TaskBalancedSlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)