Interface | Description |
---|---|
SlotAvailabilityListener |
Class | Description |
---|---|
CoLocationConstraint |
A CoLocationConstraint manages the location of a set of tasks
(Execution Vertices).
|
CoLocationGroup |
A Co-location group is a group of JobVertices, where the i-th subtask of one vertex
has to be executed on the same TaskManager as the i-th subtask of all
other JobVertices in the same group.
|
LifoSetQueue<E> |
A queue that returns elements in LIFO order and simultaneously maintains set characteristics, i.e., elements
that are already in the queue may not be added another time.
|
ScheduledUnit |
ScheduledUnit contains the information necessary to allocate a slot for the given
JobVertexID . |
Scheduler |
The scheduler is responsible for distributing the ready-to-run tasks among instances and slots.
|
SetQueue<E> |
A queue that maintains set characteristics, i.e., elements
that are already in the queue may not be added another time.
|
SlotSharingGroup |
A slot sharing units defines which different task (from different job vertices) can be
deployed together within a slot.
|
Enum | Description |
---|---|
Locality | |
LocationPreferenceConstraint |
Defines the location preference constraint.
|
Exception | Description |
---|---|
NoResourceAvailableException |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.