Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Class and Description |
---|---|
class |
Execution
A single execution of a vertex.
|
Modifier and Type | Method and Description |
---|---|
LogicalSlot.Payload |
SharedSlot.getPayload() |
LogicalSlot.Payload |
SimpleSlot.getPayload() |
Modifier and Type | Method and Description |
---|---|
boolean |
SharedSlot.tryAssignPayload(LogicalSlot.Payload payload) |
boolean |
SimpleSlot.tryAssignPayload(LogicalSlot.Payload payload)
Atomically sets the executed vertex, if no vertex has been assigned to this slot so far.
|
Modifier and Type | Field and Description |
---|---|
static LogicalSlot.Payload |
LogicalSlot.TERMINATED_PAYLOAD |
Modifier and Type | Method and Description |
---|---|
LogicalSlot.Payload |
LogicalSlot.getPayload()
Returns the set payload or null if none.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LogicalSlot.tryAssignPayload(LogicalSlot.Payload payload)
Tries to assign a payload to this slot.
|
Modifier and Type | Method and Description |
---|---|
LogicalSlot.Payload |
SingleLogicalSlot.getPayload() |
Modifier and Type | Method and Description |
---|---|
boolean |
SingleLogicalSlot.tryAssignPayload(LogicalSlot.Payload payload) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.